27 lines
699 B
27 lines
699 B
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"`
|
|
}
|
|
|