Skip to content

Commit 6fffb75

Browse files
committed
Replace reporting method with instrument
1 parent 9f7e4f6 commit 6fffb75

File tree

4 files changed

+5
-8
lines changed

4 files changed

+5
-8
lines changed
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
using System.Diagnostics;
1+
using System.Diagnostics.Metrics;
22

33
namespace DotNext.Net.Multiplexing;
44

55
internal interface IStreamMetrics
66
{
7-
static abstract void ChangeStreamCount(long delta, in TagList measurementTags);
7+
static abstract UpDownCounter<long> StreamCount { get; }
88
}

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedClient.Metrics.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
using System.Diagnostics;
21
using System.Diagnostics.Metrics;
32

43
namespace DotNext.Net.Multiplexing;
@@ -13,6 +12,5 @@ static MultiplexedClient()
1312
StreamCount = meter.CreateUpDownCounter<long>("streams-count", description: "Number of Streams");
1413
}
1514

16-
static void IStreamMetrics.ChangeStreamCount(long delta, in TagList measurementTags)
17-
=> StreamCount.Add(delta, measurementTags);
15+
static UpDownCounter<long> IStreamMetrics.StreamCount => StreamCount;
1816
}

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedListener.Metrics.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,5 @@ static MultiplexedListener()
1818

1919
private readonly TagList measurementTags;
2020

21-
static void IStreamMetrics.ChangeStreamCount(long delta, in TagList measurementTags)
22-
=> StreamCount.Add(delta, measurementTags);
21+
static UpDownCounter<long> IStreamMetrics.StreamCount => StreamCount;
2322
}

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/Multiplexer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@ internal abstract class Multiplexer<T>(
3232
{
3333
public required TagList MeasurementTags;
3434

35-
protected void ChangeStreamCount(long delta = 1) => T.ChangeStreamCount(delta, MeasurementTags);
35+
protected void ChangeStreamCount(long delta = 1) => T.StreamCount.Add(delta, MeasurementTags);
3636
}

0 commit comments

Comments
 (0)