()
| 3 | import "github.com/segmentio/kafka-go/protocol" |
| 4 | |
| 5 | func init() { |
| 6 | protocol.Register(&Request{}, &Response{}) |
| 7 | } |
| 8 | |
| 9 | type Request struct { |
| 10 | // We need at least one tagged field to indicate that this is a "flexible" message |
nothing calls this directly
no test coverage detected