mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
625e1ee1c6
#### Description Add duration metric to processors. #### Testing Unit tests added. #### Documentation Implements issue [Processor duration metric #13231](https://github.com/open-telemetry/opentelemetry-collector/issues/13231). Basic documentation generated by mdatagen. --------- Co-authored-by: Joshua MacDonald <[email protected]> Co-authored-by: Pablo Baeyens <[email protected]>
37 lines
1.2 KiB
Go
37 lines
1.2 KiB
Go
// Code generated by mdatagen. DO NOT EDIT.
|
|
|
|
package metadatatest
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
"go.opentelemetry.io/otel/sdk/metric/metricdata"
|
|
"go.opentelemetry.io/otel/sdk/metric/metricdata/metricdatatest"
|
|
|
|
"go.opentelemetry.io/collector/component/componenttest"
|
|
"go.opentelemetry.io/collector/processor/processorhelper/internal/metadata"
|
|
)
|
|
|
|
func TestSetupTelemetry(t *testing.T) {
|
|
testTel := componenttest.NewTelemetry()
|
|
tb, err := metadata.NewTelemetryBuilder(testTel.NewTelemetrySettings())
|
|
require.NoError(t, err)
|
|
defer tb.Shutdown()
|
|
tb.ProcessorIncomingItems.Add(context.Background(), 1)
|
|
tb.ProcessorInternalDuration.Record(context.Background(), 1)
|
|
tb.ProcessorOutgoingItems.Add(context.Background(), 1)
|
|
AssertEqualProcessorIncomingItems(t, testTel,
|
|
[]metricdata.DataPoint[int64]{{Value: 1}},
|
|
metricdatatest.IgnoreTimestamp())
|
|
AssertEqualProcessorInternalDuration(t, testTel,
|
|
[]metricdata.HistogramDataPoint[float64]{{}}, metricdatatest.IgnoreValue(),
|
|
metricdatatest.IgnoreTimestamp())
|
|
AssertEqualProcessorOutgoingItems(t, testTel,
|
|
[]metricdata.DataPoint[int64]{{Value: 1}},
|
|
metricdatatest.IgnoreTimestamp())
|
|
|
|
require.NoError(t, testTel.Shutdown(context.Background()))
|
|
}
|