Interface GeneratorCodec

pkg/ingest/encoding.go:154–156

GeneratorCodec is the interface used to convert data from Kafka records to the tempopb.PushSpansRequest expected by the generator processors.

// GeneratorCodec is the interface used to convert data from Kafka records to the
// tempopb.PushSpansRequest expected by the generator processors.
type GeneratorCodec interface {
	Decode([]byte) (iter.Seq2[*tempopb.PushSpansRequest, error], error)
}

// PushBytesDecoder unmarshals tempopb.PushBytesRequest.
type PushBytesDecoder struct {