Versions in this module Expand all Collapse all v0 v0.0.2 Dec 9, 2024 Changes in this version + type Request struct + Groups []string + IncludeAuthorizedOperations bool + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Group() string + func (r *Request) Split(cluster protocol.Cluster) ([]protocol.Message, protocol.Merger, error) + type Response struct + Groups []ResponseGroup + ThrottleTimeMs int32 + func (r *Response) ApiKey() protocol.ApiKey + func (r *Response) Merge(requests []protocol.Message, results []interface{}) (protocol.Message, error) + type ResponseGroup struct + AuthorizedOperations int32 + ErrorCode int16 + GroupID string + GroupState string + Members []ResponseGroupMember + ProtocolData string + ProtocolType string + type ResponseGroupMember struct + ClientHost string + ClientID string + GroupInstanceID string + MemberAssignment []byte + MemberID string + MemberMetadata []byte
Go to main page