123456789101112131415161718192021222324252627 |
- package apiversions
- import "github.com/segmentio/kafka-go/protocol"
- func init() {
- protocol.Register(&Request{}, &Response{})
- }
- type Request struct {
- _ struct{} `kafka:"min=v0,max=v2"`
- }
- func (r *Request) ApiKey() protocol.ApiKey { return protocol.ApiVersions }
- type Response struct {
- ErrorCode int16 `kafka:"min=v0,max=v2"`
- ApiKeys []ApiKeyResponse `kafka:"min=v0,max=v2"`
- ThrottleTimeMs int32 `kafka:"min=v1,max=v2"`
- }
- func (r *Response) ApiKey() protocol.ApiKey { return protocol.ApiVersions }
- type ApiKeyResponse struct {
- ApiKey int16 `kafka:"min=v0,max=v2"`
- MinVersion int16 `kafka:"min=v0,max=v2"`
- MaxVersion int16 `kafka:"min=v0,max=v2"`
- }
|