mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-10-30 18:26:25 +00:00
zeekay
087e487107
- Go module: github.com/SigNoz/signoz-otel-collector → github.com/hanzoai/otel-collector - All signoz-prefixed packages → o11y-prefixed - Docker: signoz/* → ghcr.io/hanzoai/otel-collector - ClickHouse exporter → Hanzo Datastore - Env vars: SIGNOZ_* → HANZO_* - Directory renames for all processor/receiver/exporter packages
82 lines
2.7 KiB
Go
82 lines
2.7 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package o11yspanmetricsprocessor
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/consumer/consumertest"
|
|
"go.opentelemetry.io/collector/pdata/pcommon"
|
|
"go.opentelemetry.io/collector/processor/processortest"
|
|
|
|
"github.com/hanzoai/otel-collector/processor/o11yspanmetricsprocessor/internal/metadata"
|
|
)
|
|
|
|
func TestNewProcessor(t *testing.T) {
|
|
defaultMethod := "GET"
|
|
defaultMethodValue := pcommon.NewValueStr(defaultMethod)
|
|
for _, tc := range []struct {
|
|
name string
|
|
metricsExporter string
|
|
latencyHistogramBuckets []time.Duration
|
|
dimensions []Dimension
|
|
wantLatencyHistogramBuckets []float64
|
|
wantDimensions []dimension
|
|
}{
|
|
{
|
|
name: "simplest config (use defaults)",
|
|
wantLatencyHistogramBuckets: defaultLatencyHistogramBucketsMs,
|
|
},
|
|
{
|
|
name: "1 configured latency histogram bucket should result in 1 explicit latency bucket (+1 implicit +Inf bucket)",
|
|
latencyHistogramBuckets: []time.Duration{2 * time.Millisecond},
|
|
dimensions: []Dimension{
|
|
{Name: "http.method", Default: &defaultMethod},
|
|
{Name: "http.status_code"},
|
|
},
|
|
wantLatencyHistogramBuckets: []float64{2},
|
|
wantDimensions: []dimension{
|
|
{name: "http.method", value: &defaultMethodValue},
|
|
{"http.status_code", nil},
|
|
},
|
|
},
|
|
} {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
// Prepare
|
|
factory := NewFactory()
|
|
|
|
creationParams := processortest.NewNopSettings(component.Type(metadata.Type))
|
|
cfg := factory.CreateDefaultConfig().(*Config)
|
|
cfg.LatencyHistogramBuckets = tc.latencyHistogramBuckets
|
|
cfg.Dimensions = tc.dimensions
|
|
|
|
// Test
|
|
traceProcessor, err := factory.CreateTraces(context.Background(), creationParams, cfg, consumertest.NewNop())
|
|
smp := traceProcessor.(*processorImp)
|
|
|
|
// Verify
|
|
assert.Nil(t, err)
|
|
assert.NotNil(t, smp)
|
|
|
|
assert.Equal(t, tc.wantLatencyHistogramBuckets, smp.latencyBounds)
|
|
assert.Equal(t, tc.wantDimensions, smp.dimensions)
|
|
})
|
|
}
|
|
}
|