(req *tempopb.PushBytesRequest)
| 33 | } |
| 34 | |
| 35 | func encoderPoolPut(req *tempopb.PushBytesRequest) { |
| 36 | resetPushBytesRequest(req) |
| 37 | encoderPool.Put(req) |
| 38 | } |
| 39 | |
| 40 | func Encode(partitionID int32, tenantID string, req *tempopb.PushBytesRequest, maxSize int) ([]*kgo.Record, error) { |
| 41 | reqSize := req.Size() |