Decoder is responsible for decoding Kafka record data back into logproto.Stream format. It caches parsed labels for efficiency.
| 117 | // Decoder is responsible for decoding Kafka record data back into logproto.Stream format. |
| 118 | // It caches parsed labels for efficiency. |
| 119 | type Decoder struct { |
| 120 | req *tempopb.PushBytesRequest |
| 121 | } |
| 122 | |
| 123 | func NewDecoder() *Decoder { |
| 124 | return &Decoder{ |
nothing calls this directly
no outgoing calls
no test coverage detected