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
71 lines
1.7 KiB
Go
71 lines
1.7 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package o11ykafkareceiver // import "github.com/hanzoai/otel-collector/receiver/o11ykafkareceiver"
|
|
|
|
import (
|
|
"go.opentelemetry.io/collector/pdata/plog"
|
|
"go.opentelemetry.io/collector/pdata/pmetric"
|
|
"go.opentelemetry.io/collector/pdata/ptrace"
|
|
)
|
|
|
|
type pdataLogsUnmarshaler struct {
|
|
plog.Unmarshaler
|
|
encoding string
|
|
}
|
|
|
|
func (p pdataLogsUnmarshaler) Unmarshal(buf []byte) (plog.Logs, error) {
|
|
return p.Unmarshaler.UnmarshalLogs(buf)
|
|
}
|
|
|
|
func (p pdataLogsUnmarshaler) Encoding() string {
|
|
return p.encoding
|
|
}
|
|
|
|
func NewPdataLogsUnmarshaler(unmarshaler plog.Unmarshaler, encoding string) LogsUnmarshaler {
|
|
return pdataLogsUnmarshaler{
|
|
Unmarshaler: unmarshaler,
|
|
encoding: encoding,
|
|
}
|
|
}
|
|
|
|
type pdataTracesUnmarshaler struct {
|
|
ptrace.Unmarshaler
|
|
encoding string
|
|
}
|
|
|
|
func (p pdataTracesUnmarshaler) Unmarshal(buf []byte) (ptrace.Traces, error) {
|
|
return p.Unmarshaler.UnmarshalTraces(buf)
|
|
}
|
|
|
|
func (p pdataTracesUnmarshaler) Encoding() string {
|
|
return p.encoding
|
|
}
|
|
|
|
func newPdataTracesUnmarshaler(unmarshaler ptrace.Unmarshaler, encoding string) TracesUnmarshaler {
|
|
return pdataTracesUnmarshaler{
|
|
Unmarshaler: unmarshaler,
|
|
encoding: encoding,
|
|
}
|
|
}
|
|
|
|
type pdataMetricsUnmarshaler struct {
|
|
pmetric.Unmarshaler
|
|
encoding string
|
|
}
|
|
|
|
func (p pdataMetricsUnmarshaler) Unmarshal(buf []byte) (pmetric.Metrics, error) {
|
|
return p.Unmarshaler.UnmarshalMetrics(buf)
|
|
}
|
|
|
|
func (p pdataMetricsUnmarshaler) Encoding() string {
|
|
return p.encoding
|
|
}
|
|
|
|
func newPdataMetricsUnmarshaler(unmarshaler pmetric.Unmarshaler, encoding string) MetricsUnmarshaler {
|
|
return pdataMetricsUnmarshaler{
|
|
Unmarshaler: unmarshaler,
|
|
encoding: encoding,
|
|
}
|
|
}
|