Skip to content

Commit

Permalink
Add Sum and Histogram metrics
Browse files Browse the repository at this point in the history
  • Loading branch information
marcelbirkner committed Sep 12, 2023
1 parent 70c334b commit 407b67a
Showing 1 changed file with 39 additions and 1 deletion.
40 changes: 39 additions & 1 deletion cmd/telemetrygen/internal/metrics/worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (
"sync/atomic"
"time"

"go.opentelemetry.io/otel/attribute"
sdkmetric "go.opentelemetry.io/otel/sdk/metric"
"go.opentelemetry.io/otel/sdk/metric/metricdata"
"go.opentelemetry.io/otel/sdk/resource"
Expand All @@ -28,7 +29,13 @@ type worker struct {

func (w worker) simulateMetrics(res *resource.Resource, exporter sdkmetric.Exporter) {
limiter := rate.NewLimiter(w.limitPerSecond, 1)

var i int64
value := 24.42
attrs := attribute.NewSet(attribute.KeyValue{
Key: attribute.Key("node_id"),
Value: attribute.StringValue("test"),
})

for w.running.Load() {
rm := metricdata.ResourceMetrics{
Expand All @@ -37,7 +44,7 @@ func (w worker) simulateMetrics(res *resource.Resource, exporter sdkmetric.Expor
{
Metrics: []metricdata.Metrics{
{
Name: "gen",
Name: "gen.metric.gauge",
Data: metricdata.Gauge[int64]{
DataPoints: []metricdata.DataPoint[int64]{
{
Expand All @@ -47,10 +54,41 @@ func (w worker) simulateMetrics(res *resource.Resource, exporter sdkmetric.Expor
},
},
},
{
Name: "gen.metric.sum",
Data: metricdata.Sum[int64]{
IsMonotonic: true,
Temporality: metricdata.DeltaTemporality,
DataPoints: []metricdata.DataPoint[int64]{
{
Attributes: attrs,
StartTime: time.Now(),
Time: time.Now().Add(1 * time.Second),
Value: i,
},
},
},
},
{
Name: "gen.metric.histogram",
Data: metricdata.Histogram[float64]{
Temporality: metricdata.CumulativeTemporality,
DataPoints: []metricdata.HistogramDataPoint[float64]{
{
Attributes: attrs,
Sum: float64(float32(value)),
Max: metricdata.NewExtrema(float64(float32(value))),
Min: metricdata.NewExtrema(float64(float32(value))),
Count: 1,
},
},
},
},
},
},
},
}

if err := exporter.Export(context.Background(), &rm); err != nil {
w.logger.Fatal("exporter failed", zap.Error(err))
}
Expand Down

0 comments on commit 407b67a

Please sign in to comment.