Function NewOTLPDecoder

pkg/ingest/encoding.go:196–198

()

}

func NewOTLPDecoder() *OTLPDecoder {
	return &OTLPDecoder{trace: tempopb.Trace{}}
}

// Decode implements GeneratorCodec.
func (d *OTLPDecoder) Decode(data []byte) (iter.Seq2[*tempopb.PushSpansRequest, error], error) {