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
35 lines
717 B
Go
35 lines
717 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package o11ykafkareceiver
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestNewTextUnmarshaler(t *testing.T) {
|
|
t.Parallel()
|
|
um := newTextLogsUnmarshaler()
|
|
assert.Equal(t, "text", um.Encoding())
|
|
}
|
|
|
|
func TestTextUnmarshalerWithEnc(t *testing.T) {
|
|
t.Parallel()
|
|
um := newTextLogsUnmarshaler()
|
|
um2 := um
|
|
assert.EqualValues(t, um, um2)
|
|
|
|
um, err := um.WithEnc("utf8")
|
|
require.NoError(t, err)
|
|
um2, err = um2.WithEnc("gbk")
|
|
require.NoError(t, err)
|
|
assert.NotEqualValues(t, um, um2)
|
|
|
|
um2, err = um2.WithEnc("utf8")
|
|
require.NoError(t, err)
|
|
assert.EqualValues(t, um, um2)
|
|
}
|