mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-11-03 02:20:04 +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
29 lines
790 B
Go
29 lines
790 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package o11ykafkareceiver
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"go.opentelemetry.io/collector/pdata/plog"
|
|
"go.opentelemetry.io/collector/pdata/pmetric"
|
|
"go.opentelemetry.io/collector/pdata/ptrace"
|
|
)
|
|
|
|
func TestNewPdataTracesUnmarshaler(t *testing.T) {
|
|
um := newPdataTracesUnmarshaler(&ptrace.ProtoUnmarshaler{}, "test")
|
|
assert.Equal(t, "test", um.Encoding())
|
|
}
|
|
|
|
func TestNewPdataMetricsUnmarshaler(t *testing.T) {
|
|
um := newPdataMetricsUnmarshaler(&pmetric.ProtoUnmarshaler{}, "test")
|
|
assert.Equal(t, "test", um.Encoding())
|
|
}
|
|
|
|
func TestNewPdataLogsUnmarshaler(t *testing.T) {
|
|
um := NewPdataLogsUnmarshaler(&plog.ProtoUnmarshaler{}, "test")
|
|
assert.Equal(t, "test", um.Encoding())
|
|
}
|