Measurement

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));

Http2\Http2RequestTests.cs (1)

55measurementTcs.SetResult(new Measurement<double>(measurement, tags));

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)

288return new[] { new Measurement<T>(value) }; 329yield return new Measurement<double>(systemCpuTime / NanosecondsInSecond, [new KeyValuePair<string, object?>("cpu.mode", "system")]); 334yield return new Measurement<double>(userCpuTime, [new KeyValuePair<string, object?>("cpu.mode", "user")]);

Linux\Network\LinuxNetworkMetrics.cs (11)

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)

Windows\WindowsContainerSnapshotProvider.cs (2)

273yield return new Measurement<double>(basicAccountingInfo.TotalUserTime / TicksPerSecondDouble, 275yield return new Measurement<double>(basicAccountingInfo.TotalKernelTime / TicksPerSecondDouble,

TestMetrics.cs (1)

51return new Measurement<double>(sum / uploadSpeed.Count);

GaugeMetrics.cs (1)

28measurements.Add(new Measurement<long>(workingSet, new KeyValuePair<string, object?>("process.id", process.Id)));

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]));

ConfluentKafkaMetrics.cs (12)

Http2\Http2RequestTests.cs (2)

44var measurementTcs = new TaskCompletionSource<Measurement<double>>(); 72var measurement = await measurementTcs.Task.DefaultTimeout();

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)

280private Measurement<T>[] GetMeasurementWithRetry<T>(Func<T> func) 285return Array.Empty<Measurement<T>>(); 325private 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)

268private IEnumerable<Measurement<double>> GetCpuTime()

Linux\LinuxNetworkMetricsTests.cs (7)

56List<Measurement<long>> measurements = metrics.GetMeasurements().ToList(); 73List<Measurement<long>> measurements = metrics.GetMeasurements().ToList(); 86List<Measurement<long>> first = metrics.GetMeasurements().ToList(); 89List<Measurement<long>> second = metrics.GetMeasurements().ToList(); 104List<Measurement<long>> first = metrics.GetMeasurements().ToList(); 107List<Measurement<long>> second = metrics.GetMeasurements().ToList(); 117private static bool HasTagWithValue(Measurement<long> measurement, string tagKey, string tagValue, long expectedValue)

GaugeMetrics.cs (1)

22var measurements = new List<Measurement<long>>();

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)

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()