Method Decode

pkg/ingest/encoding.go:130–136

Decode converts a Kafka record's byte data back into a tempopb.Trace.

(data []byte)

// Decode converts a Kafka record's byte data back into a tempopb.Trace.
func (d *Decoder) Decode(data []byte) (*tempopb.PushBytesRequest, error) {
	err := d.req.Unmarshal(data)
	if err != nil {
		return nil, fmt.Errorf("failed to unmarshal record: %w", err)
	}
	return d.req, nil
}

func (d *Decoder) Reset() {
	// Retain slice capacity