larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add async counter

Browse Source
This commit is contained in:
Abhishek Pandey 2023-10-06 20:35:06 +05:30
parent 22b43b7255
commit 12b50f1df2
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/internal/events/adot_sdk_client.go
View File

@ -19,6 +19,7 @@ import (
) )
var Ctr metric.Int64Counter var Ctr metric.Int64Counter
var AsyncCtr metric.Int64ObservableCounter
type collector struct { type collector struct {
meter metric.Meter meter metric.Meter
@ -40,10 +41,29 @@ func (rmc *collector) RegisterMetricsClient(ctx context.Context, cfg Config) {
time.Sleep(time.Second * 1) time.Sleep(time.Second * 1)
} }
}() }()
} }
func (rmc *collector) registerCounter() { func (rmc *collector) registerCounter() {
Ctr, _ = rmc.meter.Int64Counter(growCounter) Ctr, _ = rmc.meter.Int64Counter(growCounter)
AsyncCtr, _ = rmc.meter.Int64ObservableCounter("async_counter")
var token int64
cb := func(_ context.Context, o metric.Observer) error {
token++
o.ObserveInt64(AsyncCtr, token)
return nil
}
_, err := rmc.meter.RegisterCallback(
cb,
AsyncCtr,
)
if err != nil {
log.Fatalf("failed to register callback: %v", err)
}
} }
func (rmc *collector) updateCounter(ctx context.Context) { func (rmc *collector) updateCounter(ctx context.Context) {