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