Function NewDecoder

pkg/ingest/encoding.go:123–127

()

}

func NewDecoder() *Decoder {
	return &Decoder{
		req: &tempopb.PushBytesRequest{}, // TODO - Pool?
	}
}

// Decode converts a Kafka record's byte data back into a tempopb.Trace.
func (d *Decoder) Decode(data []byte) (*tempopb.PushBytesRequest, error) {