62 instantiations of Measurement
Aspire.Confluent.Kafka (3)
MetricsService.cs (3)
46metrics.ReplyQueueMeasurements.Enqueue(new Measurement<long>(statistics.ReplyQueue, tags)); 47metrics.MessageCountMeasurements.Enqueue(new Measurement<long>(statistics.MessageCount, tags)); 48metrics.MessageSizeMeasurements.Enqueue(new Measurement<long>(statistics.MessageSize, tags));
Interop.FunctionalTests (1)
Http2\Http2RequestTests.cs (1)
55measurementTcs.SetResult(new Measurement<double>(measurement, tags));
Microsoft.Extensions.Diagnostics.ResourceMonitoring (50)
Linux\Disk\LinuxSystemDiskMetrics.cs (5)
104measurements.Add(new Measurement<long>(readBytes, new TagList { _directionReadTag, new(DeviceKey, diskStats.DeviceName) })); 105measurements.Add(new Measurement<long>(writeBytes, new TagList { _directionWriteTag, new(DeviceKey, diskStats.DeviceName) })); 121measurements.Add(new Measurement<long>(readCount, new TagList { _directionReadTag, new(DeviceKey, diskStats.DeviceName) })); 122measurements.Add(new Measurement<long>(writeCount, new TagList { _directionWriteTag, new(DeviceKey, diskStats.DeviceName) })); 137measurements.Add(new Measurement<double>(ioTimeSeconds, new TagList { new(DeviceKey, diskStats.DeviceName) }));
Linux\LinuxUtilizationProvider.cs (3)
274return new[] { new Measurement<double>(value) }; 315yield return new Measurement<double>(systemCpuTime / NanosecondsInSecond, [new KeyValuePair<string, object?>("cpu.mode", "system")]); 320yield return new Measurement<double>(userCpuTime, [new KeyValuePair<string, object?>("cpu.mode", "user")]);
Linux\Network\LinuxNetworkMetrics.cs (11)
75measurements.Add(new Measurement<long>(state.ClosedCount, new TagList { tcpVersionTag, new(NetworkStateKey, "close") })); 76measurements.Add(new Measurement<long>(state.ListenCount, new TagList { tcpVersionTag, new(NetworkStateKey, "listen") })); 77measurements.Add(new Measurement<long>(state.SynSentCount, new TagList { tcpVersionTag, new(NetworkStateKey, "syn_sent") })); 78measurements.Add(new Measurement<long>(state.SynRcvdCount, new TagList { tcpVersionTag, new(NetworkStateKey, "syn_recv") })); 79measurements.Add(new Measurement<long>(state.EstabCount, new TagList { tcpVersionTag, new(NetworkStateKey, "established") })); 80measurements.Add(new Measurement<long>(state.FinWait1Count, new TagList { tcpVersionTag, new(NetworkStateKey, "fin_wait_1") })); 81measurements.Add(new Measurement<long>(state.FinWait2Count, new TagList { tcpVersionTag, new(NetworkStateKey, "fin_wait_2") })); 82measurements.Add(new Measurement<long>(state.CloseWaitCount, new TagList { tcpVersionTag, new(NetworkStateKey, "close_wait") })); 83measurements.Add(new Measurement<long>(state.ClosingCount, new TagList { tcpVersionTag, new(NetworkStateKey, "closing") })); 84measurements.Add(new Measurement<long>(state.LastAckCount, new TagList { tcpVersionTag, new(NetworkStateKey, "last_ack") })); 85measurements.Add(new Measurement<long>(state.TimeWaitCount, new TagList { tcpVersionTag, new(NetworkStateKey, "time_wait") }));
Windows\Disk\WindowsDiskMetrics.cs (5)
143measurements.Add(new Measurement<long>(pair.Value, new TagList { _directionWriteTag, new(DeviceKey, pair.Key) })); 152measurements.Add(new Measurement<long>(pair.Value, new TagList { _directionReadTag, new(DeviceKey, pair.Key) })); 168measurements.Add(new Measurement<long>(pair.Value, new TagList { _directionWriteTag, new(DeviceKey, pair.Key) })); 177measurements.Add(new Measurement<long>(pair.Value, new TagList { _directionReadTag, new(DeviceKey, pair.Key) })); 192measurements.Add(new Measurement<double>(pair.Value, new TagList { new(DeviceKey, pair.Key) }));
Windows\Network\WindowsNetworkMetrics.cs (24)
52measurements.Add(new Measurement<long>(stateV4.ClosedCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "close") })); 53measurements.Add(new Measurement<long>(stateV4.ListenCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "listen") })); 54measurements.Add(new Measurement<long>(stateV4.SynSentCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "syn_sent") })); 55measurements.Add(new Measurement<long>(stateV4.SynRcvdCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "syn_recv") })); 56measurements.Add(new Measurement<long>(stateV4.EstabCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "established") })); 57measurements.Add(new Measurement<long>(stateV4.FinWait1Count, new TagList { tcpVersionFourTag, new(NetworkStateKey, "fin_wait_1") })); 58measurements.Add(new Measurement<long>(stateV4.FinWait2Count, new TagList { tcpVersionFourTag, new(NetworkStateKey, "fin_wait_2") })); 59measurements.Add(new Measurement<long>(stateV4.CloseWaitCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "close_wait") })); 60measurements.Add(new Measurement<long>(stateV4.ClosingCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "closing") })); 61measurements.Add(new Measurement<long>(stateV4.LastAckCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "last_ack") })); 62measurements.Add(new Measurement<long>(stateV4.TimeWaitCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "time_wait") })); 63measurements.Add(new Measurement<long>(stateV4.DeleteTcbCount, new TagList { tcpVersionFourTag, new(NetworkStateKey, "delete") })); 67measurements.Add(new Measurement<long>(stateV6.ClosedCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "close") })); 68measurements.Add(new Measurement<long>(stateV6.ListenCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "listen") })); 69measurements.Add(new Measurement<long>(stateV6.SynSentCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "syn_sent") })); 70measurements.Add(new Measurement<long>(stateV6.SynRcvdCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "syn_recv") })); 71measurements.Add(new Measurement<long>(stateV6.EstabCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "established") })); 72measurements.Add(new Measurement<long>(stateV6.FinWait1Count, new TagList { tcpVersionSixTag, new(NetworkStateKey, "fin_wait_1") })); 73measurements.Add(new Measurement<long>(stateV6.FinWait2Count, new TagList { tcpVersionSixTag, new(NetworkStateKey, "fin_wait_2") })); 74measurements.Add(new Measurement<long>(stateV6.CloseWaitCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "close_wait") })); 75measurements.Add(new Measurement<long>(stateV6.ClosingCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "closing") })); 76measurements.Add(new Measurement<long>(stateV6.LastAckCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "last_ack") })); 77measurements.Add(new Measurement<long>(stateV6.TimeWaitCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "time_wait") })); 78measurements.Add(new Measurement<long>(stateV6.DeleteTcbCount, new TagList { tcpVersionSixTag, new(NetworkStateKey, "delete") }));
Windows\WindowsContainerSnapshotProvider.cs (2)
222yield return new Measurement<double>(basicAccountingInfo.TotalUserTime / TicksPerSecondDouble, 224yield return new Measurement<double>(basicAccountingInfo.TotalKernelTime / TicksPerSecondDouble,
Stress.ApiService (1)
TestMetrics.cs (1)
51return new Measurement<double>(sum / uploadSpeed.Count);
Stress.TelemetryService (1)
GaugeMetrics.cs (1)
28measurements.Add(new Measurement<long>(workingSet, new KeyValuePair<string, object?>("process.id", process.Id)));
System.Diagnostics.DiagnosticSource (6)
System\Diagnostics\Metrics\ObservableInstrument.cs (1)
76return new Measurement<T>[1] { new Measurement<T>(valueOnlyFunc()) };
System\Diagnostics\Metrics\RuntimeMetrics.cs (5)
166yield return new(collectionsFromThisGeneration - collectionsFromHigherGeneration, new KeyValuePair<string, object?>("gc.heap.generation", s_genNames[gen])); 181yield return new(processCpuUsage.UserTime.TotalSeconds, [new KeyValuePair<string, object?>("cpu.mode", "user")]); 182yield return new(processCpuUsage.PrivilegedTime.TotalSeconds, [new KeyValuePair<string, object?>("cpu.mode", "system")]); 191yield return new(gcInfo.GenerationInfo[i].SizeAfterBytes, new KeyValuePair<string, object?>("gc.heap.generation", s_genNames[i])); 201yield return new(gcInfo.GenerationInfo[i].FragmentationAfterBytes, new KeyValuePair<string, object?>("gc.heap.generation", s_genNames[i]));
77 references to Measurement
Aspire.Confluent.Kafka (12)
ConfluentKafkaMetrics.cs (12)
22public ConcurrentQueue<Measurement<long>> ReplyQueueMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 23public ConcurrentQueue<Measurement<long>> MessageCountMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 24public ConcurrentQueue<Measurement<long>> MessageSizeMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 85private IEnumerable<Measurement<long>> GetReplyQMeasurements() 87while (ReplyQueueMeasurements.TryDequeue(out var measurement)) 93private IEnumerable<Measurement<long>> GetMessageCountMeasurements() 95while (MessageCountMeasurements.TryDequeue(out var measurement)) 101private IEnumerable<Measurement<long>> GetMessageSizeMeasurements() 103while (MessageSizeMeasurements.TryDequeue(out var measurement))
Interop.FunctionalTests (2)
Http2\Http2RequestTests.cs (2)
44var measurementTcs = new TaskCompletionSource<Measurement<double>>(); 72var measurement = await measurementTcs.Task.DefaultTimeout();
Microsoft.Extensions.Diagnostics.ResourceMonitoring (21)
Linux\Disk\LinuxSystemDiskMetrics.cs (6)
94private IEnumerable<Measurement<long>> GetDiskIoMeasurements() 96List<Measurement<long>> measurements = []; 111private IEnumerable<Measurement<long>> GetDiskOperationMeasurements() 113List<Measurement<long>> measurements = []; 128private IEnumerable<Measurement<double>> GetDiskIoTimeMeasurements() 130List<Measurement<double>> measurements = [];
Linux\LinuxUtilizationProvider.cs (3)
267private Measurement<double>[] GetMeasurementWithRetry(Func<double> func) 271return Array.Empty<Measurement<double>>(); 311private IEnumerable<Measurement<double>> GetCpuTime()
Linux\Network\LinuxNetworkMetrics.cs (3)
50public IEnumerable<Measurement<long>> GetMeasurements() 58List<Measurement<long>> measurements = new(24); 71private static void CreateMeasurements(KeyValuePair<string, object?> tcpVersionTag, List<Measurement<long>> measurements, TcpStateInfo state)
Windows\Disk\WindowsDiskMetrics.cs (6)
134private IEnumerable<Measurement<long>> GetDiskIoMeasurements() 136List<Measurement<long>> measurements = []; 159private IEnumerable<Measurement<long>> GetDiskOperationMeasurements() 161List<Measurement<long>> measurements = []; 184private IEnumerable<Measurement<double>> GetDiskIoTimeMeasurements() 186List<Measurement<double>> measurements = [];
Windows\Network\WindowsNetworkMetrics.cs (2)
39private IEnumerable<Measurement<long>> GetMeasurements() 48List<Measurement<long>> measurements = new(24);
Windows\WindowsContainerSnapshotProvider.cs (1)
217private IEnumerable<Measurement<double>> GetCpuTime()
Stress.TelemetryService (1)
GaugeMetrics.cs (1)
22var measurements = new List<Measurement<long>>();
System.Diagnostics.DiagnosticSource (41)
System\Diagnostics\Metrics\Measurement.cs (2)
11/// <see cref="Measurement{T}"/> stores one observed value and its associated tags for a metric. 19/// Initializes a new instance of <see cref="Measurement{T}"/> with the provided <paramref name="value"/>.
System\Diagnostics\Metrics\Meter.cs (12)
294public ObservableUpDownCounter<T> CreateObservableUpDownCounter<T>(string name, Func<Measurement<T>> observeValue, string? unit = null, string? description = null) where T : struct => 308public ObservableUpDownCounter<T> CreateObservableUpDownCounter<T>(string name, Func<Measurement<T>> observeValue, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) where T : struct => 321public ObservableUpDownCounter<T> CreateObservableUpDownCounter<T>(string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit = null, string? description = null) where T : struct => 335public ObservableUpDownCounter<T> CreateObservableUpDownCounter<T>(string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) where T : struct => 375public ObservableCounter<T> CreateObservableCounter<T>(string name, Func<Measurement<T>> observeValue, string? unit = null, string? description = null) where T : struct => 389public ObservableCounter<T> CreateObservableCounter<T>(string name, Func<Measurement<T>> observeValue, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) where T : struct => 403public ObservableCounter<T> CreateObservableCounter<T>(string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit = null, string? description = null) where T : struct => 417public ObservableCounter<T> CreateObservableCounter<T>(string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) where T : struct => 448public ObservableGauge<T> CreateObservableGauge<T>(string name, Func<Measurement<T>> observeValue, string? unit = null, string? description = null) where T : struct => 459public ObservableGauge<T> CreateObservableGauge<T>(string name, Func<Measurement<T>> observeValue, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) where T : struct => 469public ObservableGauge<T> CreateObservableGauge<T>(string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit = null, string? description = null) where T : struct => 480public ObservableGauge<T> CreateObservableGauge<T>(string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) where T : struct =>
System\Diagnostics\Metrics\ObservableCounter.cs (5)
30internal ObservableCounter(Meter meter, string name, Func<Measurement<T>> observeValue, string? unit, string? description) : this(meter, name, observeValue, unit, description, tags: null) 34internal ObservableCounter(Meter meter, string name, Func<Measurement<T>> observeValue, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) : base(meter, name, unit, description, tags) 40internal ObservableCounter(Meter meter, string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description) : this(meter, name, observeValues, unit, description, tags: null) 44internal ObservableCounter(Meter meter, string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) : base(meter, name, unit, description, tags) 53protected override IEnumerable<Measurement<T>> Observe() => Observe(_callback);
System\Diagnostics\Metrics\ObservableGauge.cs (5)
30internal ObservableGauge(Meter meter, string name, Func<Measurement<T>> observeValue, string? unit, string? description) : this(meter, name, observeValue, unit, description, tags: null) 34internal ObservableGauge(Meter meter, string name, Func<Measurement<T>> observeValue, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) : base(meter, name, unit, description, tags) 40internal ObservableGauge(Meter meter, string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description) : this(meter, name, observeValues, unit, description, tags: null) 44internal ObservableGauge(Meter meter, string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) : base(meter, name, unit, description, tags) 53protected override IEnumerable<Measurement<T>> Observe() => Observe(_callback);
System\Diagnostics\Metrics\ObservableInstrument.cs (8)
46protected abstract IEnumerable<Measurement<T>> Observe(); 58IEnumerable<Measurement<T>> measurements = Observe(); 64foreach (Measurement<T> measurement in measurements) 72internal static IEnumerable<Measurement<T>> Observe(object callback) 76return new Measurement<T>[1] { new Measurement<T>(valueOnlyFunc()) }; 79if (callback is Func<Measurement<T>> measurementOnlyFunc) 81return new Measurement<T>[1] { measurementOnlyFunc() }; 84if (callback is Func<IEnumerable<Measurement<T>>> listOfMeasurementsFunc)
System\Diagnostics\Metrics\ObservableUpDownCounter.cs (5)
30internal ObservableUpDownCounter(Meter meter, string name, Func<Measurement<T>> observeValue, string? unit, string? description) : this(meter, name, observeValue, unit, description, tags: null) 34internal ObservableUpDownCounter(Meter meter, string name, Func<Measurement<T>> observeValue, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) : base(meter, name, unit, description, tags) 40internal ObservableUpDownCounter(Meter meter, string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description) : this(meter, name, observeValues, unit, description, tags: null) 44internal ObservableUpDownCounter(Meter meter, string name, Func<IEnumerable<Measurement<T>>> observeValues, string? unit, string? description, IEnumerable<KeyValuePair<string, object?>>? tags) : base(meter, name, unit, description, tags) 53protected override IEnumerable<Measurement<T>> Observe() => Observe(_callback);
System\Diagnostics\Metrics\RuntimeMetrics.cs (4)
159private static IEnumerable<Measurement<long>> GetGarbageCollectionCounts() 175private static IEnumerable<Measurement<double>> GetCpuTime() 185private static IEnumerable<Measurement<long>> GetHeapSizes() 195private static IEnumerable<Measurement<long>> GetHeapFragmentation()