mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-11-03 02:20:04 +00:00
zeekay
df7d6cb470
- 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
28 lines
981 B
Go
28 lines
981 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package o11ykafkareceiver // import "github.com/hanzoai/otel-collector/receiver/o11ykafkareceiver"
|
|
|
|
import (
|
|
"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/zipkin/zipkinv1"
|
|
"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/zipkin/zipkinv2"
|
|
)
|
|
|
|
const (
|
|
zipkinProtobufEncoding = "zipkin_proto"
|
|
zipkinJSONEncoding = "zipkin_json"
|
|
zipkinThriftEncoding = "zipkin_thrift"
|
|
)
|
|
|
|
func newZipkinProtobufUnmarshaler() TracesUnmarshaler {
|
|
return newPdataTracesUnmarshaler(zipkinv2.NewProtobufTracesUnmarshaler(false, false), zipkinProtobufEncoding)
|
|
}
|
|
|
|
func newZipkinJSONUnmarshaler() TracesUnmarshaler {
|
|
return newPdataTracesUnmarshaler(zipkinv2.NewJSONTracesUnmarshaler(false), zipkinJSONEncoding)
|
|
}
|
|
|
|
func newZipkinThriftUnmarshaler() TracesUnmarshaler {
|
|
return newPdataTracesUnmarshaler(zipkinv1.NewThriftTracesUnmarshaler(), zipkinThriftEncoding)
|
|
}
|