1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
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"`
}
|
