mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Pablo BaeyensandGitHub
8555326968
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description <!-- Issue number if applicable --> I forgot to move these symbols in #13821. #### Link to tracking issue Relates to open-telemetry/opentelemetry-collector-contrib/pull/42782, which is how I noticed. Follows #13821 Updates #11143
17 lines
692 B
Go
17 lines
692 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package queuebatch // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch"
|
|
|
|
import "context"
|
|
|
|
// encoding defines the encoding to be used if persistent queue is configured.
|
|
// Duplicate definition with exporterhelper.QueueBatchEncoding since aliasing generics is not supported by default.
|
|
type encoding[T any] interface {
|
|
// Marshal is a function that can marshal a request and its context into bytes.
|
|
Marshal(context.Context, T) ([]byte, error)
|
|
|
|
// Unmarshal is a function that can unmarshal bytes into a request and its context.
|
|
Unmarshal([]byte) (context.Context, T, error)
|
|
}
|