Versions in this module Expand all Collapse all v0 v0.1.1 Jan 25, 2019 Changes in this version + const Default_CommandActiveConsumerChange_IsActive + const Default_CommandConnect_ProtocolVersion + const Default_CommandConnected_ProtocolVersion + const Default_CommandLookupTopicResponse_Authoritative + const Default_CommandLookupTopicResponse_ProxyThroughServiceUrl + const Default_CommandLookupTopic_Authoritative + const Default_CommandProducerSuccess_LastSequenceId + const Default_CommandProducer_Encrypted + const Default_CommandSend_NumMessages + const Default_CommandSubscribe_Durable + const Default_MessageIdData_BatchIndex + const Default_MessageIdData_Partition + const Default_MessageMetadata_EventTime + const Default_MessageMetadata_NumMessagesInBatch + const Default_MessageMetadata_UncompressedSize + const Default_SingleMessageMetadata_CompactedOut + const Default_SingleMessageMetadata_EventTime + 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 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 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 + 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 + ActiveConsumerChange *CommandActiveConsumerChange + CloseConsumer *CommandCloseConsumer + CloseProducer *CommandCloseProducer + Connect *CommandConnect + Connected *CommandConnected + ConsumerStats *CommandConsumerStats + ConsumerStatsResponse *CommandConsumerStatsResponse + Error *CommandError + Flow *CommandFlow + GetLastMessageId *CommandGetLastMessageId + GetLastMessageIdResponse *CommandGetLastMessageIdResponse + GetTopicsOfNamespace *CommandGetTopicsOfNamespace + GetTopicsOfNamespaceResponse *CommandGetTopicsOfNamespaceResponse + LookupTopic *CommandLookupTopic + LookupTopicResponse *CommandLookupTopicResponse + Message *CommandMessage + 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 + Type *BaseCommand_Type + Unsubscribe *CommandUnsubscribe + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BaseCommand) Descriptor() ([]byte, []int) + func (*BaseCommand) ProtoMessage() + func (dst *BaseCommand) XXX_Merge(src proto.Message) + func (m *BaseCommand) GetAck() *CommandAck + func (m *BaseCommand) GetActiveConsumerChange() *CommandActiveConsumerChange + 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) GetError() *CommandError + func (m *BaseCommand) GetFlow() *CommandFlow + func (m *BaseCommand) GetGetLastMessageId() *CommandGetLastMessageId + func (m *BaseCommand) GetGetLastMessageIdResponse() *CommandGetLastMessageIdResponse + 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) 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) GetType() BaseCommand_Type + func (m *BaseCommand) GetUnsubscribe() *CommandUnsubscribe + func (m *BaseCommand) Reset() + func (m *BaseCommand) String() string + func (m *BaseCommand) XXX_DiscardUnknown() + func (m *BaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BaseCommand) XXX_Size() int + func (m *BaseCommand) XXX_Unmarshal(b []byte) error + type BaseCommand_Type int32 + const BaseCommand_ACK + const BaseCommand_ACTIVE_CONSUMER_CHANGE + 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_ERROR + const BaseCommand_FLOW + const BaseCommand_GET_LAST_MESSAGE_ID + const BaseCommand_GET_LAST_MESSAGE_ID_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_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_UNSUBSCRIBE + 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 CommandAck struct + AckType *CommandAck_AckType + ConsumerId *uint64 + MessageId []*MessageIdData + Properties []*KeyLongValue + ValidationError *CommandAck_ValidationError + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandAck) Descriptor() ([]byte, []int) + func (*CommandAck) ProtoMessage() + func (dst *CommandAck) XXX_Merge(src proto.Message) + func (m *CommandAck) GetAckType() CommandAck_AckType + func (m *CommandAck) GetConsumerId() uint64 + func (m *CommandAck) GetMessageId() []*MessageIdData + func (m *CommandAck) GetProperties() []*KeyLongValue + func (m *CommandAck) GetValidationError() CommandAck_ValidationError + func (m *CommandAck) Reset() + func (m *CommandAck) String() string + func (m *CommandAck) XXX_DiscardUnknown() + func (m *CommandAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandAck) XXX_Size() int + func (m *CommandAck) 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 (dst *CommandActiveConsumerChange) XXX_Merge(src proto.Message) + func (m *CommandActiveConsumerChange) GetConsumerId() uint64 + func (m *CommandActiveConsumerChange) GetIsActive() bool + func (m *CommandActiveConsumerChange) Reset() + func (m *CommandActiveConsumerChange) String() string + func (m *CommandActiveConsumerChange) XXX_DiscardUnknown() + func (m *CommandActiveConsumerChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandActiveConsumerChange) XXX_Size() int + func (m *CommandActiveConsumerChange) 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 (dst *CommandCloseConsumer) XXX_Merge(src proto.Message) + func (m *CommandCloseConsumer) GetConsumerId() uint64 + func (m *CommandCloseConsumer) GetRequestId() uint64 + func (m *CommandCloseConsumer) Reset() + func (m *CommandCloseConsumer) String() string + func (m *CommandCloseConsumer) XXX_DiscardUnknown() + func (m *CommandCloseConsumer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandCloseProducer) XXX_Merge(src proto.Message) + func (m *CommandCloseProducer) GetProducerId() uint64 + func (m *CommandCloseProducer) GetRequestId() uint64 + func (m *CommandCloseProducer) Reset() + func (m *CommandCloseProducer) String() string + func (m *CommandCloseProducer) XXX_DiscardUnknown() + func (m *CommandCloseProducer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 + 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 (dst *CommandConnect) XXX_Merge(src proto.Message) + func (m *CommandConnect) GetAuthData() []byte + func (m *CommandConnect) GetAuthMethod() AuthMethod + func (m *CommandConnect) GetAuthMethodName() string + func (m *CommandConnect) GetClientVersion() string + 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) Reset() + func (m *CommandConnect) String() string + func (m *CommandConnect) XXX_DiscardUnknown() + func (m *CommandConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandConnect) XXX_Size() int + func (m *CommandConnect) XXX_Unmarshal(b []byte) error + type CommandConnected struct + ProtocolVersion *int32 + ServerVersion *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandConnected) Descriptor() ([]byte, []int) + func (*CommandConnected) ProtoMessage() + func (dst *CommandConnected) XXX_Merge(src proto.Message) + func (m *CommandConnected) GetProtocolVersion() int32 + func (m *CommandConnected) GetServerVersion() string + func (m *CommandConnected) Reset() + func (m *CommandConnected) String() string + func (m *CommandConnected) XXX_DiscardUnknown() + func (m *CommandConnected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandConsumerStats) XXX_Merge(src proto.Message) + func (m *CommandConsumerStats) GetConsumerId() uint64 + func (m *CommandConsumerStats) GetRequestId() uint64 + func (m *CommandConsumerStats) Reset() + func (m *CommandConsumerStats) String() string + func (m *CommandConsumerStats) XXX_DiscardUnknown() + func (m *CommandConsumerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 + 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 (dst *CommandConsumerStatsResponse) XXX_Merge(src proto.Message) + 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) 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) Reset() + func (m *CommandConsumerStatsResponse) String() string + func (m *CommandConsumerStatsResponse) XXX_DiscardUnknown() + func (m *CommandConsumerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandConsumerStatsResponse) XXX_Size() int + func (m *CommandConsumerStatsResponse) 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 (dst *CommandError) XXX_Merge(src proto.Message) + func (m *CommandError) GetError() ServerError + func (m *CommandError) GetMessage() string + func (m *CommandError) GetRequestId() uint64 + func (m *CommandError) Reset() + func (m *CommandError) String() string + func (m *CommandError) XXX_DiscardUnknown() + func (m *CommandError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandFlow) XXX_Merge(src proto.Message) + func (m *CommandFlow) GetConsumerId() uint64 + func (m *CommandFlow) GetMessagePermits() uint32 + func (m *CommandFlow) Reset() + func (m *CommandFlow) String() string + func (m *CommandFlow) XXX_DiscardUnknown() + func (m *CommandFlow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandGetLastMessageId) XXX_Merge(src proto.Message) + func (m *CommandGetLastMessageId) GetConsumerId() uint64 + func (m *CommandGetLastMessageId) GetRequestId() uint64 + func (m *CommandGetLastMessageId) Reset() + func (m *CommandGetLastMessageId) String() string + func (m *CommandGetLastMessageId) XXX_DiscardUnknown() + func (m *CommandGetLastMessageId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetLastMessageId) XXX_Size() int + func (m *CommandGetLastMessageId) XXX_Unmarshal(b []byte) error + type CommandGetLastMessageIdResponse struct + LastMessageId *MessageIdData + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetLastMessageIdResponse) Descriptor() ([]byte, []int) + func (*CommandGetLastMessageIdResponse) ProtoMessage() + func (dst *CommandGetLastMessageIdResponse) XXX_Merge(src proto.Message) + func (m *CommandGetLastMessageIdResponse) GetLastMessageId() *MessageIdData + func (m *CommandGetLastMessageIdResponse) GetRequestId() uint64 + func (m *CommandGetLastMessageIdResponse) Reset() + func (m *CommandGetLastMessageIdResponse) String() string + func (m *CommandGetLastMessageIdResponse) XXX_DiscardUnknown() + func (m *CommandGetLastMessageIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetLastMessageIdResponse) XXX_Size() int + func (m *CommandGetLastMessageIdResponse) XXX_Unmarshal(b []byte) error + type CommandGetTopicsOfNamespace struct + Namespace *string + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetTopicsOfNamespace) Descriptor() ([]byte, []int) + func (*CommandGetTopicsOfNamespace) ProtoMessage() + func (dst *CommandGetTopicsOfNamespace) XXX_Merge(src proto.Message) + func (m *CommandGetTopicsOfNamespace) GetNamespace() string + func (m *CommandGetTopicsOfNamespace) GetRequestId() uint64 + func (m *CommandGetTopicsOfNamespace) Reset() + func (m *CommandGetTopicsOfNamespace) String() string + func (m *CommandGetTopicsOfNamespace) XXX_DiscardUnknown() + func (m *CommandGetTopicsOfNamespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetTopicsOfNamespace) XXX_Size() int + func (m *CommandGetTopicsOfNamespace) XXX_Unmarshal(b []byte) error + type CommandGetTopicsOfNamespaceResponse struct + RequestId *uint64 + Topics []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandGetTopicsOfNamespaceResponse) Descriptor() ([]byte, []int) + func (*CommandGetTopicsOfNamespaceResponse) ProtoMessage() + func (dst *CommandGetTopicsOfNamespaceResponse) XXX_Merge(src proto.Message) + func (m *CommandGetTopicsOfNamespaceResponse) GetRequestId() uint64 + func (m *CommandGetTopicsOfNamespaceResponse) GetTopics() []string + func (m *CommandGetTopicsOfNamespaceResponse) Reset() + func (m *CommandGetTopicsOfNamespaceResponse) String() string + func (m *CommandGetTopicsOfNamespaceResponse) XXX_DiscardUnknown() + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Size() int + func (m *CommandGetTopicsOfNamespaceResponse) XXX_Unmarshal(b []byte) error + type CommandLookupTopic struct + 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 (dst *CommandLookupTopic) XXX_Merge(src proto.Message) + 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) Reset() + func (m *CommandLookupTopic) String() string + func (m *CommandLookupTopic) XXX_DiscardUnknown() + func (m *CommandLookupTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandLookupTopicResponse) XXX_Merge(src proto.Message) + 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) Reset() + func (m *CommandLookupTopicResponse) String() string + func (m *CommandLookupTopicResponse) XXX_DiscardUnknown() + func (m *CommandLookupTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 + ConsumerId *uint64 + MessageId *MessageIdData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandMessage) Descriptor() ([]byte, []int) + func (*CommandMessage) ProtoMessage() + func (dst *CommandMessage) XXX_Merge(src proto.Message) + func (m *CommandMessage) GetConsumerId() uint64 + func (m *CommandMessage) GetMessageId() *MessageIdData + func (m *CommandMessage) Reset() + func (m *CommandMessage) String() string + func (m *CommandMessage) XXX_DiscardUnknown() + func (m *CommandMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandMessage) XXX_Size() int + func (m *CommandMessage) 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 (dst *CommandPartitionedTopicMetadata) XXX_Merge(src proto.Message) + 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) Reset() + func (m *CommandPartitionedTopicMetadata) String() string + func (m *CommandPartitionedTopicMetadata) XXX_DiscardUnknown() + func (m *CommandPartitionedTopicMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandPartitionedTopicMetadataResponse) XXX_Merge(src proto.Message) + 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) Reset() + func (m *CommandPartitionedTopicMetadataResponse) String() string + func (m *CommandPartitionedTopicMetadataResponse) XXX_DiscardUnknown() + func (m *CommandPartitionedTopicMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandPing) XXX_Merge(src proto.Message) + func (m *CommandPing) Reset() + func (m *CommandPing) String() string + func (m *CommandPing) XXX_DiscardUnknown() + func (m *CommandPing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandPong) XXX_Merge(src proto.Message) + func (m *CommandPong) Reset() + func (m *CommandPong) String() string + func (m *CommandPong) XXX_DiscardUnknown() + func (m *CommandPong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandPong) XXX_Size() int + func (m *CommandPong) XXX_Unmarshal(b []byte) error + type CommandProducer struct + Encrypted *bool + Metadata []*KeyValue + ProducerId *uint64 + ProducerName *string + RequestId *uint64 + Schema *Schema + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandProducer) Descriptor() ([]byte, []int) + func (*CommandProducer) ProtoMessage() + func (dst *CommandProducer) XXX_Merge(src proto.Message) + func (m *CommandProducer) GetEncrypted() bool + func (m *CommandProducer) GetMetadata() []*KeyValue + 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) Reset() + func (m *CommandProducer) String() string + func (m *CommandProducer) XXX_DiscardUnknown() + func (m *CommandProducer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandProducer) XXX_Size() int + func (m *CommandProducer) XXX_Unmarshal(b []byte) error + type CommandProducerSuccess struct + LastSequenceId *int64 + ProducerName *string + RequestId *uint64 + SchemaVersion []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandProducerSuccess) Descriptor() ([]byte, []int) + func (*CommandProducerSuccess) ProtoMessage() + func (dst *CommandProducerSuccess) XXX_Merge(src proto.Message) + func (m *CommandProducerSuccess) GetLastSequenceId() int64 + func (m *CommandProducerSuccess) GetProducerName() string + func (m *CommandProducerSuccess) GetRequestId() uint64 + func (m *CommandProducerSuccess) GetSchemaVersion() []byte + func (m *CommandProducerSuccess) Reset() + func (m *CommandProducerSuccess) String() string + func (m *CommandProducerSuccess) XXX_DiscardUnknown() + func (m *CommandProducerSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandReachedEndOfTopic) XXX_Merge(src proto.Message) + func (m *CommandReachedEndOfTopic) GetConsumerId() uint64 + func (m *CommandReachedEndOfTopic) Reset() + func (m *CommandReachedEndOfTopic) String() string + func (m *CommandReachedEndOfTopic) XXX_DiscardUnknown() + func (m *CommandReachedEndOfTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandReachedEndOfTopic) XXX_Size() int + func (m *CommandReachedEndOfTopic) XXX_Unmarshal(b []byte) error + type CommandRedeliverUnacknowledgedMessages struct + ConsumerId *uint64 + MessageIds []*MessageIdData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandRedeliverUnacknowledgedMessages) Descriptor() ([]byte, []int) + func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage() + func (dst *CommandRedeliverUnacknowledgedMessages) XXX_Merge(src proto.Message) + func (m *CommandRedeliverUnacknowledgedMessages) GetConsumerId() uint64 + func (m *CommandRedeliverUnacknowledgedMessages) GetMessageIds() []*MessageIdData + func (m *CommandRedeliverUnacknowledgedMessages) Reset() + func (m *CommandRedeliverUnacknowledgedMessages) String() string + func (m *CommandRedeliverUnacknowledgedMessages) XXX_DiscardUnknown() + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Size() int + func (m *CommandRedeliverUnacknowledgedMessages) XXX_Unmarshal(b []byte) error + type CommandSeek struct + ConsumerId *uint64 + MessageId *MessageIdData + RequestId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSeek) Descriptor() ([]byte, []int) + func (*CommandSeek) ProtoMessage() + func (dst *CommandSeek) XXX_Merge(src proto.Message) + func (m *CommandSeek) GetConsumerId() uint64 + func (m *CommandSeek) GetMessageId() *MessageIdData + func (m *CommandSeek) GetRequestId() uint64 + func (m *CommandSeek) Reset() + func (m *CommandSeek) String() string + func (m *CommandSeek) XXX_DiscardUnknown() + func (m *CommandSeek) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSeek) XXX_Size() int + func (m *CommandSeek) XXX_Unmarshal(b []byte) error + type CommandSend struct + NumMessages *int32 + ProducerId *uint64 + SequenceId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSend) Descriptor() ([]byte, []int) + func (*CommandSend) ProtoMessage() + func (dst *CommandSend) XXX_Merge(src proto.Message) + func (m *CommandSend) GetNumMessages() int32 + func (m *CommandSend) GetProducerId() uint64 + func (m *CommandSend) GetSequenceId() uint64 + func (m *CommandSend) Reset() + func (m *CommandSend) String() string + func (m *CommandSend) XXX_DiscardUnknown() + func (m *CommandSend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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 (dst *CommandSendError) XXX_Merge(src proto.Message) + func (m *CommandSendError) GetError() ServerError + func (m *CommandSendError) GetMessage() string + func (m *CommandSendError) GetProducerId() uint64 + func (m *CommandSendError) GetSequenceId() uint64 + func (m *CommandSendError) Reset() + func (m *CommandSendError) String() string + func (m *CommandSendError) XXX_DiscardUnknown() + func (m *CommandSendError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSendError) XXX_Size() int + func (m *CommandSendError) XXX_Unmarshal(b []byte) error + type CommandSendReceipt struct + MessageId *MessageIdData + ProducerId *uint64 + SequenceId *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSendReceipt) Descriptor() ([]byte, []int) + func (*CommandSendReceipt) ProtoMessage() + func (dst *CommandSendReceipt) XXX_Merge(src proto.Message) + func (m *CommandSendReceipt) GetMessageId() *MessageIdData + func (m *CommandSendReceipt) GetProducerId() uint64 + func (m *CommandSendReceipt) GetSequenceId() uint64 + func (m *CommandSendReceipt) Reset() + func (m *CommandSendReceipt) String() string + func (m *CommandSendReceipt) XXX_DiscardUnknown() + func (m *CommandSendReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSendReceipt) XXX_Size() int + func (m *CommandSendReceipt) XXX_Unmarshal(b []byte) error + type CommandSubscribe struct + ConsumerId *uint64 + ConsumerName *string + Durable *bool + InitialPosition *CommandSubscribe_InitialPosition + Metadata []*KeyValue + PriorityLevel *int32 + ReadCompacted *bool + RequestId *uint64 + Schema *Schema + StartMessageId *MessageIdData + SubType *CommandSubscribe_SubType + Subscription *string + Topic *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandSubscribe) Descriptor() ([]byte, []int) + func (*CommandSubscribe) ProtoMessage() + func (dst *CommandSubscribe) XXX_Merge(src proto.Message) + func (m *CommandSubscribe) GetConsumerId() uint64 + func (m *CommandSubscribe) GetConsumerName() string + func (m *CommandSubscribe) GetDurable() bool + func (m *CommandSubscribe) GetInitialPosition() CommandSubscribe_InitialPosition + func (m *CommandSubscribe) GetMetadata() []*KeyValue + func (m *CommandSubscribe) GetPriorityLevel() int32 + func (m *CommandSubscribe) GetReadCompacted() bool + func (m *CommandSubscribe) GetRequestId() uint64 + func (m *CommandSubscribe) GetSchema() *Schema + func (m *CommandSubscribe) GetStartMessageId() *MessageIdData + func (m *CommandSubscribe) GetSubType() CommandSubscribe_SubType + func (m *CommandSubscribe) GetSubscription() string + func (m *CommandSubscribe) GetTopic() string + func (m *CommandSubscribe) Reset() + func (m *CommandSubscribe) String() string + func (m *CommandSubscribe) XXX_DiscardUnknown() + func (m *CommandSubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + 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_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 (dst *CommandSuccess) XXX_Merge(src proto.Message) + func (m *CommandSuccess) GetRequestId() uint64 + func (m *CommandSuccess) GetSchema() *Schema + func (m *CommandSuccess) Reset() + func (m *CommandSuccess) String() string + func (m *CommandSuccess) XXX_DiscardUnknown() + func (m *CommandSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandSuccess) XXX_Size() int + func (m *CommandSuccess) 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 (dst *CommandUnsubscribe) XXX_Merge(src proto.Message) + func (m *CommandUnsubscribe) GetConsumerId() uint64 + func (m *CommandUnsubscribe) GetRequestId() uint64 + func (m *CommandUnsubscribe) Reset() + func (m *CommandUnsubscribe) String() string + func (m *CommandUnsubscribe) XXX_DiscardUnknown() + func (m *CommandUnsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandUnsubscribe) XXX_Size() int + func (m *CommandUnsubscribe) XXX_Unmarshal(b []byte) error + type CompressionType int32 + const CompressionType_LZ4 + const CompressionType_NONE + const CompressionType_ZLIB + 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 (dst *EncryptionKeys) XXX_Merge(src proto.Message) + func (m *EncryptionKeys) GetKey() string + func (m *EncryptionKeys) GetMetadata() []*KeyValue + func (m *EncryptionKeys) GetValue() []byte + func (m *EncryptionKeys) Reset() + func (m *EncryptionKeys) String() string + func (m *EncryptionKeys) XXX_DiscardUnknown() + func (m *EncryptionKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EncryptionKeys) XXX_Size() int + func (m *EncryptionKeys) 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 (dst *KeyLongValue) XXX_Merge(src proto.Message) + func (m *KeyLongValue) GetKey() string + func (m *KeyLongValue) GetValue() uint64 + func (m *KeyLongValue) Reset() + func (m *KeyLongValue) String() string + func (m *KeyLongValue) XXX_DiscardUnknown() + func (m *KeyLongValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyLongValue) XXX_Size() int + func (m *KeyLongValue) XXX_Unmarshal(b []byte) error + 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 (dst *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) GetKey() string + func (m *KeyValue) GetValue() string + func (m *KeyValue) Reset() + func (m *KeyValue) String() string + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + type MessageIdData struct + BatchIndex *int32 + EntryId *uint64 + LedgerId *uint64 + Partition *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MessageIdData) Descriptor() ([]byte, []int) + func (*MessageIdData) ProtoMessage() + func (dst *MessageIdData) XXX_Merge(src proto.Message) + func (m *MessageIdData) GetBatchIndex() int32 + func (m *MessageIdData) GetEntryId() uint64 + func (m *MessageIdData) GetLedgerId() uint64 + func (m *MessageIdData) GetPartition() int32 + func (m *MessageIdData) Reset() + func (m *MessageIdData) String() string + func (m *MessageIdData) XXX_DiscardUnknown() + func (m *MessageIdData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MessageIdData) XXX_Size() int + func (m *MessageIdData) XXX_Unmarshal(b []byte) error + type MessageMetadata struct + Compression *CompressionType + EncryptionAlgo *string + EncryptionKeys []*EncryptionKeys + EncryptionParam []byte + EventTime *uint64 + NumMessagesInBatch *int32 + PartitionKey *string + ProducerName *string + Properties []*KeyValue + PublishTime *uint64 + ReplicateTo []string + ReplicatedFrom *string + SchemaVersion []byte + SequenceId *uint64 + UncompressedSize *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MessageMetadata) Descriptor() ([]byte, []int) + func (*MessageMetadata) ProtoMessage() + func (dst *MessageMetadata) XXX_Merge(src proto.Message) + func (m *MessageMetadata) GetCompression() CompressionType + func (m *MessageMetadata) GetEncryptionAlgo() string + func (m *MessageMetadata) GetEncryptionKeys() []*EncryptionKeys + func (m *MessageMetadata) GetEncryptionParam() []byte + func (m *MessageMetadata) GetEventTime() uint64 + func (m *MessageMetadata) GetNumMessagesInBatch() int32 + func (m *MessageMetadata) GetPartitionKey() string + 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) GetUncompressedSize() uint32 + func (m *MessageMetadata) Reset() + func (m *MessageMetadata) String() string + func (m *MessageMetadata) XXX_DiscardUnknown() + func (m *MessageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MessageMetadata) XXX_Size() int + func (m *MessageMetadata) XXX_Unmarshal(b []byte) error + type ProtocolVersion int32 + const ProtocolVersion_v0 + const ProtocolVersion_v1 + const ProtocolVersion_v10 + const ProtocolVersion_v11 + const ProtocolVersion_v12 + 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 (dst *Schema) XXX_Merge(src proto.Message) + func (m *Schema) GetName() string + func (m *Schema) GetProperties() []*KeyValue + func (m *Schema) GetSchemaData() []byte + func (m *Schema) GetType() Schema_Type + func (m *Schema) Reset() + func (m *Schema) String() string + func (m *Schema) XXX_DiscardUnknown() + func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Schema) XXX_Size() int + func (m *Schema) XXX_Unmarshal(b []byte) error + type Schema_Type int32 + const Schema_Json + const Schema_None + const Schema_String + 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_ConsumerBusy + const ServerError_ConsumerNotFound + const ServerError_InvalidTopicName + const ServerError_MetadataError + const ServerError_PersistenceError + const ServerError_ProducerBlockedQuotaExceededError + const ServerError_ProducerBlockedQuotaExceededException + const ServerError_ProducerBusy + const ServerError_ServiceNotReady + const ServerError_SubscriptionNotFound + const ServerError_TooManyRequests + const ServerError_TopicNotFound + const ServerError_TopicTerminatedError + 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 + PartitionKey *string + PayloadSize *int32 + Properties []*KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SingleMessageMetadata) Descriptor() ([]byte, []int) + func (*SingleMessageMetadata) ProtoMessage() + func (dst *SingleMessageMetadata) XXX_Merge(src proto.Message) + func (m *SingleMessageMetadata) GetCompactedOut() bool + func (m *SingleMessageMetadata) GetEventTime() uint64 + func (m *SingleMessageMetadata) GetPartitionKey() string + func (m *SingleMessageMetadata) GetPayloadSize() int32 + func (m *SingleMessageMetadata) GetProperties() []*KeyValue + func (m *SingleMessageMetadata) Reset() + func (m *SingleMessageMetadata) String() string + func (m *SingleMessageMetadata) XXX_DiscardUnknown() + func (m *SingleMessageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SingleMessageMetadata) XXX_Size() int + func (m *SingleMessageMetadata) XXX_Unmarshal(b []byte) error