Versions in this module Expand all Collapse all v0 v0.4.28 Feb 4, 2023 Changes in this version + type Request struct + IncludeDocumentation bool + IncludeSynonyms bool + Resources []RequestResource + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) + func (r *Request) Split(cluster protocol.Cluster) ([]protocol.Message, protocol.Merger, error) + type RequestResource struct + ConfigNames []string + ResourceName string + ResourceType int8 + type Response struct + Resources []ResponseResource + ThrottleTimeMs int32 + func (r *Response) ApiKey() protocol.ApiKey + func (r *Response) Merge(requests []protocol.Message, results []interface{}) (protocol.Message, error) + type ResponseConfigEntry struct + ConfigDocumentation string + ConfigName string + ConfigSource int8 + ConfigSynonyms []ResponseConfigSynonym + ConfigType int8 + ConfigValue string + IsDefault bool + IsSensitive bool + ReadOnly bool + type ResponseConfigSynonym struct + ConfigName string + ConfigSource int8 + ConfigValue string + type ResponseResource struct + ConfigEntries []ResponseConfigEntry + ErrorCode int16 + ErrorMessage string + ResourceName string + ResourceType int8
Go to main page