Versions in this module Expand all Collapse all v0 v0.6.12 Dec 12, 2023 Changes in this version + const Default_CommandAckResponse_TxnidLeastBits + const Default_CommandAckResponse_TxnidMostBits + const Default_CommandAck_TxnidLeastBits + const Default_CommandAck_TxnidMostBits + const Default_CommandActiveConsumerChange_IsActive + const Default_CommandAddPartitionToTxnResponse_TxnidLeastBits + const Default_CommandAddPartitionToTxnResponse_TxnidMostBits + const Default_CommandAddPartitionToTxn_TxnidLeastBits + const Default_CommandAddPartitionToTxn_TxnidMostBits + const Default_CommandAddSubscriptionToTxnResponse_TxnidLeastBits + const Default_CommandAddSubscriptionToTxnResponse_TxnidMostBits + const Default_CommandAddSubscriptionToTxn_TxnidLeastBits + const Default_CommandAddSubscriptionToTxn_TxnidMostBits + const Default_CommandAuthChallenge_ProtocolVersion + const Default_CommandAuthResponse_ProtocolVersion + const Default_CommandConnect_ProtocolVersion + const Default_CommandConnected_ProtocolVersion + const Default_CommandEndTxnOnPartitionResponse_TxnidLeastBits + const Default_CommandEndTxnOnPartitionResponse_TxnidMostBits + const Default_CommandEndTxnOnPartition_TxnidLeastBits + const Default_CommandEndTxnOnPartition_TxnidMostBits + const Default_CommandEndTxnOnSubscriptionResponse_TxnidLeastBits + const Default_CommandEndTxnOnSubscriptionResponse_TxnidMostBits + const Default_CommandEndTxnOnSubscription_TxnidLeastBits + const Default_CommandEndTxnOnSubscription_TxnidMostBits + const Default_CommandEndTxnResponse_TxnidLeastBits + const Default_CommandEndTxnResponse_TxnidMostBits + const Default_CommandEndTxn_TxnidLeastBits + const Default_CommandEndTxn_TxnidMostBits + const Default_CommandGetTopicsOfNamespaceResponse_Changed + const Default_CommandGetTopicsOfNamespaceResponse_Filtered + const Default_CommandLookupTopicResponse_Authoritative + const Default_CommandLookupTopicResponse_ProxyThroughServiceUrl + const Default_CommandLookupTopic_Authoritative + const Default_CommandMessage_RedeliveryCount + const Default_CommandNewTxnResponse_TxnidLeastBits + const Default_CommandNewTxnResponse_TxnidMostBits + const Default_CommandNewTxn_TcId + const Default_CommandNewTxn_TxnTtlSeconds + const Default_CommandProducerSuccess_LastSequenceId + const Default_CommandProducerSuccess_ProducerReady + const Default_CommandProducer_Encrypted + const Default_CommandProducer_Epoch + const Default_CommandProducer_TxnEnabled + const Default_CommandProducer_UserProvidedProducerName + const Default_CommandSendReceipt_HighestSequenceId + const Default_CommandSend_HighestSequenceId + const Default_CommandSend_IsChunk + const Default_CommandSend_Marker + const Default_CommandSend_NumMessages + const Default_CommandSend_TxnidLeastBits + const Default_CommandSend_TxnidMostBits + const Default_CommandSubscribe_Durable + const Default_CommandSubscribe_ForceTopicCreation + const Default_CommandSubscribe_StartMessageRollbackDurationSec + const Default_CommandTcClientConnectRequest_TcId + const Default_FeatureFlags_SupportsAuthRefresh + const Default_FeatureFlags_SupportsBrokerEntryMetadata + const Default_FeatureFlags_SupportsPartialProducer + const Default_FeatureFlags_SupportsTopicWatchers + const Default_KeySharedMeta_AllowOutOfOrderDelivery + const Default_MessageIdData_BatchIndex + const Default_MessageIdData_Partition + const Default_MessageMetadata_EventTime + const Default_MessageMetadata_HighestSequenceId + const Default_MessageMetadata_NullPartitionKey + const Default_MessageMetadata_NullValue + const Default_MessageMetadata_NumMessagesInBatch + const Default_MessageMetadata_PartitionKeyB64Encoded + const Default_MessageMetadata_UncompressedSize + const Default_SingleMessageMetadata_CompactedOut + const Default_SingleMessageMetadata_EventTime + const Default_SingleMessageMetadata_NullPartitionKey + const Default_SingleMessageMetadata_NullValue + const Default_SingleMessageMetadata_PartitionKeyB64Encoded + var AuthMethod_name = map[int32]string + var AuthMethod_value = map[string]int32 + var BaseCommand_Type_name = map[int32]string + var BaseCommand_Type_value = map[string]int32 + var CommandAck_AckType_name = map[int32]string + var CommandAck_AckType_value = map[string]int32 + var CommandAck_ValidationError_name = map[int32]string + var CommandAck_ValidationError_value = map[string]int32 + var CommandGetTopicsOfNamespace_Mode_name = map[int32]string + var CommandGetTopicsOfNamespace_Mode_value = map[string]int32 + var CommandLookupTopicResponse_LookupType_name = map[int32]string + var CommandLookupTopicResponse_LookupType_value = map[string]int32 + var CommandPartitionedTopicMetadataResponse_LookupType_name = map[int32]string + var CommandPartitionedTopicMetadataResponse_LookupType_value = map[string]int32 + var CommandSubscribe_InitialPosition_name = map[int32]string + var CommandSubscribe_InitialPosition_value = map[string]int32 + var CommandSubscribe_SubType_name = map[int32]string + var CommandSubscribe_SubType_value = map[string]int32 + var CompressionType_name = map[int32]string + var CompressionType_value = map[string]int32 + var ErrIntOverflowPulsarApi = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPulsarApi = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPulsarApi = fmt.Errorf("proto: unexpected end of group") + var KeySharedMode_name = map[int32]string + var KeySharedMode_value = map[string]int32 + var ProducerAccessMode_name = map[int32]string + var ProducerAccessMode_value = map[string]int32 + var ProtocolVersion_name = map[int32]string + var ProtocolVersion_value = map[string]int32 + var Schema_Type_name = map[int32]string + var Schema_Type_value = map[string]int32 + var ServerError_name = map[int32]string + var ServerError_value = map[string]int32 + var TxnAction_name = map[int32]string + var TxnAction_value = map[string]int32 + type AuthData struct + AuthData []byte + AuthMethodName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AuthData) Descriptor() ([]byte, []int) + func (*AuthData) ProtoMessage() + func (m *AuthData) GetAuthData() []byte + func (m *AuthData) GetAuthMethodName() string + func (m *AuthData) Marshal() (dAtA []byte, err error) + func (m *AuthData) MarshalTo(dAtA []byte) (int, error) + func (m *AuthData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AuthData) Reset() + func (m *AuthData) Size() (n int) + func (m *AuthData) String() string + func (m *AuthData) Unmarshal(dAtA []byte) error + func (m *AuthData) XXX_DiscardUnknown() + func (m *AuthData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AuthData) XXX_Merge(src proto.Message) + func (m *AuthData) XXX_Size() int + func (m *AuthData) XXX_Unmarshal(b []byte) error + type AuthMethod int32 + const AuthMethod_AuthMethodAthens + const AuthMethod_AuthMethodNone + const AuthMethod_AuthMethodYcaV1 + func (AuthMethod) EnumDescriptor() ([]byte, []int) + func (x *AuthMethod) UnmarshalJSON(data []byte) error + func (x AuthMethod) Enum() *AuthMethod + func (x AuthMethod) String() string + type BaseCommand struct + Ack *CommandAck + AckResponse *CommandAckResponse + ActiveConsumerChange *CommandActiveConsumerChange + AddPartitionToTxn *CommandAddPartitionToTxn + AddPartitionToTxnResponse *CommandAddPartitionToTxnResponse + AddSubscriptionToTxn *CommandAddSubscriptionToTxn + AddSubscriptionToTxnResponse *CommandAddSubscriptionToTxnResponse + AuthChallenge *CommandAuthChallenge + AuthResponse *CommandAuthResponse + CloseConsumer *CommandCloseConsumer + CloseProducer *CommandCloseProducer + Connect *CommandConnect + Connected *CommandConnected + ConsumerStats *CommandConsumerStats + ConsumerStatsResponse *CommandConsumerStatsResponse + EndTxn *CommandEndTxn + EndTxnOnPartition *CommandEndTxnOnPartition + EndTxnOnPartitionResponse *CommandEndTxnOnPartitionResponse + EndTxnOnSubscription *CommandEndTxnOnSubscription + EndTxnOnSubscriptionResponse *CommandEndTxnOnSubscriptionResponse + EndTxnResponse *CommandEndTxnResponse + Error *CommandError + Flow *CommandFlow + GetLastMessageId *CommandGetLastMessageId + GetLastMessageIdResponse *CommandGetLastMessageIdResponse + GetOrCreateSchema *CommandGetOrCreateSchema + GetOrCreateSchemaResponse *CommandGetOrCreateSchemaResponse + GetSchema *CommandGetSchema + GetSchemaResponse *CommandGetSchemaResponse + GetTopicsOfNamespace *CommandGetTopicsOfNamespace + GetTopicsOfNamespaceResponse *CommandGetTopicsOfNamespaceResponse + LookupTopic *CommandLookupTopic + LookupTopicResponse *CommandLookupTopicResponse + Message *CommandMessage + NewTxn *CommandNewTxn + NewTxnResponse *CommandNewTxnResponse + PartitionMetadata *CommandPartitionedTopicMetadata + PartitionMetadataResponse *CommandPartitionedTopicMetadataResponse + Ping *CommandPing + Pong *CommandPong + Producer *CommandProducer + ProducerSuccess *CommandProducerSuccess + ReachedEndOfTopic *CommandReachedEndOfTopic + RedeliverUnacknowledgedMessages *CommandRedeliverUnacknowledgedMessages + Seek *CommandSeek + Send *CommandSend + SendError *CommandSendError + SendReceipt *CommandSendReceipt + Subscribe *CommandSubscribe + Success *CommandSuccess + TcClientConnectRequest *CommandTcClientConnectRequest + TcClientConnectResponse *CommandTcClientConnectResponse + Type *BaseCommand_Type + Unsubscribe *CommandUnsubscribe + WatchTopicList *CommandWatchTopicList + WatchTopicListClose *CommandWatchTopicListClose + WatchTopicListSuccess *CommandWatchTopicListSuccess + WatchTopicUpdate *CommandWatchTopicUpdate + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BaseCommand) Descriptor() ([]byte, []int) + func (*BaseCommand) ProtoMessage() + func (m *BaseCommand) GetAck() *CommandAck + func (m *BaseCommand) GetAckResponse() *CommandAckResponse + func (m *BaseCommand) GetActiveConsumerChange() *CommandActiveConsumerChange + func (m *BaseCommand) GetAddPartitionToTxn() *CommandAddPartitionToTxn + func (m *BaseCommand) GetAddPartitionToTxnResponse() *CommandAddPartitionToTxnResponse + func (m *BaseCommand) GetAddSubscriptionToTxn() *CommandAddSubscriptionToTxn + func (m *BaseCommand) GetAddSubscriptionToTxnResponse() *CommandAddSubscriptionToTxnResponse + func (m *BaseCommand) GetAuthChallenge() *CommandAuthChallenge + func (m *BaseCommand) GetAuthResponse() *CommandAuthResponse + func (m *BaseCommand) GetCloseConsumer() *CommandCloseConsumer + func (m *BaseCommand) GetCloseProducer() *CommandCloseProducer + func (m *BaseCommand) GetConnect() *CommandConnect + func (m *BaseCommand) GetConnected() *CommandConnected + func (m *BaseCommand) GetConsumerStats() *CommandConsumerStats + func (m *BaseCommand) GetConsumerStatsResponse() *CommandConsumerStatsResponse + func (m *BaseCommand) GetEndTxn() *CommandEndTxn + func (m *BaseCommand) GetEndTxnOnPartition() *CommandEndTxnOnPartition + func (m *BaseCommand) GetEndTxnOnPartitionResponse() *CommandEndTxnOnPartitionResponse + func (m *BaseCommand) GetEndTxnOnSubscription() *CommandEndTxnOnSubscription + func (m *BaseCommand) GetEndTxnOnSubscriptionResponse() *CommandEndTxnOnSubscriptionResponse + func (m *BaseCommand) GetEndTxnResponse() *CommandEndTxnResponse + func (m *BaseCommand) GetError() *CommandError + func (m *BaseCommand) GetFlow() *CommandFlow + func (m *BaseCommand) GetGetLastMessageId() *CommandGetLastMessageId + func (m *BaseCommand) GetGetLastMessageIdResponse() *CommandGetLastMessageIdResponse + func (m *BaseCommand) GetGetOrCreateSchema() *CommandGetOrCreateSchema + func (m *BaseCommand) GetGetOrCreateSchemaResponse() *CommandGetOrCreateSchemaResponse + func (m *BaseCommand) GetGetSchema() *CommandGetSchema + func (m *BaseCommand) GetGetSchemaResponse() *CommandGetSchemaResponse + func (m *BaseCommand) GetGetTopicsOfNamespace() *CommandGetTopicsOfNamespace + func (m *BaseCommand) GetGetTopicsOfNamespaceResponse() *CommandGetTopicsOfNamespaceResponse + func (m *BaseCommand) GetLookupTopic() *CommandLookupTopic + func (m *BaseCommand) GetLookupTopicResponse() *CommandLookupTopicResponse + func (m *BaseCommand) GetMessage() *CommandMessage + func (m *BaseCommand) GetNewTxn() *CommandNewTxn + func (m *BaseCommand) GetNewTxnResponse() *CommandNewTxnResponse + func (m *BaseCommand) GetPartitionMetadata() *CommandPartitionedTopicMetadata + func (m *BaseCommand) GetPartitionMetadataResponse() *CommandPartitionedTopicMetadataResponse + func (m *BaseCommand) GetPing() *CommandPing + func (m *BaseCommand) GetPong() *CommandPong + func (m *BaseCommand) GetProducer() *CommandProducer + func (m *BaseCommand) GetProducerSuccess() *CommandProducerSuccess + func (m *BaseCommand) GetReachedEndOfTopic() *CommandReachedEndOfTopic + func (m *BaseCommand) GetRedeliverUnacknowledgedMessages() *CommandRedeliverUnacknowledgedMessages + func (m *BaseCommand) GetSeek() *CommandSeek + func (m *BaseCommand) GetSend() *CommandSend + func (m *BaseCommand) GetSendError() *CommandSendError + func (m *BaseCommand) GetSendReceipt() *CommandSendReceipt + func (m *BaseCommand) GetSubscribe() *CommandSubscribe + func (m *BaseCommand) GetSuccess() *CommandSuccess + func (m *BaseCommand) GetTcClientConnectRequest() *CommandTcClientConnectRequest + func (m *BaseCommand) GetTcClientConnectResponse() *CommandTcClientConnectResponse + func (m *BaseCommand) GetType() BaseCommand_Type + func (m *BaseCommand) GetUnsubscribe() *CommandUnsubscribe + func (m *BaseCommand) GetWatchTopicList() *CommandWatchTopicList + func (m *BaseCommand) GetWatchTopicListClose() *CommandWatchTopicListClose + func (m *BaseCommand) GetWatchTopicListSuccess() *CommandWatchTopicListSuccess + func (m *BaseCommand) GetWatchTopicUpdate() *CommandWatchTopicUpdate + func (m *BaseCommand) Marshal() (dAtA []byte, err error) + func (m *BaseCommand) MarshalTo(dAtA []byte) (int, error) + func (m *BaseCommand) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BaseCommand) Reset() + func (m *BaseCommand) Size() (n int) + func (m *BaseCommand) String() string + func (m *BaseCommand) Unmarshal(dAtA []byte) error + func (m *BaseCommand) XXX_DiscardUnknown() + func (m *BaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BaseCommand) XXX_Merge(src proto.Message) + func (m *BaseCommand) XXX_Size() int + func (m *BaseCommand) XXX_Unmarshal(b []byte) error + type BaseCommand_Type int32 + const BaseCommand_ACK + const BaseCommand_ACK_RESPONSE + const BaseCommand_ACTIVE_CONSUMER_CHANGE + const BaseCommand_ADD_PARTITION_TO_TXN + const BaseCommand_ADD_PARTITION_TO_TXN_RESPONSE + const BaseCommand_ADD_SUBSCRIPTION_TO_TXN + const BaseCommand_ADD_SUBSCRIPTION_TO_TXN_RESPONSE + const BaseCommand_AUTH_CHALLENGE + const BaseCommand_AUTH_RESPONSE + const BaseCommand_CLOSE_CONSUMER + const BaseCommand_CLOSE_PRODUCER + const BaseCommand_CONNECT + const BaseCommand_CONNECTED + const BaseCommand_CONSUMER_STATS + const BaseCommand_CONSUMER_STATS_RESPONSE + const BaseCommand_END_TXN + const BaseCommand_END_TXN_ON_PARTITION + const BaseCommand_END_TXN_ON_PARTITION_RESPONSE + const BaseCommand_END_TXN_ON_SUBSCRIPTION + const BaseCommand_END_TXN_ON_SUBSCRIPTION_RESPONSE + const BaseCommand_END_TXN_RESPONSE + const BaseCommand_ERROR + const BaseCommand_FLOW + const BaseCommand_GET_LAST_MESSAGE_ID + const BaseCommand_GET_LAST_MESSAGE_ID_RESPONSE + const BaseCommand_GET_OR_CREATE_SCHEMA + const BaseCommand_GET_OR_CREATE_SCHEMA_RESPONSE + const BaseCommand_GET_SCHEMA + const BaseCommand_GET_SCHEMA_RESPONSE + const BaseCommand_GET_TOPICS_OF_NAMESPACE + const BaseCommand_GET_TOPICS_OF_NAMESPACE_RESPONSE + const BaseCommand_LOOKUP + const BaseCommand_LOOKUP_RESPONSE + const BaseCommand_MESSAGE + const BaseCommand_NEW_TXN + const BaseCommand_NEW_TXN_RESPONSE + const BaseCommand_PARTITIONED_METADATA + const BaseCommand_PARTITIONED_METADATA_RESPONSE + const BaseCommand_PING + const BaseCommand_PONG + const BaseCommand_PRODUCER + const BaseCommand_PRODUCER_SUCCESS + const BaseCommand_REACHED_END_OF_TOPIC + const BaseCommand_REDELIVER_UNACKNOWLEDGED_MESSAGES + const BaseCommand_SEEK + const BaseCommand_SEND + const BaseCommand_SEND_ERROR + const BaseCommand_SEND_RECEIPT + const BaseCommand_SUBSCRIBE + const BaseCommand_SUCCESS + const BaseCommand_TC_CLIENT_CONNECT_REQUEST + const BaseCommand_TC_CLIENT_CONNECT_RESPONSE + const BaseCommand_UNSUBSCRIBE + const BaseCommand_WATCH_TOPIC_LIST + const BaseCommand_WATCH_TOPIC_LIST_CLOSE + const BaseCommand_WATCH_TOPIC_LIST_SUCCESS + const BaseCommand_WATCH_TOPIC_UPDATE + func (BaseCommand_Type) EnumDescriptor() ([]byte, []int) + func (x *BaseCommand_Type) UnmarshalJSON(data []byte) error + func (x BaseCommand_Type) Enum() *BaseCommand_Type + func (x BaseCommand_Type) String() string + type BrokerEntryMetadata struct + BrokerTimestamp *uint64 + Index *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BrokerEntryMetadata) Descriptor() ([]byte, []int) + func (*BrokerEntryMetadata) ProtoMessage() + func (m *BrokerEntryMetadata) GetBrokerTimestamp() uint64 + func (m *BrokerEntryMetadata) GetIndex() uint64 + func (m *BrokerEntryMetadata) Marshal() (dAtA []byte, err error) + func (m *BrokerEntryMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *BrokerEntryMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BrokerEntryMetadata) Reset() + func (m *BrokerEntryMetadata) Size() (n int) + func (m *BrokerEntryMetadata) String() string + func (m *BrokerEntryMetadata) Unmarshal(dAtA []byte) error + func (m *BrokerEntryMetadata) XXX_DiscardUnknown() + func (m *BrokerEntryMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BrokerEntryMetadata) XXX_Merge(src proto.Message) + func (m *BrokerEntryMetadata) XXX_Size() int + func (m *BrokerEntryMetadata) XXX_Unmarshal(b []byte) error + type CommandAck struct + AckType *CommandAck_AckType + ConsumerId *uint64 + MessageId []*MessageIdData + Properties []*KeyLongValue + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + ValidationError *CommandAck_ValidationError + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAck) Descriptor() ([]byte, []int) + func (*CommandAck) ProtoMessage() + func (m *CommandAck) GetAckType() CommandAck_AckType + func (m *CommandAck) GetConsumerId() uint64 + func (m *CommandAck) GetMessageId() []*MessageIdData + func (m *CommandAck) GetProperties() []*KeyLongValue + func (m *CommandAck) GetRequestId() uint64 + func (m *CommandAck) GetTxnidLeastBits() uint64 + func (m *CommandAck) GetTxnidMostBits() uint64 + func (m *CommandAck) GetValidationError() CommandAck_ValidationError + func (m *CommandAck) Marshal() (dAtA []byte, err error) + func (m *CommandAck) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAck) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAck) Reset() + func (m *CommandAck) Size() (n int) + func (m *CommandAck) String() string + func (m *CommandAck) Unmarshal(dAtA []byte) error + func (m *CommandAck) XXX_DiscardUnknown() + func (m *CommandAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAck) XXX_Merge(src proto.Message) + func (m *CommandAck) XXX_Size() int + func (m *CommandAck) XXX_Unmarshal(b []byte) error + type CommandAckResponse struct + ConsumerId *uint64 + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAckResponse) Descriptor() ([]byte, []int) + func (*CommandAckResponse) ProtoMessage() + func (m *CommandAckResponse) GetConsumerId() uint64 + func (m *CommandAckResponse) GetError() ServerError + func (m *CommandAckResponse) GetMessage() string + func (m *CommandAckResponse) GetRequestId() uint64 + func (m *CommandAckResponse) GetTxnidLeastBits() uint64 + func (m *CommandAckResponse) GetTxnidMostBits() uint64 + func (m *CommandAckResponse) Marshal() (dAtA []byte, err error) + func (m *CommandAckResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAckResponse) Reset() + func (m *CommandAckResponse) Size() (n int) + func (m *CommandAckResponse) String() string + func (m *CommandAckResponse) Unmarshal(dAtA []byte) error + func (m *CommandAckResponse) XXX_DiscardUnknown() + func (m *CommandAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAckResponse) XXX_Merge(src proto.Message) + func (m *CommandAckResponse) XXX_Size() int + func (m *CommandAckResponse) XXX_Unmarshal(b []byte) error + type CommandAck_AckType int32 + const CommandAck_Cumulative + const CommandAck_Individual + func (CommandAck_AckType) EnumDescriptor() ([]byte, []int) + func (x *CommandAck_AckType) UnmarshalJSON(data []byte) error + func (x CommandAck_AckType) Enum() *CommandAck_AckType + func (x CommandAck_AckType) String() string + type CommandAck_ValidationError int32 + const CommandAck_BatchDeSerializeError + const CommandAck_ChecksumMismatch + const CommandAck_DecompressionError + const CommandAck_DecryptionError + const CommandAck_UncompressedSizeCorruption + func (CommandAck_ValidationError) EnumDescriptor() ([]byte, []int) + func (x *CommandAck_ValidationError) UnmarshalJSON(data []byte) error + func (x CommandAck_ValidationError) Enum() *CommandAck_ValidationError + func (x CommandAck_ValidationError) String() string + type CommandActiveConsumerChange struct + ConsumerId *uint64 + IsActive *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandActiveConsumerChange) Descriptor() ([]byte, []int) + func (*CommandActiveConsumerChange) ProtoMessage() + func (m *CommandActiveConsumerChange) GetConsumerId() uint64 + func (m *CommandActiveConsumerChange) GetIsActive() bool + func (m *CommandActiveConsumerChange) Marshal() (dAtA []byte, err error) + func (m *CommandActiveConsumerChange) MarshalTo(dAtA []byte) (int, error) + func (m *CommandActiveConsumerChange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandActiveConsumerChange) Reset() + func (m *CommandActiveConsumerChange) Size() (n int) + func (m *CommandActiveConsumerChange) String() string + func (m *CommandActiveConsumerChange) Unmarshal(dAtA []byte) error + func (m *CommandActiveConsumerChange) XXX_DiscardUnknown() + func (m *CommandActiveConsumerChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandActiveConsumerChange) XXX_Merge(src proto.Message) + func (m *CommandActiveConsumerChange) XXX_Size() int + func (m *CommandActiveConsumerChange) XXX_Unmarshal(b []byte) error + type CommandAddPartitionToTxn struct + Partitions []string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAddPartitionToTxn) Descriptor() ([]byte, []int) + func (*CommandAddPartitionToTxn) ProtoMessage() + func (m *CommandAddPartitionToTxn) GetPartitions() []string + func (m *CommandAddPartitionToTxn) GetRequestId() uint64 + func (m *CommandAddPartitionToTxn) GetTxnidLeastBits() uint64 + func (m *CommandAddPartitionToTxn) GetTxnidMostBits() uint64 + func (m *CommandAddPartitionToTxn) Marshal() (dAtA []byte, err error) + func (m *CommandAddPartitionToTxn) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAddPartitionToTxn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAddPartitionToTxn) Reset() + func (m *CommandAddPartitionToTxn) Size() (n int) + func (m *CommandAddPartitionToTxn) String() string + func (m *CommandAddPartitionToTxn) Unmarshal(dAtA []byte) error + func (m *CommandAddPartitionToTxn) XXX_DiscardUnknown() + func (m *CommandAddPartitionToTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAddPartitionToTxn) XXX_Merge(src proto.Message) + func (m *CommandAddPartitionToTxn) XXX_Size() int + func (m *CommandAddPartitionToTxn) XXX_Unmarshal(b []byte) error + type CommandAddPartitionToTxnResponse struct + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAddPartitionToTxnResponse) Descriptor() ([]byte, []int) + func (*CommandAddPartitionToTxnResponse) ProtoMessage() + func (m *CommandAddPartitionToTxnResponse) GetError() ServerError + func (m *CommandAddPartitionToTxnResponse) GetMessage() string + func (m *CommandAddPartitionToTxnResponse) GetRequestId() uint64 + func (m *CommandAddPartitionToTxnResponse) GetTxnidLeastBits() uint64 + func (m *CommandAddPartitionToTxnResponse) GetTxnidMostBits() uint64 + func (m *CommandAddPartitionToTxnResponse) Marshal() (dAtA []byte, err error) + func (m *CommandAddPartitionToTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAddPartitionToTxnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAddPartitionToTxnResponse) Reset() + func (m *CommandAddPartitionToTxnResponse) Size() (n int) + func (m *CommandAddPartitionToTxnResponse) String() string + func (m *CommandAddPartitionToTxnResponse) Unmarshal(dAtA []byte) error + func (m *CommandAddPartitionToTxnResponse) XXX_DiscardUnknown() + func (m *CommandAddPartitionToTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAddPartitionToTxnResponse) XXX_Merge(src proto.Message) + func (m *CommandAddPartitionToTxnResponse) XXX_Size() int + func (m *CommandAddPartitionToTxnResponse) XXX_Unmarshal(b []byte) error + type CommandAddSubscriptionToTxn struct + RequestId *uint64 + Subscription []*Subscription + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAddSubscriptionToTxn) Descriptor() ([]byte, []int) + func (*CommandAddSubscriptionToTxn) ProtoMessage() + func (m *CommandAddSubscriptionToTxn) GetRequestId() uint64 + func (m *CommandAddSubscriptionToTxn) GetSubscription() []*Subscription + func (m *CommandAddSubscriptionToTxn) GetTxnidLeastBits() uint64 + func (m *CommandAddSubscriptionToTxn) GetTxnidMostBits() uint64 + func (m *CommandAddSubscriptionToTxn) Marshal() (dAtA []byte, err error) + func (m *CommandAddSubscriptionToTxn) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAddSubscriptionToTxn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAddSubscriptionToTxn) Reset() + func (m *CommandAddSubscriptionToTxn) Size() (n int) + func (m *CommandAddSubscriptionToTxn) String() string + func (m *CommandAddSubscriptionToTxn) Unmarshal(dAtA []byte) error + func (m *CommandAddSubscriptionToTxn) XXX_DiscardUnknown() + func (m *CommandAddSubscriptionToTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAddSubscriptionToTxn) XXX_Merge(src proto.Message) + func (m *CommandAddSubscriptionToTxn) XXX_Size() int + func (m *CommandAddSubscriptionToTxn) XXX_Unmarshal(b []byte) error + type CommandAddSubscriptionToTxnResponse struct + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAddSubscriptionToTxnResponse) Descriptor() ([]byte, []int) + func (*CommandAddSubscriptionToTxnResponse) ProtoMessage() + func (m *CommandAddSubscriptionToTxnResponse) GetError() ServerError + func (m *CommandAddSubscriptionToTxnResponse) GetMessage() string + func (m *CommandAddSubscriptionToTxnResponse) GetRequestId() uint64 + func (m *CommandAddSubscriptionToTxnResponse) GetTxnidLeastBits() uint64 + func (m *CommandAddSubscriptionToTxnResponse) GetTxnidMostBits() uint64 + func (m *CommandAddSubscriptionToTxnResponse) Marshal() (dAtA []byte, err error) + func (m *CommandAddSubscriptionToTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAddSubscriptionToTxnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAddSubscriptionToTxnResponse) Reset() + func (m *CommandAddSubscriptionToTxnResponse) Size() (n int) + func (m *CommandAddSubscriptionToTxnResponse) String() string + func (m *CommandAddSubscriptionToTxnResponse) Unmarshal(dAtA []byte) error + func (m *CommandAddSubscriptionToTxnResponse) XXX_DiscardUnknown() + func (m *CommandAddSubscriptionToTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAddSubscriptionToTxnResponse) XXX_Merge(src proto.Message) + func (m *CommandAddSubscriptionToTxnResponse) XXX_Size() int + func (m *CommandAddSubscriptionToTxnResponse) XXX_Unmarshal(b []byte) error + type CommandAuthChallenge struct + Challenge *AuthData + ProtocolVersion *int32 + ServerVersion *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAuthChallenge) Descriptor() ([]byte, []int) + func (*CommandAuthChallenge) ProtoMessage() + func (m *CommandAuthChallenge) GetChallenge() *AuthData + func (m *CommandAuthChallenge) GetProtocolVersion() int32 + func (m *CommandAuthChallenge) GetServerVersion() string + func (m *CommandAuthChallenge) Marshal() (dAtA []byte, err error) + func (m *CommandAuthChallenge) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAuthChallenge) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAuthChallenge) Reset() + func (m *CommandAuthChallenge) Size() (n int) + func (m *CommandAuthChallenge) String() string + func (m *CommandAuthChallenge) Unmarshal(dAtA []byte) error + func (m *CommandAuthChallenge) XXX_DiscardUnknown() + func (m *CommandAuthChallenge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAuthChallenge) XXX_Merge(src proto.Message) + func (m *CommandAuthChallenge) XXX_Size() int + func (m *CommandAuthChallenge) XXX_Unmarshal(b []byte) error + type CommandAuthResponse struct + ClientVersion *string + ProtocolVersion *int32 + Response *AuthData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAuthResponse) Descriptor() ([]byte, []int) + func (*CommandAuthResponse) ProtoMessage() + func (m *CommandAuthResponse) GetClientVersion() string + func (m *CommandAuthResponse) GetProtocolVersion() int32 + func (m *CommandAuthResponse) GetResponse() *AuthData + func (m *CommandAuthResponse) Marshal() (dAtA []byte, err error) + func (m *CommandAuthResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandAuthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandAuthResponse) Reset() + func (m *CommandAuthResponse) Size() (n int) + func (m *CommandAuthResponse) String() string + func (m *CommandAuthResponse) Unmarshal(dAtA []byte) error + func (m *CommandAuthResponse) XXX_DiscardUnknown() + func (m *CommandAuthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAuthResponse) XXX_Merge(src proto.Message) + func (m *CommandAuthResponse) XXX_Size() int + func (m *CommandAuthResponse) XXX_Unmarshal(b []byte) error + type CommandCloseConsumer struct + ConsumerId *uint64 + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandCloseConsumer) Descriptor() ([]byte, []int) + func (*CommandCloseConsumer) ProtoMessage() + func (m *CommandCloseConsumer) GetConsumerId() uint64 + func (m *CommandCloseConsumer) GetRequestId() uint64 + func (m *CommandCloseConsumer) Marshal() (dAtA []byte, err error) + func (m *CommandCloseConsumer) MarshalTo(dAtA []byte) (int, error) + func (m *CommandCloseConsumer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandCloseConsumer) Reset() + func (m *CommandCloseConsumer) Size() (n int) + func (m *CommandCloseConsumer) String() string + func (m *CommandCloseConsumer) Unmarshal(dAtA []byte) error + func (m *CommandCloseConsumer) XXX_DiscardUnknown() + func (m *CommandCloseConsumer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandCloseConsumer) XXX_Merge(src proto.Message) + func (m *CommandCloseConsumer) XXX_Size() int + func (m *CommandCloseConsumer) XXX_Unmarshal(b []byte) error + type CommandCloseProducer struct + ProducerId *uint64 + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandCloseProducer) Descriptor() ([]byte, []int) + func (*CommandCloseProducer) ProtoMessage() + func (m *CommandCloseProducer) GetProducerId() uint64 + func (m *CommandCloseProducer) GetRequestId() uint64 + func (m *CommandCloseProducer) Marshal() (dAtA []byte, err error) + func (m *CommandCloseProducer) MarshalTo(dAtA []byte) (int, error) + func (m *CommandCloseProducer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandCloseProducer) Reset() + func (m *CommandCloseProducer) Size() (n int) + func (m *CommandCloseProducer) String() string + func (m *CommandCloseProducer) Unmarshal(dAtA []byte) error + func (m *CommandCloseProducer) XXX_DiscardUnknown() + func (m *CommandCloseProducer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandCloseProducer) XXX_Merge(src proto.Message) + func (m *CommandCloseProducer) XXX_Size() int + func (m *CommandCloseProducer) XXX_Unmarshal(b []byte) error + type CommandConnect struct + AuthData []byte + AuthMethod *AuthMethod + AuthMethodName *string + ClientVersion *string + FeatureFlags *FeatureFlags + OriginalAuthData *string + OriginalAuthMethod *string + OriginalPrincipal *string + ProtocolVersion *int32 + ProxyToBrokerUrl *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandConnect) Descriptor() ([]byte, []int) + func (*CommandConnect) ProtoMessage() + func (m *CommandConnect) GetAuthData() []byte + func (m *CommandConnect) GetAuthMethod() AuthMethod + func (m *CommandConnect) GetAuthMethodName() string + func (m *CommandConnect) GetClientVersion() string + func (m *CommandConnect) GetFeatureFlags() *FeatureFlags + func (m *CommandConnect) GetOriginalAuthData() string + func (m *CommandConnect) GetOriginalAuthMethod() string + func (m *CommandConnect) GetOriginalPrincipal() string + func (m *CommandConnect) GetProtocolVersion() int32 + func (m *CommandConnect) GetProxyToBrokerUrl() string + func (m *CommandConnect) Marshal() (dAtA []byte, err error) + func (m *CommandConnect) MarshalTo(dAtA []byte) (int, error) + func (m *CommandConnect) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandConnect) Reset() + func (m *CommandConnect) Size() (n int) + func (m *CommandConnect) String() string + func (m *CommandConnect) Unmarshal(dAtA []byte) error + func (m *CommandConnect) XXX_DiscardUnknown() + func (m *CommandConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandConnect) XXX_Merge(src proto.Message) + func (m *CommandConnect) XXX_Size() int + func (m *CommandConnect) XXX_Unmarshal(b []byte) error + type CommandConnected struct + FeatureFlags *FeatureFlags + MaxMessageSize *int32 + ProtocolVersion *int32 + ServerVersion *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandConnected) Descriptor() ([]byte, []int) + func (*CommandConnected) ProtoMessage() + func (m *CommandConnected) GetFeatureFlags() *FeatureFlags + func (m *CommandConnected) GetMaxMessageSize() int32 + func (m *CommandConnected) GetProtocolVersion() int32 + func (m *CommandConnected) GetServerVersion() string + func (m *CommandConnected) Marshal() (dAtA []byte, err error) + func (m *CommandConnected) MarshalTo(dAtA []byte) (int, error) + func (m *CommandConnected) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandConnected) Reset() + func (m *CommandConnected) Size() (n int) + func (m *CommandConnected) String() string + func (m *CommandConnected) Unmarshal(dAtA []byte) error + func (m *CommandConnected) XXX_DiscardUnknown() + func (m *CommandConnected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandConnected) XXX_Merge(src proto.Message) + func (m *CommandConnected) XXX_Size() int + func (m *CommandConnected) XXX_Unmarshal(b []byte) error + type CommandConsumerStats struct + ConsumerId *uint64 + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandConsumerStats) Descriptor() ([]byte, []int) + func (*CommandConsumerStats) ProtoMessage() + func (m *CommandConsumerStats) GetConsumerId() uint64 + func (m *CommandConsumerStats) GetRequestId() uint64 + func (m *CommandConsumerStats) Marshal() (dAtA []byte, err error) + func (m *CommandConsumerStats) MarshalTo(dAtA []byte) (int, error) + func (m *CommandConsumerStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandConsumerStats) Reset() + func (m *CommandConsumerStats) Size() (n int) + func (m *CommandConsumerStats) String() string + func (m *CommandConsumerStats) Unmarshal(dAtA []byte) error + func (m *CommandConsumerStats) XXX_DiscardUnknown() + func (m *CommandConsumerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandConsumerStats) XXX_Merge(src proto.Message) + func (m *CommandConsumerStats) XXX_Size() int + func (m *CommandConsumerStats) XXX_Unmarshal(b []byte) error + type CommandConsumerStatsResponse struct + Address *string + AvailablePermits *uint64 + BlockedConsumerOnUnackedMsgs *bool + ConnectedSince *string + ConsumerName *string + ErrorCode *ServerError + ErrorMessage *string + MessageAckRate *float64 + MsgBacklog *uint64 + MsgRateExpired *float64 + MsgRateOut *float64 + MsgRateRedeliver *float64 + MsgThroughputOut *float64 + RequestId *uint64 + Type *string + UnackedMessages *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandConsumerStatsResponse) Descriptor() ([]byte, []int) + func (*CommandConsumerStatsResponse) ProtoMessage() + func (m *CommandConsumerStatsResponse) GetAddress() string + func (m *CommandConsumerStatsResponse) GetAvailablePermits() uint64 + func (m *CommandConsumerStatsResponse) GetBlockedConsumerOnUnackedMsgs() bool + func (m *CommandConsumerStatsResponse) GetConnectedSince() string + func (m *CommandConsumerStatsResponse) GetConsumerName() string + func (m *CommandConsumerStatsResponse) GetErrorCode() ServerError + func (m *CommandConsumerStatsResponse) GetErrorMessage() string + func (m *CommandConsumerStatsResponse) GetMessageAckRate() float64 + func (m *CommandConsumerStatsResponse) GetMsgBacklog() uint64 + func (m *CommandConsumerStatsResponse) GetMsgRateExpired() float64 + func (m *CommandConsumerStatsResponse) GetMsgRateOut() float64 + func (m *CommandConsumerStatsResponse) GetMsgRateRedeliver() float64 + func (m *CommandConsumerStatsResponse) GetMsgThroughputOut() float64 + func (m *CommandConsumerStatsResponse) GetRequestId() uint64 + func (m *CommandConsumerStatsResponse) GetType() string + func (m *CommandConsumerStatsResponse) GetUnackedMessages() uint64 + func (m *CommandConsumerStatsResponse) Marshal() (dAtA []byte, err error) + func (m *CommandConsumerStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandConsumerStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandConsumerStatsResponse) Reset() + func (m *CommandConsumerStatsResponse) Size() (n int) + func (m *CommandConsumerStatsResponse) String() string + func (m *CommandConsumerStatsResponse) Unmarshal(dAtA []byte) error + func (m *CommandConsumerStatsResponse) XXX_DiscardUnknown() + func (m *CommandConsumerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandConsumerStatsResponse) XXX_Merge(src proto.Message) + func (m *CommandConsumerStatsResponse) XXX_Size() int + func (m *CommandConsumerStatsResponse) XXX_Unmarshal(b []byte) error + type CommandEndTxn struct + RequestId *uint64 + TxnAction *TxnAction + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandEndTxn) Descriptor() ([]byte, []int) + func (*CommandEndTxn) ProtoMessage() + func (m *CommandEndTxn) GetRequestId() uint64 + func (m *CommandEndTxn) GetTxnAction() TxnAction + func (m *CommandEndTxn) GetTxnidLeastBits() uint64 + func (m *CommandEndTxn) GetTxnidMostBits() uint64 + func (m *CommandEndTxn) Marshal() (dAtA []byte, err error) + func (m *CommandEndTxn) MarshalTo(dAtA []byte) (int, error) + func (m *CommandEndTxn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandEndTxn) Reset() + func (m *CommandEndTxn) Size() (n int) + func (m *CommandEndTxn) String() string + func (m *CommandEndTxn) Unmarshal(dAtA []byte) error + func (m *CommandEndTxn) XXX_DiscardUnknown() + func (m *CommandEndTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandEndTxn) XXX_Merge(src proto.Message) + func (m *CommandEndTxn) XXX_Size() int + func (m *CommandEndTxn) XXX_Unmarshal(b []byte) error + type CommandEndTxnOnPartition struct + RequestId *uint64 + Topic *string + TxnAction *TxnAction + TxnidLeastBits *uint64 + TxnidLeastBitsOfLowWatermark *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandEndTxnOnPartition) Descriptor() ([]byte, []int) + func (*CommandEndTxnOnPartition) ProtoMessage() + func (m *CommandEndTxnOnPartition) GetRequestId() uint64 + func (m *CommandEndTxnOnPartition) GetTopic() string + func (m *CommandEndTxnOnPartition) GetTxnAction() TxnAction + func (m *CommandEndTxnOnPartition) GetTxnidLeastBits() uint64 + func (m *CommandEndTxnOnPartition) GetTxnidLeastBitsOfLowWatermark() uint64 + func (m *CommandEndTxnOnPartition) GetTxnidMostBits() uint64 + func (m *CommandEndTxnOnPartition) Marshal() (dAtA []byte, err error) + func (m *CommandEndTxnOnPartition) MarshalTo(dAtA []byte) (int, error) + func (m *CommandEndTxnOnPartition) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandEndTxnOnPartition) Reset() + func (m *CommandEndTxnOnPartition) Size() (n int) + func (m *CommandEndTxnOnPartition) String() string + func (m *CommandEndTxnOnPartition) Unmarshal(dAtA []byte) error + func (m *CommandEndTxnOnPartition) XXX_DiscardUnknown() + func (m *CommandEndTxnOnPartition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandEndTxnOnPartition) XXX_Merge(src proto.Message) + func (m *CommandEndTxnOnPartition) XXX_Size() int + func (m *CommandEndTxnOnPartition) XXX_Unmarshal(b []byte) error + type CommandEndTxnOnPartitionResponse struct + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandEndTxnOnPartitionResponse) Descriptor() ([]byte, []int) + func (*CommandEndTxnOnPartitionResponse) ProtoMessage() + func (m *CommandEndTxnOnPartitionResponse) GetError() ServerError + func (m *CommandEndTxnOnPartitionResponse) GetMessage() string + func (m *CommandEndTxnOnPartitionResponse) GetRequestId() uint64 + func (m *CommandEndTxnOnPartitionResponse) GetTxnidLeastBits() uint64 + func (m *CommandEndTxnOnPartitionResponse) GetTxnidMostBits() uint64 + func (m *CommandEndTxnOnPartitionResponse) Marshal() (dAtA []byte, err error) + func (m *CommandEndTxnOnPartitionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandEndTxnOnPartitionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandEndTxnOnPartitionResponse) Reset() + func (m *CommandEndTxnOnPartitionResponse) Size() (n int) + func (m *CommandEndTxnOnPartitionResponse) String() string + func (m *CommandEndTxnOnPartitionResponse) Unmarshal(dAtA []byte) error + func (m *CommandEndTxnOnPartitionResponse) XXX_DiscardUnknown() + func (m *CommandEndTxnOnPartitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandEndTxnOnPartitionResponse) XXX_Merge(src proto.Message) + func (m *CommandEndTxnOnPartitionResponse) XXX_Size() int + func (m *CommandEndTxnOnPartitionResponse) XXX_Unmarshal(b []byte) error + type CommandEndTxnOnSubscription struct + RequestId *uint64 + Subscription *Subscription + TxnAction *TxnAction + TxnidLeastBits *uint64 + TxnidLeastBitsOfLowWatermark *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandEndTxnOnSubscription) Descriptor() ([]byte, []int) + func (*CommandEndTxnOnSubscription) ProtoMessage() + func (m *CommandEndTxnOnSubscription) GetRequestId() uint64 + func (m *CommandEndTxnOnSubscription) GetSubscription() *Subscription + func (m *CommandEndTxnOnSubscription) GetTxnAction() TxnAction + func (m *CommandEndTxnOnSubscription) GetTxnidLeastBits() uint64 + func (m *CommandEndTxnOnSubscription) GetTxnidLeastBitsOfLowWatermark() uint64 + func (m *CommandEndTxnOnSubscription) GetTxnidMostBits() uint64 + func (m *CommandEndTxnOnSubscription) Marshal() (dAtA []byte, err error) + func (m *CommandEndTxnOnSubscription) MarshalTo(dAtA []byte) (int, error) + func (m *CommandEndTxnOnSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandEndTxnOnSubscription) Reset() + func (m *CommandEndTxnOnSubscription) Size() (n int) + func (m *CommandEndTxnOnSubscription) String() string + func (m *CommandEndTxnOnSubscription) Unmarshal(dAtA []byte) error + func (m *CommandEndTxnOnSubscription) XXX_DiscardUnknown() + func (m *CommandEndTxnOnSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandEndTxnOnSubscription) XXX_Merge(src proto.Message) + func (m *CommandEndTxnOnSubscription) XXX_Size() int + func (m *CommandEndTxnOnSubscription) XXX_Unmarshal(b []byte) error + type CommandEndTxnOnSubscriptionResponse struct + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandEndTxnOnSubscriptionResponse) Descriptor() ([]byte, []int) + func (*CommandEndTxnOnSubscriptionResponse) ProtoMessage() + func (m *CommandEndTxnOnSubscriptionResponse) GetError() ServerError + func (m *CommandEndTxnOnSubscriptionResponse) GetMessage() string + func (m *CommandEndTxnOnSubscriptionResponse) GetRequestId() uint64 + func (m *CommandEndTxnOnSubscriptionResponse) GetTxnidLeastBits() uint64 + func (m *CommandEndTxnOnSubscriptionResponse) GetTxnidMostBits() uint64 + func (m *CommandEndTxnOnSubscriptionResponse) Marshal() (dAtA []byte, err error) + func (m *CommandEndTxnOnSubscriptionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandEndTxnOnSubscriptionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandEndTxnOnSubscriptionResponse) Reset() + func (m *CommandEndTxnOnSubscriptionResponse) Size() (n int) + func (m *CommandEndTxnOnSubscriptionResponse) String() string + func (m *CommandEndTxnOnSubscriptionResponse) Unmarshal(dAtA []byte) error + func (m *CommandEndTxnOnSubscriptionResponse) XXX_DiscardUnknown() + func (m *CommandEndTxnOnSubscriptionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandEndTxnOnSubscriptionResponse) XXX_Merge(src proto.Message) + func (m *CommandEndTxnOnSubscriptionResponse) XXX_Size() int + func (m *CommandEndTxnOnSubscriptionResponse) XXX_Unmarshal(b []byte) error + type CommandEndTxnResponse struct + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandEndTxnResponse) Descriptor() ([]byte, []int) + func (*CommandEndTxnResponse) ProtoMessage() + func (m *CommandEndTxnResponse) GetError() ServerError + func (m *CommandEndTxnResponse) GetMessage() string + func (m *CommandEndTxnResponse) GetRequestId() uint64 + func (m *CommandEndTxnResponse) GetTxnidLeastBits() uint64 + func (m *CommandEndTxnResponse) GetTxnidMostBits() uint64 + func (m *CommandEndTxnResponse) Marshal() (dAtA []byte, err error) + func (m *CommandEndTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandEndTxnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandEndTxnResponse) Reset() + func (m *CommandEndTxnResponse) Size() (n int) + func (m *CommandEndTxnResponse) String() string + func (m *CommandEndTxnResponse) Unmarshal(dAtA []byte) error + func (m *CommandEndTxnResponse) XXX_DiscardUnknown() + func (m *CommandEndTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandEndTxnResponse) XXX_Merge(src proto.Message) + func (m *CommandEndTxnResponse) XXX_Size() int + func (m *CommandEndTxnResponse) XXX_Unmarshal(b []byte) error + type CommandError struct + Error *ServerError + Message *string + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandError) Descriptor() ([]byte, []int) + func (*CommandError) ProtoMessage() + func (m *CommandError) GetError() ServerError + func (m *CommandError) GetMessage() string + func (m *CommandError) GetRequestId() uint64 + func (m *CommandError) Marshal() (dAtA []byte, err error) + func (m *CommandError) MarshalTo(dAtA []byte) (int, error) + func (m *CommandError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandError) Reset() + func (m *CommandError) Size() (n int) + func (m *CommandError) String() string + func (m *CommandError) Unmarshal(dAtA []byte) error + func (m *CommandError) XXX_DiscardUnknown() + func (m *CommandError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandError) XXX_Merge(src proto.Message) + func (m *CommandError) XXX_Size() int + func (m *CommandError) XXX_Unmarshal(b []byte) error + type CommandFlow struct + ConsumerId *uint64 + MessagePermits *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandFlow) Descriptor() ([]byte, []int) + func (*CommandFlow) ProtoMessage() + func (m *CommandFlow) GetConsumerId() uint64 + func (m *CommandFlow) GetMessagePermits() uint32 + func (m *CommandFlow) Marshal() (dAtA []byte, err error) + func (m *CommandFlow) MarshalTo(dAtA []byte) (int, error) + func (m *CommandFlow) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandFlow) Reset() + func (m *CommandFlow) Size() (n int) + func (m *CommandFlow) String() string + func (m *CommandFlow) Unmarshal(dAtA []byte) error + func (m *CommandFlow) XXX_DiscardUnknown() + func (m *CommandFlow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandFlow) XXX_Merge(src proto.Message) + func (m *CommandFlow) XXX_Size() int + func (m *CommandFlow) XXX_Unmarshal(b []byte) error + type CommandGetLastMessageId struct + ConsumerId *uint64 + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetLastMessageId) Descriptor() ([]byte, []int) + func (*CommandGetLastMessageId) ProtoMessage() + func (m *CommandGetLastMessageId) GetConsumerId() uint64 + func (m *CommandGetLastMessageId) GetRequestId() uint64 + func (m *CommandGetLastMessageId) Marshal() (dAtA []byte, err error) + func (m *CommandGetLastMessageId) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetLastMessageId) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetLastMessageId) Reset() + func (m *CommandGetLastMessageId) Size() (n int) + func (m *CommandGetLastMessageId) String() string + func (m *CommandGetLastMessageId) Unmarshal(dAtA []byte) error + func (m *CommandGetLastMessageId) XXX_DiscardUnknown() + func (m *CommandGetLastMessageId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetLastMessageId) XXX_Merge(src proto.Message) + func (m *CommandGetLastMessageId) XXX_Size() int + func (m *CommandGetLastMessageId) XXX_Unmarshal(b []byte) error + type CommandGetLastMessageIdResponse struct + ConsumerMarkDeletePosition *MessageIdData + LastMessageId *MessageIdData + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetLastMessageIdResponse) Descriptor() ([]byte, []int) + func (*CommandGetLastMessageIdResponse) ProtoMessage() + func (m *CommandGetLastMessageIdResponse) GetConsumerMarkDeletePosition() *MessageIdData + func (m *CommandGetLastMessageIdResponse) GetLastMessageId() *MessageIdData + func (m *CommandGetLastMessageIdResponse) GetRequestId() uint64 + func (m *CommandGetLastMessageIdResponse) Marshal() (dAtA []byte, err error) + func (m *CommandGetLastMessageIdResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetLastMessageIdResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetLastMessageIdResponse) Reset() + func (m *CommandGetLastMessageIdResponse) Size() (n int) + func (m *CommandGetLastMessageIdResponse) String() string + func (m *CommandGetLastMessageIdResponse) Unmarshal(dAtA []byte) error + func (m *CommandGetLastMessageIdResponse) XXX_DiscardUnknown() + func (m *CommandGetLastMessageIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetLastMessageIdResponse) XXX_Merge(src proto.Message) + func (m *CommandGetLastMessageIdResponse) XXX_Size() int + func (m *CommandGetLastMessageIdResponse) XXX_Unmarshal(b []byte) error + type CommandGetOrCreateSchema struct + RequestId *uint64 + Schema *Schema + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetOrCreateSchema) Descriptor() ([]byte, []int) + func (*CommandGetOrCreateSchema) ProtoMessage() + func (m *CommandGetOrCreateSchema) GetRequestId() uint64 + func (m *CommandGetOrCreateSchema) GetSchema() *Schema + func (m *CommandGetOrCreateSchema) GetTopic() string + func (m *CommandGetOrCreateSchema) Marshal() (dAtA []byte, err error) + func (m *CommandGetOrCreateSchema) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetOrCreateSchema) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetOrCreateSchema) Reset() + func (m *CommandGetOrCreateSchema) Size() (n int) + func (m *CommandGetOrCreateSchema) String() string + func (m *CommandGetOrCreateSchema) Unmarshal(dAtA []byte) error + func (m *CommandGetOrCreateSchema) XXX_DiscardUnknown() + func (m *CommandGetOrCreateSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetOrCreateSchema) XXX_Merge(src proto.Message) + func (m *CommandGetOrCreateSchema) XXX_Size() int + func (m *CommandGetOrCreateSchema) XXX_Unmarshal(b []byte) error + type CommandGetOrCreateSchemaResponse struct + ErrorCode *ServerError + ErrorMessage *string + RequestId *uint64 + SchemaVersion []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetOrCreateSchemaResponse) Descriptor() ([]byte, []int) + func (*CommandGetOrCreateSchemaResponse) ProtoMessage() + func (m *CommandGetOrCreateSchemaResponse) GetErrorCode() ServerError + func (m *CommandGetOrCreateSchemaResponse) GetErrorMessage() string + func (m *CommandGetOrCreateSchemaResponse) GetRequestId() uint64 + func (m *CommandGetOrCreateSchemaResponse) GetSchemaVersion() []byte + func (m *CommandGetOrCreateSchemaResponse) Marshal() (dAtA []byte, err error) + func (m *CommandGetOrCreateSchemaResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetOrCreateSchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetOrCreateSchemaResponse) Reset() + func (m *CommandGetOrCreateSchemaResponse) Size() (n int) + func (m *CommandGetOrCreateSchemaResponse) String() string + func (m *CommandGetOrCreateSchemaResponse) Unmarshal(dAtA []byte) error + func (m *CommandGetOrCreateSchemaResponse) XXX_DiscardUnknown() + func (m *CommandGetOrCreateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetOrCreateSchemaResponse) XXX_Merge(src proto.Message) + func (m *CommandGetOrCreateSchemaResponse) XXX_Size() int + func (m *CommandGetOrCreateSchemaResponse) XXX_Unmarshal(b []byte) error + type CommandGetSchema struct + RequestId *uint64 + SchemaVersion []byte + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetSchema) Descriptor() ([]byte, []int) + func (*CommandGetSchema) ProtoMessage() + func (m *CommandGetSchema) GetRequestId() uint64 + func (m *CommandGetSchema) GetSchemaVersion() []byte + func (m *CommandGetSchema) GetTopic() string + func (m *CommandGetSchema) Marshal() (dAtA []byte, err error) + func (m *CommandGetSchema) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetSchema) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetSchema) Reset() + func (m *CommandGetSchema) Size() (n int) + func (m *CommandGetSchema) String() string + func (m *CommandGetSchema) Unmarshal(dAtA []byte) error + func (m *CommandGetSchema) XXX_DiscardUnknown() + func (m *CommandGetSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetSchema) XXX_Merge(src proto.Message) + func (m *CommandGetSchema) XXX_Size() int + func (m *CommandGetSchema) XXX_Unmarshal(b []byte) error + type CommandGetSchemaResponse struct + ErrorCode *ServerError + ErrorMessage *string + RequestId *uint64 + Schema *Schema + SchemaVersion []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetSchemaResponse) Descriptor() ([]byte, []int) + func (*CommandGetSchemaResponse) ProtoMessage() + func (m *CommandGetSchemaResponse) GetErrorCode() ServerError + func (m *CommandGetSchemaResponse) GetErrorMessage() string + func (m *CommandGetSchemaResponse) GetRequestId() uint64 + func (m *CommandGetSchemaResponse) GetSchema() *Schema + func (m *CommandGetSchemaResponse) GetSchemaVersion() []byte + func (m *CommandGetSchemaResponse) Marshal() (dAtA []byte, err error) + func (m *CommandGetSchemaResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetSchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetSchemaResponse) Reset() + func (m *CommandGetSchemaResponse) Size() (n int) + func (m *CommandGetSchemaResponse) String() string + func (m *CommandGetSchemaResponse) Unmarshal(dAtA []byte) error + func (m *CommandGetSchemaResponse) XXX_DiscardUnknown() + func (m *CommandGetSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetSchemaResponse) XXX_Merge(src proto.Message) + func (m *CommandGetSchemaResponse) XXX_Size() int + func (m *CommandGetSchemaResponse) XXX_Unmarshal(b []byte) error + type CommandGetTopicsOfNamespace struct + Mode *CommandGetTopicsOfNamespace_Mode + Namespace *string + RequestId *uint64 + TopicsHash *string + TopicsPattern *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetTopicsOfNamespace) Descriptor() ([]byte, []int) + func (*CommandGetTopicsOfNamespace) ProtoMessage() + func (m *CommandGetTopicsOfNamespace) GetMode() CommandGetTopicsOfNamespace_Mode + func (m *CommandGetTopicsOfNamespace) GetNamespace() string + func (m *CommandGetTopicsOfNamespace) GetRequestId() uint64 + func (m *CommandGetTopicsOfNamespace) GetTopicsHash() string + func (m *CommandGetTopicsOfNamespace) GetTopicsPattern() string + func (m *CommandGetTopicsOfNamespace) Marshal() (dAtA []byte, err error) + func (m *CommandGetTopicsOfNamespace) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetTopicsOfNamespace) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetTopicsOfNamespace) Reset() + func (m *CommandGetTopicsOfNamespace) Size() (n int) + func (m *CommandGetTopicsOfNamespace) String() string + func (m *CommandGetTopicsOfNamespace) Unmarshal(dAtA []byte) error + func (m *CommandGetTopicsOfNamespace) XXX_DiscardUnknown() + func (m *CommandGetTopicsOfNamespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetTopicsOfNamespace) XXX_Merge(src proto.Message) + func (m *CommandGetTopicsOfNamespace) XXX_Size() int + func (m *CommandGetTopicsOfNamespace) XXX_Unmarshal(b []byte) error + type CommandGetTopicsOfNamespaceResponse struct + Changed *bool + Filtered *bool + RequestId *uint64 + Topics []string + TopicsHash *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetTopicsOfNamespaceResponse) Descriptor() ([]byte, []int) + func (*CommandGetTopicsOfNamespaceResponse) ProtoMessage() + func (m *CommandGetTopicsOfNamespaceResponse) GetChanged() bool + func (m *CommandGetTopicsOfNamespaceResponse) GetFiltered() bool + func (m *CommandGetTopicsOfNamespaceResponse) GetRequestId() uint64 + func (m *CommandGetTopicsOfNamespaceResponse) GetTopics() []string + func (m *CommandGetTopicsOfNamespaceResponse) GetTopicsHash() string + func (m *CommandGetTopicsOfNamespaceResponse) Marshal() (dAtA []byte, err error) + func (m *CommandGetTopicsOfNamespaceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandGetTopicsOfNamespaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandGetTopicsOfNamespaceResponse) Reset() + func (m *CommandGetTopicsOfNamespaceResponse) Size() (n int) + func (m *CommandGetTopicsOfNamespaceResponse) String() string + func (m *CommandGetTopicsOfNamespaceResponse) Unmarshal(dAtA []byte) error + func (m *CommandGetTopicsOfNamespaceResponse) XXX_DiscardUnknown() + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Merge(src proto.Message) + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Size() int + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Unmarshal(b []byte) error + type CommandGetTopicsOfNamespace_Mode int32 + const CommandGetTopicsOfNamespace_ALL + const CommandGetTopicsOfNamespace_NON_PERSISTENT + const CommandGetTopicsOfNamespace_PERSISTENT + const Default_CommandGetTopicsOfNamespace_Mode + func (CommandGetTopicsOfNamespace_Mode) EnumDescriptor() ([]byte, []int) + func (x *CommandGetTopicsOfNamespace_Mode) UnmarshalJSON(data []byte) error + func (x CommandGetTopicsOfNamespace_Mode) Enum() *CommandGetTopicsOfNamespace_Mode + func (x CommandGetTopicsOfNamespace_Mode) String() string + type CommandLookupTopic struct + AdvertisedListenerName *string + Authoritative *bool + OriginalAuthData *string + OriginalAuthMethod *string + OriginalPrincipal *string + RequestId *uint64 + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandLookupTopic) Descriptor() ([]byte, []int) + func (*CommandLookupTopic) ProtoMessage() + func (m *CommandLookupTopic) GetAdvertisedListenerName() string + func (m *CommandLookupTopic) GetAuthoritative() bool + func (m *CommandLookupTopic) GetOriginalAuthData() string + func (m *CommandLookupTopic) GetOriginalAuthMethod() string + func (m *CommandLookupTopic) GetOriginalPrincipal() string + func (m *CommandLookupTopic) GetRequestId() uint64 + func (m *CommandLookupTopic) GetTopic() string + func (m *CommandLookupTopic) Marshal() (dAtA []byte, err error) + func (m *CommandLookupTopic) MarshalTo(dAtA []byte) (int, error) + func (m *CommandLookupTopic) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandLookupTopic) Reset() + func (m *CommandLookupTopic) Size() (n int) + func (m *CommandLookupTopic) String() string + func (m *CommandLookupTopic) Unmarshal(dAtA []byte) error + func (m *CommandLookupTopic) XXX_DiscardUnknown() + func (m *CommandLookupTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandLookupTopic) XXX_Merge(src proto.Message) + func (m *CommandLookupTopic) XXX_Size() int + func (m *CommandLookupTopic) XXX_Unmarshal(b []byte) error + type CommandLookupTopicResponse struct + Authoritative *bool + BrokerServiceUrl *string + BrokerServiceUrlTls *string + Error *ServerError + Message *string + ProxyThroughServiceUrl *bool + RequestId *uint64 + Response *CommandLookupTopicResponse_LookupType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandLookupTopicResponse) Descriptor() ([]byte, []int) + func (*CommandLookupTopicResponse) ProtoMessage() + func (m *CommandLookupTopicResponse) GetAuthoritative() bool + func (m *CommandLookupTopicResponse) GetBrokerServiceUrl() string + func (m *CommandLookupTopicResponse) GetBrokerServiceUrlTls() string + func (m *CommandLookupTopicResponse) GetError() ServerError + func (m *CommandLookupTopicResponse) GetMessage() string + func (m *CommandLookupTopicResponse) GetProxyThroughServiceUrl() bool + func (m *CommandLookupTopicResponse) GetRequestId() uint64 + func (m *CommandLookupTopicResponse) GetResponse() CommandLookupTopicResponse_LookupType + func (m *CommandLookupTopicResponse) Marshal() (dAtA []byte, err error) + func (m *CommandLookupTopicResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandLookupTopicResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandLookupTopicResponse) Reset() + func (m *CommandLookupTopicResponse) Size() (n int) + func (m *CommandLookupTopicResponse) String() string + func (m *CommandLookupTopicResponse) Unmarshal(dAtA []byte) error + func (m *CommandLookupTopicResponse) XXX_DiscardUnknown() + func (m *CommandLookupTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandLookupTopicResponse) XXX_Merge(src proto.Message) + func (m *CommandLookupTopicResponse) XXX_Size() int + func (m *CommandLookupTopicResponse) XXX_Unmarshal(b []byte) error + type CommandLookupTopicResponse_LookupType int32 + const CommandLookupTopicResponse_Connect + const CommandLookupTopicResponse_Failed + const CommandLookupTopicResponse_Redirect + func (CommandLookupTopicResponse_LookupType) EnumDescriptor() ([]byte, []int) + func (x *CommandLookupTopicResponse_LookupType) UnmarshalJSON(data []byte) error + func (x CommandLookupTopicResponse_LookupType) Enum() *CommandLookupTopicResponse_LookupType + func (x CommandLookupTopicResponse_LookupType) String() string + type CommandMessage struct + AckSet []int64 + ConsumerEpoch *uint64 + ConsumerId *uint64 + MessageId *MessageIdData + RedeliveryCount *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandMessage) Descriptor() ([]byte, []int) + func (*CommandMessage) ProtoMessage() + func (m *CommandMessage) GetAckSet() []int64 + func (m *CommandMessage) GetConsumerEpoch() uint64 + func (m *CommandMessage) GetConsumerId() uint64 + func (m *CommandMessage) GetMessageId() *MessageIdData + func (m *CommandMessage) GetRedeliveryCount() uint32 + func (m *CommandMessage) Marshal() (dAtA []byte, err error) + func (m *CommandMessage) MarshalTo(dAtA []byte) (int, error) + func (m *CommandMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandMessage) Reset() + func (m *CommandMessage) Size() (n int) + func (m *CommandMessage) String() string + func (m *CommandMessage) Unmarshal(dAtA []byte) error + func (m *CommandMessage) XXX_DiscardUnknown() + func (m *CommandMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandMessage) XXX_Merge(src proto.Message) + func (m *CommandMessage) XXX_Size() int + func (m *CommandMessage) XXX_Unmarshal(b []byte) error + type CommandNewTxn struct + RequestId *uint64 + TcId *uint64 + TxnTtlSeconds *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandNewTxn) Descriptor() ([]byte, []int) + func (*CommandNewTxn) ProtoMessage() + func (m *CommandNewTxn) GetRequestId() uint64 + func (m *CommandNewTxn) GetTcId() uint64 + func (m *CommandNewTxn) GetTxnTtlSeconds() uint64 + func (m *CommandNewTxn) Marshal() (dAtA []byte, err error) + func (m *CommandNewTxn) MarshalTo(dAtA []byte) (int, error) + func (m *CommandNewTxn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandNewTxn) Reset() + func (m *CommandNewTxn) Size() (n int) + func (m *CommandNewTxn) String() string + func (m *CommandNewTxn) Unmarshal(dAtA []byte) error + func (m *CommandNewTxn) XXX_DiscardUnknown() + func (m *CommandNewTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandNewTxn) XXX_Merge(src proto.Message) + func (m *CommandNewTxn) XXX_Size() int + func (m *CommandNewTxn) XXX_Unmarshal(b []byte) error + type CommandNewTxnResponse struct + Error *ServerError + Message *string + RequestId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandNewTxnResponse) Descriptor() ([]byte, []int) + func (*CommandNewTxnResponse) ProtoMessage() + func (m *CommandNewTxnResponse) GetError() ServerError + func (m *CommandNewTxnResponse) GetMessage() string + func (m *CommandNewTxnResponse) GetRequestId() uint64 + func (m *CommandNewTxnResponse) GetTxnidLeastBits() uint64 + func (m *CommandNewTxnResponse) GetTxnidMostBits() uint64 + func (m *CommandNewTxnResponse) Marshal() (dAtA []byte, err error) + func (m *CommandNewTxnResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandNewTxnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandNewTxnResponse) Reset() + func (m *CommandNewTxnResponse) Size() (n int) + func (m *CommandNewTxnResponse) String() string + func (m *CommandNewTxnResponse) Unmarshal(dAtA []byte) error + func (m *CommandNewTxnResponse) XXX_DiscardUnknown() + func (m *CommandNewTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandNewTxnResponse) XXX_Merge(src proto.Message) + func (m *CommandNewTxnResponse) XXX_Size() int + func (m *CommandNewTxnResponse) XXX_Unmarshal(b []byte) error + type CommandPartitionedTopicMetadata struct + OriginalAuthData *string + OriginalAuthMethod *string + OriginalPrincipal *string + RequestId *uint64 + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandPartitionedTopicMetadata) Descriptor() ([]byte, []int) + func (*CommandPartitionedTopicMetadata) ProtoMessage() + func (m *CommandPartitionedTopicMetadata) GetOriginalAuthData() string + func (m *CommandPartitionedTopicMetadata) GetOriginalAuthMethod() string + func (m *CommandPartitionedTopicMetadata) GetOriginalPrincipal() string + func (m *CommandPartitionedTopicMetadata) GetRequestId() uint64 + func (m *CommandPartitionedTopicMetadata) GetTopic() string + func (m *CommandPartitionedTopicMetadata) Marshal() (dAtA []byte, err error) + func (m *CommandPartitionedTopicMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *CommandPartitionedTopicMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandPartitionedTopicMetadata) Reset() + func (m *CommandPartitionedTopicMetadata) Size() (n int) + func (m *CommandPartitionedTopicMetadata) String() string + func (m *CommandPartitionedTopicMetadata) Unmarshal(dAtA []byte) error + func (m *CommandPartitionedTopicMetadata) XXX_DiscardUnknown() + func (m *CommandPartitionedTopicMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandPartitionedTopicMetadata) XXX_Merge(src proto.Message) + func (m *CommandPartitionedTopicMetadata) XXX_Size() int + func (m *CommandPartitionedTopicMetadata) XXX_Unmarshal(b []byte) error + type CommandPartitionedTopicMetadataResponse struct + Error *ServerError + Message *string + Partitions *uint32 + RequestId *uint64 + Response *CommandPartitionedTopicMetadataResponse_LookupType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandPartitionedTopicMetadataResponse) Descriptor() ([]byte, []int) + func (*CommandPartitionedTopicMetadataResponse) ProtoMessage() + func (m *CommandPartitionedTopicMetadataResponse) GetError() ServerError + func (m *CommandPartitionedTopicMetadataResponse) GetMessage() string + func (m *CommandPartitionedTopicMetadataResponse) GetPartitions() uint32 + func (m *CommandPartitionedTopicMetadataResponse) GetRequestId() uint64 + func (m *CommandPartitionedTopicMetadataResponse) GetResponse() CommandPartitionedTopicMetadataResponse_LookupType + func (m *CommandPartitionedTopicMetadataResponse) Marshal() (dAtA []byte, err error) + func (m *CommandPartitionedTopicMetadataResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandPartitionedTopicMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandPartitionedTopicMetadataResponse) Reset() + func (m *CommandPartitionedTopicMetadataResponse) Size() (n int) + func (m *CommandPartitionedTopicMetadataResponse) String() string + func (m *CommandPartitionedTopicMetadataResponse) Unmarshal(dAtA []byte) error + func (m *CommandPartitionedTopicMetadataResponse) XXX_DiscardUnknown() + func (m *CommandPartitionedTopicMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandPartitionedTopicMetadataResponse) XXX_Merge(src proto.Message) + func (m *CommandPartitionedTopicMetadataResponse) XXX_Size() int + func (m *CommandPartitionedTopicMetadataResponse) XXX_Unmarshal(b []byte) error + type CommandPartitionedTopicMetadataResponse_LookupType int32 + const CommandPartitionedTopicMetadataResponse_Failed + const CommandPartitionedTopicMetadataResponse_Success + func (CommandPartitionedTopicMetadataResponse_LookupType) EnumDescriptor() ([]byte, []int) + func (x *CommandPartitionedTopicMetadataResponse_LookupType) UnmarshalJSON(data []byte) error + func (x CommandPartitionedTopicMetadataResponse_LookupType) Enum() *CommandPartitionedTopicMetadataResponse_LookupType + func (x CommandPartitionedTopicMetadataResponse_LookupType) String() string + type CommandPing struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandPing) Descriptor() ([]byte, []int) + func (*CommandPing) ProtoMessage() + func (m *CommandPing) Marshal() (dAtA []byte, err error) + func (m *CommandPing) MarshalTo(dAtA []byte) (int, error) + func (m *CommandPing) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandPing) Reset() + func (m *CommandPing) Size() (n int) + func (m *CommandPing) String() string + func (m *CommandPing) Unmarshal(dAtA []byte) error + func (m *CommandPing) XXX_DiscardUnknown() + func (m *CommandPing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandPing) XXX_Merge(src proto.Message) + func (m *CommandPing) XXX_Size() int + func (m *CommandPing) XXX_Unmarshal(b []byte) error + type CommandPong struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandPong) Descriptor() ([]byte, []int) + func (*CommandPong) ProtoMessage() + func (m *CommandPong) Marshal() (dAtA []byte, err error) + func (m *CommandPong) MarshalTo(dAtA []byte) (int, error) + func (m *CommandPong) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandPong) Reset() + func (m *CommandPong) Size() (n int) + func (m *CommandPong) String() string + func (m *CommandPong) Unmarshal(dAtA []byte) error + func (m *CommandPong) XXX_DiscardUnknown() + func (m *CommandPong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandPong) XXX_Merge(src proto.Message) + func (m *CommandPong) XXX_Size() int + func (m *CommandPong) XXX_Unmarshal(b []byte) error + type CommandProducer struct + Encrypted *bool + Epoch *uint64 + InitialSubscriptionName *string + Metadata []*KeyValue + ProducerAccessMode *ProducerAccessMode + ProducerId *uint64 + ProducerName *string + RequestId *uint64 + Schema *Schema + Topic *string + TopicEpoch *uint64 + TxnEnabled *bool + UserProvidedProducerName *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandProducer) Descriptor() ([]byte, []int) + func (*CommandProducer) ProtoMessage() + func (m *CommandProducer) GetEncrypted() bool + func (m *CommandProducer) GetEpoch() uint64 + func (m *CommandProducer) GetInitialSubscriptionName() string + func (m *CommandProducer) GetMetadata() []*KeyValue + func (m *CommandProducer) GetProducerAccessMode() ProducerAccessMode + func (m *CommandProducer) GetProducerId() uint64 + func (m *CommandProducer) GetProducerName() string + func (m *CommandProducer) GetRequestId() uint64 + func (m *CommandProducer) GetSchema() *Schema + func (m *CommandProducer) GetTopic() string + func (m *CommandProducer) GetTopicEpoch() uint64 + func (m *CommandProducer) GetTxnEnabled() bool + func (m *CommandProducer) GetUserProvidedProducerName() bool + func (m *CommandProducer) Marshal() (dAtA []byte, err error) + func (m *CommandProducer) MarshalTo(dAtA []byte) (int, error) + func (m *CommandProducer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandProducer) Reset() + func (m *CommandProducer) Size() (n int) + func (m *CommandProducer) String() string + func (m *CommandProducer) Unmarshal(dAtA []byte) error + func (m *CommandProducer) XXX_DiscardUnknown() + func (m *CommandProducer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandProducer) XXX_Merge(src proto.Message) + func (m *CommandProducer) XXX_Size() int + func (m *CommandProducer) XXX_Unmarshal(b []byte) error + type CommandProducerSuccess struct + LastSequenceId *int64 + ProducerName *string + ProducerReady *bool + RequestId *uint64 + SchemaVersion []byte + TopicEpoch *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandProducerSuccess) Descriptor() ([]byte, []int) + func (*CommandProducerSuccess) ProtoMessage() + func (m *CommandProducerSuccess) GetLastSequenceId() int64 + func (m *CommandProducerSuccess) GetProducerName() string + func (m *CommandProducerSuccess) GetProducerReady() bool + func (m *CommandProducerSuccess) GetRequestId() uint64 + func (m *CommandProducerSuccess) GetSchemaVersion() []byte + func (m *CommandProducerSuccess) GetTopicEpoch() uint64 + func (m *CommandProducerSuccess) Marshal() (dAtA []byte, err error) + func (m *CommandProducerSuccess) MarshalTo(dAtA []byte) (int, error) + func (m *CommandProducerSuccess) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandProducerSuccess) Reset() + func (m *CommandProducerSuccess) Size() (n int) + func (m *CommandProducerSuccess) String() string + func (m *CommandProducerSuccess) Unmarshal(dAtA []byte) error + func (m *CommandProducerSuccess) XXX_DiscardUnknown() + func (m *CommandProducerSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandProducerSuccess) XXX_Merge(src proto.Message) + func (m *CommandProducerSuccess) XXX_Size() int + func (m *CommandProducerSuccess) XXX_Unmarshal(b []byte) error + type CommandReachedEndOfTopic struct + ConsumerId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandReachedEndOfTopic) Descriptor() ([]byte, []int) + func (*CommandReachedEndOfTopic) ProtoMessage() + func (m *CommandReachedEndOfTopic) GetConsumerId() uint64 + func (m *CommandReachedEndOfTopic) Marshal() (dAtA []byte, err error) + func (m *CommandReachedEndOfTopic) MarshalTo(dAtA []byte) (int, error) + func (m *CommandReachedEndOfTopic) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandReachedEndOfTopic) Reset() + func (m *CommandReachedEndOfTopic) Size() (n int) + func (m *CommandReachedEndOfTopic) String() string + func (m *CommandReachedEndOfTopic) Unmarshal(dAtA []byte) error + func (m *CommandReachedEndOfTopic) XXX_DiscardUnknown() + func (m *CommandReachedEndOfTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandReachedEndOfTopic) XXX_Merge(src proto.Message) + func (m *CommandReachedEndOfTopic) XXX_Size() int + func (m *CommandReachedEndOfTopic) XXX_Unmarshal(b []byte) error + type CommandRedeliverUnacknowledgedMessages struct + ConsumerEpoch *uint64 + ConsumerId *uint64 + MessageIds []*MessageIdData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandRedeliverUnacknowledgedMessages) Descriptor() ([]byte, []int) + func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage() + func (m *CommandRedeliverUnacknowledgedMessages) GetConsumerEpoch() uint64 + func (m *CommandRedeliverUnacknowledgedMessages) GetConsumerId() uint64 + func (m *CommandRedeliverUnacknowledgedMessages) GetMessageIds() []*MessageIdData + func (m *CommandRedeliverUnacknowledgedMessages) Marshal() (dAtA []byte, err error) + func (m *CommandRedeliverUnacknowledgedMessages) MarshalTo(dAtA []byte) (int, error) + func (m *CommandRedeliverUnacknowledgedMessages) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandRedeliverUnacknowledgedMessages) Reset() + func (m *CommandRedeliverUnacknowledgedMessages) Size() (n int) + func (m *CommandRedeliverUnacknowledgedMessages) String() string + func (m *CommandRedeliverUnacknowledgedMessages) Unmarshal(dAtA []byte) error + func (m *CommandRedeliverUnacknowledgedMessages) XXX_DiscardUnknown() + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Merge(src proto.Message) + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Size() int + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Unmarshal(b []byte) error + type CommandSeek struct + ConsumerId *uint64 + MessageId *MessageIdData + MessagePublishTime *uint64 + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSeek) Descriptor() ([]byte, []int) + func (*CommandSeek) ProtoMessage() + func (m *CommandSeek) GetConsumerId() uint64 + func (m *CommandSeek) GetMessageId() *MessageIdData + func (m *CommandSeek) GetMessagePublishTime() uint64 + func (m *CommandSeek) GetRequestId() uint64 + func (m *CommandSeek) Marshal() (dAtA []byte, err error) + func (m *CommandSeek) MarshalTo(dAtA []byte) (int, error) + func (m *CommandSeek) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandSeek) Reset() + func (m *CommandSeek) Size() (n int) + func (m *CommandSeek) String() string + func (m *CommandSeek) Unmarshal(dAtA []byte) error + func (m *CommandSeek) XXX_DiscardUnknown() + func (m *CommandSeek) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSeek) XXX_Merge(src proto.Message) + func (m *CommandSeek) XXX_Size() int + func (m *CommandSeek) XXX_Unmarshal(b []byte) error + type CommandSend struct + HighestSequenceId *uint64 + IsChunk *bool + Marker *bool + MessageId *MessageIdData + NumMessages *int32 + ProducerId *uint64 + SequenceId *uint64 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSend) Descriptor() ([]byte, []int) + func (*CommandSend) ProtoMessage() + func (m *CommandSend) GetHighestSequenceId() uint64 + func (m *CommandSend) GetIsChunk() bool + func (m *CommandSend) GetMarker() bool + func (m *CommandSend) GetMessageId() *MessageIdData + func (m *CommandSend) GetNumMessages() int32 + func (m *CommandSend) GetProducerId() uint64 + func (m *CommandSend) GetSequenceId() uint64 + func (m *CommandSend) GetTxnidLeastBits() uint64 + func (m *CommandSend) GetTxnidMostBits() uint64 + func (m *CommandSend) Marshal() (dAtA []byte, err error) + func (m *CommandSend) MarshalTo(dAtA []byte) (int, error) + func (m *CommandSend) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandSend) Reset() + func (m *CommandSend) Size() (n int) + func (m *CommandSend) String() string + func (m *CommandSend) Unmarshal(dAtA []byte) error + func (m *CommandSend) XXX_DiscardUnknown() + func (m *CommandSend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSend) XXX_Merge(src proto.Message) + func (m *CommandSend) XXX_Size() int + func (m *CommandSend) XXX_Unmarshal(b []byte) error + type CommandSendError struct + Error *ServerError + Message *string + ProducerId *uint64 + SequenceId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSendError) Descriptor() ([]byte, []int) + func (*CommandSendError) ProtoMessage() + func (m *CommandSendError) GetError() ServerError + func (m *CommandSendError) GetMessage() string + func (m *CommandSendError) GetProducerId() uint64 + func (m *CommandSendError) GetSequenceId() uint64 + func (m *CommandSendError) Marshal() (dAtA []byte, err error) + func (m *CommandSendError) MarshalTo(dAtA []byte) (int, error) + func (m *CommandSendError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandSendError) Reset() + func (m *CommandSendError) Size() (n int) + func (m *CommandSendError) String() string + func (m *CommandSendError) Unmarshal(dAtA []byte) error + func (m *CommandSendError) XXX_DiscardUnknown() + func (m *CommandSendError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSendError) XXX_Merge(src proto.Message) + func (m *CommandSendError) XXX_Size() int + func (m *CommandSendError) XXX_Unmarshal(b []byte) error + type CommandSendReceipt struct + HighestSequenceId *uint64 + MessageId *MessageIdData + ProducerId *uint64 + SequenceId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSendReceipt) Descriptor() ([]byte, []int) + func (*CommandSendReceipt) ProtoMessage() + func (m *CommandSendReceipt) GetHighestSequenceId() uint64 + func (m *CommandSendReceipt) GetMessageId() *MessageIdData + func (m *CommandSendReceipt) GetProducerId() uint64 + func (m *CommandSendReceipt) GetSequenceId() uint64 + func (m *CommandSendReceipt) Marshal() (dAtA []byte, err error) + func (m *CommandSendReceipt) MarshalTo(dAtA []byte) (int, error) + func (m *CommandSendReceipt) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandSendReceipt) Reset() + func (m *CommandSendReceipt) Size() (n int) + func (m *CommandSendReceipt) String() string + func (m *CommandSendReceipt) Unmarshal(dAtA []byte) error + func (m *CommandSendReceipt) XXX_DiscardUnknown() + func (m *CommandSendReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSendReceipt) XXX_Merge(src proto.Message) + func (m *CommandSendReceipt) XXX_Size() int + func (m *CommandSendReceipt) XXX_Unmarshal(b []byte) error + type CommandSubscribe struct + ConsumerEpoch *uint64 + ConsumerId *uint64 + ConsumerName *string + Durable *bool + ForceTopicCreation *bool + InitialPosition *CommandSubscribe_InitialPosition + KeySharedMeta *KeySharedMeta + Metadata []*KeyValue + PriorityLevel *int32 + ReadCompacted *bool + ReplicateSubscriptionState *bool + RequestId *uint64 + Schema *Schema + StartMessageId *MessageIdData + StartMessageRollbackDurationSec *uint64 + SubType *CommandSubscribe_SubType + Subscription *string + SubscriptionProperties []*KeyValue + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSubscribe) Descriptor() ([]byte, []int) + func (*CommandSubscribe) ProtoMessage() + func (m *CommandSubscribe) GetConsumerEpoch() uint64 + func (m *CommandSubscribe) GetConsumerId() uint64 + func (m *CommandSubscribe) GetConsumerName() string + func (m *CommandSubscribe) GetDurable() bool + func (m *CommandSubscribe) GetForceTopicCreation() bool + func (m *CommandSubscribe) GetInitialPosition() CommandSubscribe_InitialPosition + func (m *CommandSubscribe) GetKeySharedMeta() *KeySharedMeta + func (m *CommandSubscribe) GetMetadata() []*KeyValue + func (m *CommandSubscribe) GetPriorityLevel() int32 + func (m *CommandSubscribe) GetReadCompacted() bool + func (m *CommandSubscribe) GetReplicateSubscriptionState() bool + func (m *CommandSubscribe) GetRequestId() uint64 + func (m *CommandSubscribe) GetSchema() *Schema + func (m *CommandSubscribe) GetStartMessageId() *MessageIdData + func (m *CommandSubscribe) GetStartMessageRollbackDurationSec() uint64 + func (m *CommandSubscribe) GetSubType() CommandSubscribe_SubType + func (m *CommandSubscribe) GetSubscription() string + func (m *CommandSubscribe) GetSubscriptionProperties() []*KeyValue + func (m *CommandSubscribe) GetTopic() string + func (m *CommandSubscribe) Marshal() (dAtA []byte, err error) + func (m *CommandSubscribe) MarshalTo(dAtA []byte) (int, error) + func (m *CommandSubscribe) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandSubscribe) Reset() + func (m *CommandSubscribe) Size() (n int) + func (m *CommandSubscribe) String() string + func (m *CommandSubscribe) Unmarshal(dAtA []byte) error + func (m *CommandSubscribe) XXX_DiscardUnknown() + func (m *CommandSubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSubscribe) XXX_Merge(src proto.Message) + func (m *CommandSubscribe) XXX_Size() int + func (m *CommandSubscribe) XXX_Unmarshal(b []byte) error + type CommandSubscribe_InitialPosition int32 + const CommandSubscribe_Earliest + const CommandSubscribe_Latest + const Default_CommandSubscribe_InitialPosition + func (CommandSubscribe_InitialPosition) EnumDescriptor() ([]byte, []int) + func (x *CommandSubscribe_InitialPosition) UnmarshalJSON(data []byte) error + func (x CommandSubscribe_InitialPosition) Enum() *CommandSubscribe_InitialPosition + func (x CommandSubscribe_InitialPosition) String() string + type CommandSubscribe_SubType int32 + const CommandSubscribe_Exclusive + const CommandSubscribe_Failover + const CommandSubscribe_Key_Shared + const CommandSubscribe_Shared + func (CommandSubscribe_SubType) EnumDescriptor() ([]byte, []int) + func (x *CommandSubscribe_SubType) UnmarshalJSON(data []byte) error + func (x CommandSubscribe_SubType) Enum() *CommandSubscribe_SubType + func (x CommandSubscribe_SubType) String() string + type CommandSuccess struct + RequestId *uint64 + Schema *Schema + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSuccess) Descriptor() ([]byte, []int) + func (*CommandSuccess) ProtoMessage() + func (m *CommandSuccess) GetRequestId() uint64 + func (m *CommandSuccess) GetSchema() *Schema + func (m *CommandSuccess) Marshal() (dAtA []byte, err error) + func (m *CommandSuccess) MarshalTo(dAtA []byte) (int, error) + func (m *CommandSuccess) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandSuccess) Reset() + func (m *CommandSuccess) Size() (n int) + func (m *CommandSuccess) String() string + func (m *CommandSuccess) Unmarshal(dAtA []byte) error + func (m *CommandSuccess) XXX_DiscardUnknown() + func (m *CommandSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSuccess) XXX_Merge(src proto.Message) + func (m *CommandSuccess) XXX_Size() int + func (m *CommandSuccess) XXX_Unmarshal(b []byte) error + type CommandTcClientConnectRequest struct + RequestId *uint64 + TcId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandTcClientConnectRequest) Descriptor() ([]byte, []int) + func (*CommandTcClientConnectRequest) ProtoMessage() + func (m *CommandTcClientConnectRequest) GetRequestId() uint64 + func (m *CommandTcClientConnectRequest) GetTcId() uint64 + func (m *CommandTcClientConnectRequest) Marshal() (dAtA []byte, err error) + func (m *CommandTcClientConnectRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CommandTcClientConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandTcClientConnectRequest) Reset() + func (m *CommandTcClientConnectRequest) Size() (n int) + func (m *CommandTcClientConnectRequest) String() string + func (m *CommandTcClientConnectRequest) Unmarshal(dAtA []byte) error + func (m *CommandTcClientConnectRequest) XXX_DiscardUnknown() + func (m *CommandTcClientConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandTcClientConnectRequest) XXX_Merge(src proto.Message) + func (m *CommandTcClientConnectRequest) XXX_Size() int + func (m *CommandTcClientConnectRequest) XXX_Unmarshal(b []byte) error + type CommandTcClientConnectResponse struct + Error *ServerError + Message *string + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandTcClientConnectResponse) Descriptor() ([]byte, []int) + func (*CommandTcClientConnectResponse) ProtoMessage() + func (m *CommandTcClientConnectResponse) GetError() ServerError + func (m *CommandTcClientConnectResponse) GetMessage() string + func (m *CommandTcClientConnectResponse) GetRequestId() uint64 + func (m *CommandTcClientConnectResponse) Marshal() (dAtA []byte, err error) + func (m *CommandTcClientConnectResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandTcClientConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandTcClientConnectResponse) Reset() + func (m *CommandTcClientConnectResponse) Size() (n int) + func (m *CommandTcClientConnectResponse) String() string + func (m *CommandTcClientConnectResponse) Unmarshal(dAtA []byte) error + func (m *CommandTcClientConnectResponse) XXX_DiscardUnknown() + func (m *CommandTcClientConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandTcClientConnectResponse) XXX_Merge(src proto.Message) + func (m *CommandTcClientConnectResponse) XXX_Size() int + func (m *CommandTcClientConnectResponse) XXX_Unmarshal(b []byte) error + type CommandUnsubscribe struct + ConsumerId *uint64 + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandUnsubscribe) Descriptor() ([]byte, []int) + func (*CommandUnsubscribe) ProtoMessage() + func (m *CommandUnsubscribe) GetConsumerId() uint64 + func (m *CommandUnsubscribe) GetRequestId() uint64 + func (m *CommandUnsubscribe) Marshal() (dAtA []byte, err error) + func (m *CommandUnsubscribe) MarshalTo(dAtA []byte) (int, error) + func (m *CommandUnsubscribe) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandUnsubscribe) Reset() + func (m *CommandUnsubscribe) Size() (n int) + func (m *CommandUnsubscribe) String() string + func (m *CommandUnsubscribe) Unmarshal(dAtA []byte) error + func (m *CommandUnsubscribe) XXX_DiscardUnknown() + func (m *CommandUnsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandUnsubscribe) XXX_Merge(src proto.Message) + func (m *CommandUnsubscribe) XXX_Size() int + func (m *CommandUnsubscribe) XXX_Unmarshal(b []byte) error + type CommandWatchTopicList struct + Namespace *string + RequestId *uint64 + TopicsHash *string + TopicsPattern *string + WatcherId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandWatchTopicList) Descriptor() ([]byte, []int) + func (*CommandWatchTopicList) ProtoMessage() + func (m *CommandWatchTopicList) GetNamespace() string + func (m *CommandWatchTopicList) GetRequestId() uint64 + func (m *CommandWatchTopicList) GetTopicsHash() string + func (m *CommandWatchTopicList) GetTopicsPattern() string + func (m *CommandWatchTopicList) GetWatcherId() uint64 + func (m *CommandWatchTopicList) Marshal() (dAtA []byte, err error) + func (m *CommandWatchTopicList) MarshalTo(dAtA []byte) (int, error) + func (m *CommandWatchTopicList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandWatchTopicList) Reset() + func (m *CommandWatchTopicList) Size() (n int) + func (m *CommandWatchTopicList) String() string + func (m *CommandWatchTopicList) Unmarshal(dAtA []byte) error + func (m *CommandWatchTopicList) XXX_DiscardUnknown() + func (m *CommandWatchTopicList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandWatchTopicList) XXX_Merge(src proto.Message) + func (m *CommandWatchTopicList) XXX_Size() int + func (m *CommandWatchTopicList) XXX_Unmarshal(b []byte) error + type CommandWatchTopicListClose struct + RequestId *uint64 + WatcherId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandWatchTopicListClose) Descriptor() ([]byte, []int) + func (*CommandWatchTopicListClose) ProtoMessage() + func (m *CommandWatchTopicListClose) GetRequestId() uint64 + func (m *CommandWatchTopicListClose) GetWatcherId() uint64 + func (m *CommandWatchTopicListClose) Marshal() (dAtA []byte, err error) + func (m *CommandWatchTopicListClose) MarshalTo(dAtA []byte) (int, error) + func (m *CommandWatchTopicListClose) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandWatchTopicListClose) Reset() + func (m *CommandWatchTopicListClose) Size() (n int) + func (m *CommandWatchTopicListClose) String() string + func (m *CommandWatchTopicListClose) Unmarshal(dAtA []byte) error + func (m *CommandWatchTopicListClose) XXX_DiscardUnknown() + func (m *CommandWatchTopicListClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandWatchTopicListClose) XXX_Merge(src proto.Message) + func (m *CommandWatchTopicListClose) XXX_Size() int + func (m *CommandWatchTopicListClose) XXX_Unmarshal(b []byte) error + type CommandWatchTopicListSuccess struct + RequestId *uint64 + Topic []string + TopicsHash *string + WatcherId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandWatchTopicListSuccess) Descriptor() ([]byte, []int) + func (*CommandWatchTopicListSuccess) ProtoMessage() + func (m *CommandWatchTopicListSuccess) GetRequestId() uint64 + func (m *CommandWatchTopicListSuccess) GetTopic() []string + func (m *CommandWatchTopicListSuccess) GetTopicsHash() string + func (m *CommandWatchTopicListSuccess) GetWatcherId() uint64 + func (m *CommandWatchTopicListSuccess) Marshal() (dAtA []byte, err error) + func (m *CommandWatchTopicListSuccess) MarshalTo(dAtA []byte) (int, error) + func (m *CommandWatchTopicListSuccess) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandWatchTopicListSuccess) Reset() + func (m *CommandWatchTopicListSuccess) Size() (n int) + func (m *CommandWatchTopicListSuccess) String() string + func (m *CommandWatchTopicListSuccess) Unmarshal(dAtA []byte) error + func (m *CommandWatchTopicListSuccess) XXX_DiscardUnknown() + func (m *CommandWatchTopicListSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandWatchTopicListSuccess) XXX_Merge(src proto.Message) + func (m *CommandWatchTopicListSuccess) XXX_Size() int + func (m *CommandWatchTopicListSuccess) XXX_Unmarshal(b []byte) error + type CommandWatchTopicUpdate struct + DeletedTopics []string + NewTopics []string + TopicsHash *string + WatcherId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandWatchTopicUpdate) Descriptor() ([]byte, []int) + func (*CommandWatchTopicUpdate) ProtoMessage() + func (m *CommandWatchTopicUpdate) GetDeletedTopics() []string + func (m *CommandWatchTopicUpdate) GetNewTopics() []string + func (m *CommandWatchTopicUpdate) GetTopicsHash() string + func (m *CommandWatchTopicUpdate) GetWatcherId() uint64 + func (m *CommandWatchTopicUpdate) Marshal() (dAtA []byte, err error) + func (m *CommandWatchTopicUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *CommandWatchTopicUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandWatchTopicUpdate) Reset() + func (m *CommandWatchTopicUpdate) Size() (n int) + func (m *CommandWatchTopicUpdate) String() string + func (m *CommandWatchTopicUpdate) Unmarshal(dAtA []byte) error + func (m *CommandWatchTopicUpdate) XXX_DiscardUnknown() + func (m *CommandWatchTopicUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandWatchTopicUpdate) XXX_Merge(src proto.Message) + func (m *CommandWatchTopicUpdate) XXX_Size() int + func (m *CommandWatchTopicUpdate) XXX_Unmarshal(b []byte) error + type CompressionType int32 + const CompressionType_LZ4 + const CompressionType_NONE + const CompressionType_SNAPPY + const CompressionType_ZLIB + const CompressionType_ZSTD + const Default_MessageMetadata_Compression + func (CompressionType) EnumDescriptor() ([]byte, []int) + func (x *CompressionType) UnmarshalJSON(data []byte) error + func (x CompressionType) Enum() *CompressionType + func (x CompressionType) String() string + type EncryptionKeys struct + Key *string + Metadata []*KeyValue + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EncryptionKeys) Descriptor() ([]byte, []int) + func (*EncryptionKeys) ProtoMessage() + func (m *EncryptionKeys) GetKey() string + func (m *EncryptionKeys) GetMetadata() []*KeyValue + func (m *EncryptionKeys) GetValue() []byte + func (m *EncryptionKeys) Marshal() (dAtA []byte, err error) + func (m *EncryptionKeys) MarshalTo(dAtA []byte) (int, error) + func (m *EncryptionKeys) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EncryptionKeys) Reset() + func (m *EncryptionKeys) Size() (n int) + func (m *EncryptionKeys) String() string + func (m *EncryptionKeys) Unmarshal(dAtA []byte) error + func (m *EncryptionKeys) XXX_DiscardUnknown() + func (m *EncryptionKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EncryptionKeys) XXX_Merge(src proto.Message) + func (m *EncryptionKeys) XXX_Size() int + func (m *EncryptionKeys) XXX_Unmarshal(b []byte) error + type FeatureFlags struct + SupportsAuthRefresh *bool + SupportsBrokerEntryMetadata *bool + SupportsPartialProducer *bool + SupportsTopicWatchers *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FeatureFlags) Descriptor() ([]byte, []int) + func (*FeatureFlags) ProtoMessage() + func (m *FeatureFlags) GetSupportsAuthRefresh() bool + func (m *FeatureFlags) GetSupportsBrokerEntryMetadata() bool + func (m *FeatureFlags) GetSupportsPartialProducer() bool + func (m *FeatureFlags) GetSupportsTopicWatchers() bool + func (m *FeatureFlags) Marshal() (dAtA []byte, err error) + func (m *FeatureFlags) MarshalTo(dAtA []byte) (int, error) + func (m *FeatureFlags) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FeatureFlags) Reset() + func (m *FeatureFlags) Size() (n int) + func (m *FeatureFlags) String() string + func (m *FeatureFlags) Unmarshal(dAtA []byte) error + func (m *FeatureFlags) XXX_DiscardUnknown() + func (m *FeatureFlags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FeatureFlags) XXX_Merge(src proto.Message) + func (m *FeatureFlags) XXX_Size() int + func (m *FeatureFlags) XXX_Unmarshal(b []byte) error + type IntRange struct + End *int32 + Start *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IntRange) Descriptor() ([]byte, []int) + func (*IntRange) ProtoMessage() + func (m *IntRange) GetEnd() int32 + func (m *IntRange) GetStart() int32 + func (m *IntRange) Marshal() (dAtA []byte, err error) + func (m *IntRange) MarshalTo(dAtA []byte) (int, error) + func (m *IntRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IntRange) Reset() + func (m *IntRange) Size() (n int) + func (m *IntRange) String() string + func (m *IntRange) Unmarshal(dAtA []byte) error + func (m *IntRange) XXX_DiscardUnknown() + func (m *IntRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IntRange) XXX_Merge(src proto.Message) + func (m *IntRange) XXX_Size() int + func (m *IntRange) XXX_Unmarshal(b []byte) error + type KeyLongValue struct + Key *string + Value *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyLongValue) Descriptor() ([]byte, []int) + func (*KeyLongValue) ProtoMessage() + func (m *KeyLongValue) GetKey() string + func (m *KeyLongValue) GetValue() uint64 + func (m *KeyLongValue) Marshal() (dAtA []byte, err error) + func (m *KeyLongValue) MarshalTo(dAtA []byte) (int, error) + func (m *KeyLongValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyLongValue) Reset() + func (m *KeyLongValue) Size() (n int) + func (m *KeyLongValue) String() string + func (m *KeyLongValue) Unmarshal(dAtA []byte) error + func (m *KeyLongValue) XXX_DiscardUnknown() + func (m *KeyLongValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyLongValue) XXX_Merge(src proto.Message) + func (m *KeyLongValue) XXX_Size() int + func (m *KeyLongValue) XXX_Unmarshal(b []byte) error + type KeySharedMeta struct + AllowOutOfOrderDelivery *bool + HashRanges []*IntRange + KeySharedMode *KeySharedMode + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeySharedMeta) Descriptor() ([]byte, []int) + func (*KeySharedMeta) ProtoMessage() + func (m *KeySharedMeta) GetAllowOutOfOrderDelivery() bool + func (m *KeySharedMeta) GetHashRanges() []*IntRange + func (m *KeySharedMeta) GetKeySharedMode() KeySharedMode + func (m *KeySharedMeta) Marshal() (dAtA []byte, err error) + func (m *KeySharedMeta) MarshalTo(dAtA []byte) (int, error) + func (m *KeySharedMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeySharedMeta) Reset() + func (m *KeySharedMeta) Size() (n int) + func (m *KeySharedMeta) String() string + func (m *KeySharedMeta) Unmarshal(dAtA []byte) error + func (m *KeySharedMeta) XXX_DiscardUnknown() + func (m *KeySharedMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeySharedMeta) XXX_Merge(src proto.Message) + func (m *KeySharedMeta) XXX_Size() int + func (m *KeySharedMeta) XXX_Unmarshal(b []byte) error + type KeySharedMode int32 + const KeySharedMode_AUTO_SPLIT + const KeySharedMode_STICKY + func (KeySharedMode) EnumDescriptor() ([]byte, []int) + func (x *KeySharedMode) UnmarshalJSON(data []byte) error + func (x KeySharedMode) Enum() *KeySharedMode + func (x KeySharedMode) String() string + type KeyValue struct + Key *string + Value *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (m *KeyValue) GetKey() string + func (m *KeyValue) GetValue() string + func (m *KeyValue) Marshal() (dAtA []byte, err error) + func (m *KeyValue) MarshalTo(dAtA []byte) (int, error) + func (m *KeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyValue) Reset() + func (m *KeyValue) Size() (n int) + func (m *KeyValue) String() string + func (m *KeyValue) Unmarshal(dAtA []byte) error + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + type MessageIdData struct + AckSet []int64 + BatchIndex *int32 + BatchSize *int32 + EntryId *uint64 + FirstChunkMessageId *MessageIdData + LedgerId *uint64 + Partition *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MessageIdData) Descriptor() ([]byte, []int) + func (*MessageIdData) ProtoMessage() + func (m *MessageIdData) GetAckSet() []int64 + func (m *MessageIdData) GetBatchIndex() int32 + func (m *MessageIdData) GetBatchSize() int32 + func (m *MessageIdData) GetEntryId() uint64 + func (m *MessageIdData) GetFirstChunkMessageId() *MessageIdData + func (m *MessageIdData) GetLedgerId() uint64 + func (m *MessageIdData) GetPartition() int32 + func (m *MessageIdData) Marshal() (dAtA []byte, err error) + func (m *MessageIdData) MarshalTo(dAtA []byte) (int, error) + func (m *MessageIdData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MessageIdData) Reset() + func (m *MessageIdData) Size() (n int) + func (m *MessageIdData) String() string + func (m *MessageIdData) Unmarshal(dAtA []byte) error + func (m *MessageIdData) XXX_DiscardUnknown() + func (m *MessageIdData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MessageIdData) XXX_Merge(src proto.Message) + func (m *MessageIdData) XXX_Size() int + func (m *MessageIdData) XXX_Unmarshal(b []byte) error + type MessageMetadata struct + ChunkId *int32 + Compression *CompressionType + DeliverAtTime *int64 + EncryptionAlgo *string + EncryptionKeys []*EncryptionKeys + EncryptionParam []byte + EventTime *uint64 + HighestSequenceId *uint64 + MarkerType *int32 + NullPartitionKey *bool + NullValue *bool + NumChunksFromMsg *int32 + NumMessagesInBatch *int32 + OrderingKey []byte + PartitionKey *string + PartitionKeyB64Encoded *bool + ProducerName *string + Properties []*KeyValue + PublishTime *uint64 + ReplicateTo []string + ReplicatedFrom *string + SchemaVersion []byte + SequenceId *uint64 + TotalChunkMsgSize *int32 + TxnidLeastBits *uint64 + TxnidMostBits *uint64 + UncompressedSize *uint32 + Uuid *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MessageMetadata) Descriptor() ([]byte, []int) + func (*MessageMetadata) ProtoMessage() + func (m *MessageMetadata) GetChunkId() int32 + func (m *MessageMetadata) GetCompression() CompressionType + func (m *MessageMetadata) GetDeliverAtTime() int64 + func (m *MessageMetadata) GetEncryptionAlgo() string + func (m *MessageMetadata) GetEncryptionKeys() []*EncryptionKeys + func (m *MessageMetadata) GetEncryptionParam() []byte + func (m *MessageMetadata) GetEventTime() uint64 + func (m *MessageMetadata) GetHighestSequenceId() uint64 + func (m *MessageMetadata) GetMarkerType() int32 + func (m *MessageMetadata) GetNullPartitionKey() bool + func (m *MessageMetadata) GetNullValue() bool + func (m *MessageMetadata) GetNumChunksFromMsg() int32 + func (m *MessageMetadata) GetNumMessagesInBatch() int32 + func (m *MessageMetadata) GetOrderingKey() []byte + func (m *MessageMetadata) GetPartitionKey() string + func (m *MessageMetadata) GetPartitionKeyB64Encoded() bool + func (m *MessageMetadata) GetProducerName() string + func (m *MessageMetadata) GetProperties() []*KeyValue + func (m *MessageMetadata) GetPublishTime() uint64 + func (m *MessageMetadata) GetReplicateTo() []string + func (m *MessageMetadata) GetReplicatedFrom() string + func (m *MessageMetadata) GetSchemaVersion() []byte + func (m *MessageMetadata) GetSequenceId() uint64 + func (m *MessageMetadata) GetTotalChunkMsgSize() int32 + func (m *MessageMetadata) GetTxnidLeastBits() uint64 + func (m *MessageMetadata) GetTxnidMostBits() uint64 + func (m *MessageMetadata) GetUncompressedSize() uint32 + func (m *MessageMetadata) GetUuid() string + func (m *MessageMetadata) Marshal() (dAtA []byte, err error) + func (m *MessageMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *MessageMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MessageMetadata) Reset() + func (m *MessageMetadata) Size() (n int) + func (m *MessageMetadata) String() string + func (m *MessageMetadata) Unmarshal(dAtA []byte) error + func (m *MessageMetadata) XXX_DiscardUnknown() + func (m *MessageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MessageMetadata) XXX_Merge(src proto.Message) + func (m *MessageMetadata) XXX_Size() int + func (m *MessageMetadata) XXX_Unmarshal(b []byte) error + type ProducerAccessMode int32 + const Default_CommandProducer_ProducerAccessMode + const ProducerAccessMode_Exclusive + const ProducerAccessMode_ExclusiveWithFencing + const ProducerAccessMode_Shared + const ProducerAccessMode_WaitForExclusive + func (ProducerAccessMode) EnumDescriptor() ([]byte, []int) + func (x *ProducerAccessMode) UnmarshalJSON(data []byte) error + func (x ProducerAccessMode) Enum() *ProducerAccessMode + func (x ProducerAccessMode) String() string + type ProtocolVersion int32 + const ProtocolVersion_v0 + const ProtocolVersion_v1 + const ProtocolVersion_v10 + const ProtocolVersion_v11 + const ProtocolVersion_v12 + const ProtocolVersion_v13 + const ProtocolVersion_v14 + const ProtocolVersion_v15 + const ProtocolVersion_v16 + const ProtocolVersion_v17 + const ProtocolVersion_v18 + const ProtocolVersion_v19 + const ProtocolVersion_v2 + const ProtocolVersion_v3 + const ProtocolVersion_v4 + const ProtocolVersion_v5 + const ProtocolVersion_v6 + const ProtocolVersion_v7 + const ProtocolVersion_v8 + const ProtocolVersion_v9 + func (ProtocolVersion) EnumDescriptor() ([]byte, []int) + func (x *ProtocolVersion) UnmarshalJSON(data []byte) error + func (x ProtocolVersion) Enum() *ProtocolVersion + func (x ProtocolVersion) String() string + type Schema struct + Name *string + Properties []*KeyValue + SchemaData []byte + Type *Schema_Type + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Schema) Descriptor() ([]byte, []int) + func (*Schema) ProtoMessage() + func (m *Schema) GetName() string + func (m *Schema) GetProperties() []*KeyValue + func (m *Schema) GetSchemaData() []byte + func (m *Schema) GetType() Schema_Type + func (m *Schema) Marshal() (dAtA []byte, err error) + func (m *Schema) MarshalTo(dAtA []byte) (int, error) + func (m *Schema) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Schema) Reset() + func (m *Schema) Size() (n int) + func (m *Schema) String() string + func (m *Schema) Unmarshal(dAtA []byte) error + func (m *Schema) XXX_DiscardUnknown() + func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Schema) XXX_Merge(src proto.Message) + func (m *Schema) XXX_Size() int + func (m *Schema) XXX_Unmarshal(b []byte) error + type Schema_Type int32 + const Schema_Avro + const Schema_Bool + const Schema_Date + const Schema_Double + const Schema_Float + const Schema_Instant + const Schema_Int16 + const Schema_Int32 + const Schema_Int64 + const Schema_Int8 + const Schema_Json + const Schema_KeyValue + const Schema_LocalDate + const Schema_LocalDateTime + const Schema_LocalTime + const Schema_None + const Schema_Protobuf + const Schema_ProtobufNative + const Schema_String + const Schema_Time + const Schema_Timestamp + func (Schema_Type) EnumDescriptor() ([]byte, []int) + func (x *Schema_Type) UnmarshalJSON(data []byte) error + func (x Schema_Type) Enum() *Schema_Type + func (x Schema_Type) String() string + type ServerError int32 + const ServerError_AuthenticationError + const ServerError_AuthorizationError + const ServerError_ChecksumError + const ServerError_ConsumerAssignError + const ServerError_ConsumerBusy + const ServerError_ConsumerNotFound + const ServerError_IncompatibleSchema + const ServerError_InvalidTopicName + const ServerError_InvalidTxnStatus + const ServerError_MetadataError + const ServerError_NotAllowedError + const ServerError_PersistenceError + const ServerError_ProducerBlockedQuotaExceededError + const ServerError_ProducerBlockedQuotaExceededException + const ServerError_ProducerBusy + const ServerError_ProducerFenced + const ServerError_ServiceNotReady + const ServerError_SubscriptionNotFound + const ServerError_TooManyRequests + const ServerError_TopicNotFound + const ServerError_TopicTerminatedError + const ServerError_TransactionConflict + const ServerError_TransactionCoordinatorNotFound + const ServerError_TransactionNotFound + const ServerError_UnknownError + const ServerError_UnsupportedVersionError + func (ServerError) EnumDescriptor() ([]byte, []int) + func (x *ServerError) UnmarshalJSON(data []byte) error + func (x ServerError) Enum() *ServerError + func (x ServerError) String() string + type SingleMessageMetadata struct + CompactedOut *bool + EventTime *uint64 + NullPartitionKey *bool + NullValue *bool + OrderingKey []byte + PartitionKey *string + PartitionKeyB64Encoded *bool + PayloadSize *int32 + Properties []*KeyValue + SequenceId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SingleMessageMetadata) Descriptor() ([]byte, []int) + func (*SingleMessageMetadata) ProtoMessage() + func (m *SingleMessageMetadata) GetCompactedOut() bool + func (m *SingleMessageMetadata) GetEventTime() uint64 + func (m *SingleMessageMetadata) GetNullPartitionKey() bool + func (m *SingleMessageMetadata) GetNullValue() bool + func (m *SingleMessageMetadata) GetOrderingKey() []byte + func (m *SingleMessageMetadata) GetPartitionKey() string + func (m *SingleMessageMetadata) GetPartitionKeyB64Encoded() bool + func (m *SingleMessageMetadata) GetPayloadSize() int32 + func (m *SingleMessageMetadata) GetProperties() []*KeyValue + func (m *SingleMessageMetadata) GetSequenceId() uint64 + func (m *SingleMessageMetadata) Marshal() (dAtA []byte, err error) + func (m *SingleMessageMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *SingleMessageMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SingleMessageMetadata) Reset() + func (m *SingleMessageMetadata) Size() (n int) + func (m *SingleMessageMetadata) String() string + func (m *SingleMessageMetadata) Unmarshal(dAtA []byte) error + func (m *SingleMessageMetadata) XXX_DiscardUnknown() + func (m *SingleMessageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SingleMessageMetadata) XXX_Merge(src proto.Message) + func (m *SingleMessageMetadata) XXX_Size() int + func (m *SingleMessageMetadata) XXX_Unmarshal(b []byte) error + type Subscription struct + Subscription *string + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Subscription) Descriptor() ([]byte, []int) + func (*Subscription) ProtoMessage() + func (m *Subscription) GetSubscription() string + func (m *Subscription) GetTopic() string + func (m *Subscription) Marshal() (dAtA []byte, err error) + func (m *Subscription) MarshalTo(dAtA []byte) (int, error) + func (m *Subscription) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Subscription) Reset() + func (m *Subscription) Size() (n int) + func (m *Subscription) String() string + func (m *Subscription) Unmarshal(dAtA []byte) error + func (m *Subscription) XXX_DiscardUnknown() + func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Subscription) XXX_Merge(src proto.Message) + func (m *Subscription) XXX_Size() int + func (m *Subscription) XXX_Unmarshal(b []byte) error + type TxnAction int32 + const TxnAction_ABORT + const TxnAction_COMMIT + func (TxnAction) EnumDescriptor() ([]byte, []int) + func (x *TxnAction) UnmarshalJSON(data []byte) error + func (x TxnAction) Enum() *TxnAction + func (x TxnAction) String() string
Go to main page