78Assert.Equal(100, collectorProducerQueueMessageCount.LastMeasurement!.Value); 79Assert.Contains(collectorProducerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 80Assert.Contains(collectorProducerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 82Assert.Equal(100, collectorConsumerQueueMessageCount.LastMeasurement!.Value); 83Assert.Contains(collectorConsumerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 84Assert.Contains(collectorConsumerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 86Assert.Equal(1638400, collectorProducerQueueSize.LastMeasurement!.Value); 87Assert.Contains(collectorProducerQueueSize.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 88Assert.Contains(collectorProducerQueueSize.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 90Assert.Equal(5, collectorNetworkTx.LastMeasurement!.Value); 91Assert.Contains(collectorNetworkTx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 92Assert.Contains(collectorNetworkTx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 93Assert.Contains(collectorNetworkTx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 95Assert.Equal(1638400, collectorNetworkTransmitted.LastMeasurement!.Value); 96Assert.Contains(collectorNetworkTransmitted.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 97Assert.Contains(collectorNetworkTransmitted.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 98Assert.Contains(collectorNetworkTransmitted.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 100Assert.Equal(5, collectorNetworkRx.LastMeasurement!.Value); 101Assert.Contains(collectorNetworkRx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 102Assert.Contains(collectorNetworkRx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 103Assert.Contains(collectorNetworkRx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 105Assert.Equal(1638400, collectorNetworkReceived.LastMeasurement!.Value); 106Assert.Contains(collectorNetworkReceived.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 107Assert.Contains(collectorNetworkReceived.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 108Assert.Contains(collectorNetworkReceived.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 110Assert.Equal(5, collectorMessageTx.LastMeasurement!.Value); 111Assert.Contains(collectorMessageTx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 112Assert.Contains(collectorMessageTx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 113Assert.Contains(collectorMessageTx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 115Assert.Equal(1638400, collectorMessageTransmitted.LastMeasurement!.Value); 116Assert.Contains(collectorMessageTransmitted.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 117Assert.Contains(collectorMessageTransmitted.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 118Assert.Contains(collectorMessageTransmitted.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 120Assert.Equal(5, collectorMessageRx.LastMeasurement!.Value); 121Assert.Contains(collectorMessageRx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 122Assert.Contains(collectorMessageRx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 123Assert.Contains(collectorMessageRx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 125Assert.Equal(1638400, collectorMessageReceived.LastMeasurement!.Value); 126Assert.Contains(collectorMessageReceived.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 127Assert.Contains(collectorMessageReceived.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 128Assert.Contains(collectorMessageReceived.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 193Assert.Equal(200, collectorProducerQueueMessageCount.LastMeasurement!.Value); 194Assert.Contains(collectorProducerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 195Assert.Contains(collectorProducerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 197Assert.Equal(200, collectorConsumerQueueMessageCount.LastMeasurement!.Value); 198Assert.Contains(collectorConsumerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 199Assert.Contains(collectorConsumerQueueMessageCount.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 201Assert.Equal(3276800, collectorProducerQueueSize.LastMeasurement!.Value); 202Assert.Contains(collectorProducerQueueSize.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 203Assert.Contains(collectorProducerQueueSize.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 205Assert.Equal(5, collectorNetworkTx.LastMeasurement!.Value); 206Assert.Contains(collectorNetworkTx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 207Assert.Contains(collectorNetworkTx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 208Assert.Contains(collectorNetworkTx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 210Assert.Equal(1638400, collectorNetworkTransmitted.LastMeasurement!.Value); 211Assert.Contains(collectorNetworkTransmitted.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 212Assert.Contains(collectorNetworkTransmitted.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 213Assert.Contains(collectorNetworkTransmitted.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 215Assert.Equal(5, collectorNetworkRx.LastMeasurement!.Value); 216Assert.Contains(collectorNetworkRx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 217Assert.Contains(collectorNetworkRx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 218Assert.Contains(collectorNetworkRx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 220Assert.Equal(1638400, collectorNetworkReceived.LastMeasurement!.Value); 221Assert.Contains(collectorNetworkReceived.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 222Assert.Contains(collectorNetworkReceived.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 223Assert.Contains(collectorNetworkReceived.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 225Assert.Equal(5, collectorMessageTx.LastMeasurement!.Value); 226Assert.Contains(collectorMessageTx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 227Assert.Contains(collectorMessageTx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 228Assert.Contains(collectorMessageTx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 230Assert.Equal(1638400, collectorMessageTransmitted.LastMeasurement!.Value); 231Assert.Contains(collectorMessageTransmitted.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 232Assert.Contains(collectorMessageTransmitted.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 233Assert.Contains(collectorMessageTransmitted.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 235Assert.Equal(5, collectorMessageRx.LastMeasurement!.Value); 236Assert.Contains(collectorMessageRx.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 237Assert.Contains(collectorMessageRx.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 238Assert.Contains(collectorMessageRx.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer"); 240Assert.Equal(1638400, collectorMessageReceived.LastMeasurement!.Value); 241Assert.Contains(collectorMessageReceived.LastMeasurement!.Tags, t => t.Key == "messaging.client_id" && t.Value!.ToString() == "rdkafka"); 242Assert.Contains(collectorMessageReceived.LastMeasurement!.Tags, t => t.Key == "name" && t.Value!.ToString() == "rdkafka#producer-1"); 243Assert.Contains(collectorMessageReceived.LastMeasurement!.Tags, t => t.Key == "type" && t.Value!.ToString() == "producer");

150var latest = metricCollector.LastMeasurement; 208var latest = metricCollector.LastMeasurement;

109var latest = healthyMetricCollector.LastMeasurement;

240Assert.NotNull(metricCollector.LastMeasurement); 241Assert.True(double.IsNaN(metricCollector.LastMeasurement.Value)); 247Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Consumed 10% of the CPU. 254Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Still consuming 10% as gauge wasn't updated. 261Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Consumed 10% of the CPU. 309Assert.NotNull(metricCollector.LastMeasurement?.Value); 310Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Consuming 10% of the memory initially. 315Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Still consuming 10% as gauge wasn't updated. 320Assert.Equal(0.3 * multiplier, metricCollector.LastMeasurement.Value); // Consuming 30% of the memory afterwards.

100Assert.NotNull(metricCollector.LastMeasurement); 101Assert.True(double.IsNaN(metricCollector.LastMeasurement.Value)); 106Assert.Equal(0.05 * multiplier, metricCollector.LastMeasurement?.Value); // Consuming 5% of the CPU (2 CPUs, 1000 ticks, 1ms). 113Assert.Equal(0.05 * multiplier, metricCollector.LastMeasurement?.Value); // Still consuming 5% of the CPU 139Assert.NotNull(metricCollector.LastMeasurement); 140Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Consuming 5% of the memory initially 148Assert.Equal(0.1 * multiplier, metricCollector.LastMeasurement.Value); // Still consuming 10% as gauge wasn't updated. 154Assert.Equal(0.3 * multiplier, metricCollector.LastMeasurement.Value); // Consuming 30% of the memory afterwards 163Assert.Equal(1 * multiplier, Math.Round(metricCollector.LastMeasurement.Value)); // Consuming 100% of the memory

53Assert.Null(collector.LastMeasurement); 60Assert.NotNull(collector.LastMeasurement); 64Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 65Assert.Equal(3, collector.LastMeasurement.Value); 66Assert.Empty(collector.LastMeasurement.Tags); 67Assert.Equal(now, collector.LastMeasurement.Timestamp); 74Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 75Assert.Equal(2, collector.LastMeasurement.Value); 76Assert.Empty(collector.LastMeasurement.Tags); 77Assert.Equal(timeProvider.GetUtcNow(), collector.LastMeasurement.Timestamp); 82Assert.Null(collector.LastMeasurement); 83Assert.Null(collector.LastMeasurement); 99Assert.Null(collector.LastMeasurement); 105Assert.NotNull(collector.LastMeasurement); 109Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 110Assert.Equal(3, collector.LastMeasurement.Value); 111Assert.Empty(collector.LastMeasurement.Tags); 112Assert.Equal(now, collector.LastMeasurement.Timestamp); 119Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 120Assert.Equal(2, collector.LastMeasurement.Value); 121Assert.Empty(collector.LastMeasurement.Tags); 122Assert.Equal(timeProvider.GetUtcNow(), collector.LastMeasurement.Timestamp); 127Assert.Null(collector.LastMeasurement); 128Assert.Null(collector.LastMeasurement); 146Assert.Null(collector.LastMeasurement); 152Assert.NotNull(collector.LastMeasurement); 156Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 157Assert.Equal(3, collector.LastMeasurement.Value); 158Assert.Empty(collector.LastMeasurement.Tags); 159Assert.Equal(now, collector.LastMeasurement.Timestamp); 166Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 167Assert.Equal(2, collector.LastMeasurement.Value); 168Assert.Empty(collector.LastMeasurement.Tags); 169Assert.Equal(timeProvider.GetUtcNow(), collector.LastMeasurement.Timestamp); 174Assert.Null(collector.LastMeasurement); 175Assert.Null(collector.LastMeasurement); 177Assert.Null(collector2.LastMeasurement); 207Assert.Null(collector.LastMeasurement); 213Assert.NotNull(collector.LastMeasurement); 217Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 218Assert.Equal(3, collector.LastMeasurement.Value); 219Assert.Empty(collector.LastMeasurement.Tags); 220Assert.Equal(now, collector.LastMeasurement.Timestamp); 227Assert.Same(collector.GetMeasurementSnapshot().Last(), collector.LastMeasurement); 228Assert.Equal(2, collector.LastMeasurement.Value); 229Assert.Empty(collector.LastMeasurement.Tags); 230Assert.Equal(timeProvider.GetUtcNow(), collector.LastMeasurement.Timestamp); 363Assert.Throws<ObjectDisposedException>(() => collector.LastMeasurement);