pb

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 11, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const Default_CommandAckResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandAckResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandAck_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandAck_TxnidMostBits uint64 = 0
View Source 
const Default_CommandActiveConsumerChange_IsActive bool = false
View Source 
const Default_CommandAddPartitionToTxnResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandAddPartitionToTxnResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandAddPartitionToTxn_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandAddPartitionToTxn_TxnidMostBits uint64 = 0
View Source 
const Default_CommandAddSubscriptionToTxnResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandAddSubscriptionToTxnResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandAddSubscriptionToTxn_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandAddSubscriptionToTxn_TxnidMostBits uint64 = 0
View Source 
const Default_CommandAuthChallenge_ProtocolVersion int32 = 0
View Source 
const Default_CommandAuthResponse_ProtocolVersion int32 = 0
View Source 
const Default_CommandConnect_ProtocolVersion int32 = 0
View Source 
const Default_CommandConnected_ProtocolVersion int32 = 0
View Source 
const Default_CommandEndTxnOnPartitionResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandEndTxnOnPartitionResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandEndTxnOnPartition_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandEndTxnOnPartition_TxnidMostBits uint64 = 0
View Source 
const Default_CommandEndTxnOnSubscriptionResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandEndTxnOnSubscriptionResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandEndTxnOnSubscription_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandEndTxnOnSubscription_TxnidMostBits uint64 = 0
View Source 
const Default_CommandEndTxnResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandEndTxnResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandEndTxn_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandEndTxn_TxnidMostBits uint64 = 0
View Source 
const Default_CommandLookupTopicResponse_Authoritative bool = false
View Source 
const Default_CommandLookupTopicResponse_ProxyThroughServiceUrl bool = false
View Source 
const Default_CommandLookupTopic_Authoritative bool = false
View Source 
const Default_CommandMessage_RedeliveryCount uint32 = 0
View Source 
const Default_CommandNewTxnResponse_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandNewTxnResponse_TxnidMostBits uint64 = 0
View Source 
const Default_CommandNewTxn_TcId uint64 = 0
View Source 
const Default_CommandNewTxn_TxnTtlSeconds uint64 = 0
View Source 
const Default_CommandProducerSuccess_LastSequenceId int64 = -1
View Source 
const Default_CommandProducer_Encrypted bool = false
View Source 
const Default_CommandProducer_Epoch uint64 = 0
View Source 
const Default_CommandProducer_UserProvidedProducerName bool = true
View Source 
const Default_CommandSendReceipt_HighestSequenceId uint64 = 0
View Source 
const Default_CommandSend_HighestSequenceId uint64 = 0
View Source 
const Default_CommandSend_NumMessages int32 = 1
View Source 
const Default_CommandSend_TxnidLeastBits uint64 = 0
View Source 
const Default_CommandSend_TxnidMostBits uint64 = 0
View Source 
const Default_CommandSubscribe_Durable bool = true
View Source 
const Default_CommandSubscribe_ForceTopicCreation bool = true
View Source 
const Default_CommandSubscribe_StartMessageRollbackDurationSec uint64 = 0
View Source 
const Default_FeatureFlags_SupportsAuthRefresh bool = false
View Source 
const Default_MessageIdData_BatchIndex int32 = -1
View Source 
const Default_MessageIdData_Partition int32 = -1
View Source 
const Default_MessageMetadata_EventTime uint64 = 0
View Source 
const Default_MessageMetadata_HighestSequenceId uint64 = 0
View Source 
const Default_MessageMetadata_NumMessagesInBatch int32 = 1
View Source 
const Default_MessageMetadata_PartitionKeyB64Encoded bool = false
View Source 
const Default_MessageMetadata_TxnidLeastBits uint64 = 0
View Source 
const Default_MessageMetadata_TxnidMostBits uint64 = 0
View Source 
const Default_MessageMetadata_UncompressedSize uint32 = 0
View Source 
const Default_SingleMessageMetadata_CompactedOut bool = false
View Source 
const Default_SingleMessageMetadata_EventTime uint64 = 0
View Source 
const Default_SingleMessageMetadata_PartitionKeyB64Encoded bool = false

Variables

View Source 
var AuthMethod_name = map[int32]string{
	0: "AuthMethodNone",
	1: "AuthMethodYcaV1",
	2: "AuthMethodAthens",
}
View Source 
var AuthMethod_value = map[string]int32{
	"AuthMethodNone":   0,
	"AuthMethodYcaV1":  1,
	"AuthMethodAthens": 2,
}
View Source 
var BaseCommand_Type_name = map[int32]string{
	2:  "CONNECT",
	3:  "CONNECTED",
	4:  "SUBSCRIBE",
	5:  "PRODUCER",
	6:  "SEND",
	7:  "SEND_RECEIPT",
	8:  "SEND_ERROR",
	9:  "MESSAGE",
	10: "ACK",
	11: "FLOW",
	12: "UNSUBSCRIBE",
	13: "SUCCESS",
	14: "ERROR",
	15: "CLOSE_PRODUCER",
	16: "CLOSE_CONSUMER",
	17: "PRODUCER_SUCCESS",
	18: "PING",
	19: "PONG",
	20: "REDELIVER_UNACKNOWLEDGED_MESSAGES",
	21: "PARTITIONED_METADATA",
	22: "PARTITIONED_METADATA_RESPONSE",
	23: "LOOKUP",
	24: "LOOKUP_RESPONSE",
	25: "CONSUMER_STATS",
	26: "CONSUMER_STATS_RESPONSE",
	27: "REACHED_END_OF_TOPIC",
	28: "SEEK",
	29: "GET_LAST_MESSAGE_ID",
	30: "GET_LAST_MESSAGE_ID_RESPONSE",
	31: "ACTIVE_CONSUMER_CHANGE",
	32: "GET_TOPICS_OF_NAMESPACE",
	33: "GET_TOPICS_OF_NAMESPACE_RESPONSE",
	34: "GET_SCHEMA",
	35: "GET_SCHEMA_RESPONSE",
	36: "AUTH_CHALLENGE",
	37: "AUTH_RESPONSE",
	38: "ACK_RESPONSE",
	39: "GET_OR_CREATE_SCHEMA",
	40: "GET_OR_CREATE_SCHEMA_RESPONSE",
	50: "NEW_TXN",
	51: "NEW_TXN_RESPONSE",
	52: "ADD_PARTITION_TO_TXN",
	53: "ADD_PARTITION_TO_TXN_RESPONSE",
	54: "ADD_SUBSCRIPTION_TO_TXN",
	55: "ADD_SUBSCRIPTION_TO_TXN_RESPONSE",
	56: "END_TXN",
	57: "END_TXN_RESPONSE",
	58: "END_TXN_ON_PARTITION",
	59: "END_TXN_ON_PARTITION_RESPONSE",
	60: "END_TXN_ON_SUBSCRIPTION",
	61: "END_TXN_ON_SUBSCRIPTION_RESPONSE",
}
View Source 
var BaseCommand_Type_value = map[string]int32{
	"CONNECT":                           2,
	"CONNECTED":                         3,
	"SUBSCRIBE":                         4,
	"PRODUCER":                          5,
	"SEND":                              6,
	"SEND_RECEIPT":                      7,
	"SEND_ERROR":                        8,
	"MESSAGE":                           9,
	"ACK":                               10,
	"FLOW":                              11,
	"UNSUBSCRIBE":                       12,
	"SUCCESS":                           13,
	"ERROR":                             14,
	"CLOSE_PRODUCER":                    15,
	"CLOSE_CONSUMER":                    16,
	"PRODUCER_SUCCESS":                  17,
	"PING":                              18,
	"PONG":                              19,
	"REDELIVER_UNACKNOWLEDGED_MESSAGES": 20,
	"PARTITIONED_METADATA":              21,
	"PARTITIONED_METADATA_RESPONSE":     22,
	"LOOKUP":                            23,
	"LOOKUP_RESPONSE":                   24,
	"CONSUMER_STATS":                    25,
	"CONSUMER_STATS_RESPONSE":           26,
	"REACHED_END_OF_TOPIC":              27,
	"SEEK":                              28,
	"GET_LAST_MESSAGE_ID":               29,
	"GET_LAST_MESSAGE_ID_RESPONSE":      30,
	"ACTIVE_CONSUMER_CHANGE":            31,
	"GET_TOPICS_OF_NAMESPACE":           32,
	"GET_TOPICS_OF_NAMESPACE_RESPONSE":  33,
	"GET_SCHEMA":                        34,
	"GET_SCHEMA_RESPONSE":               35,
	"AUTH_CHALLENGE":                    36,
	"AUTH_RESPONSE":                     37,
	"ACK_RESPONSE":                      38,
	"GET_OR_CREATE_SCHEMA":              39,
	"GET_OR_CREATE_SCHEMA_RESPONSE":     40,
	"NEW_TXN":                           50,
	"NEW_TXN_RESPONSE":                  51,
	"ADD_PARTITION_TO_TXN":              52,
	"ADD_PARTITION_TO_TXN_RESPONSE":     53,
	"ADD_SUBSCRIPTION_TO_TXN":           54,
	"ADD_SUBSCRIPTION_TO_TXN_RESPONSE":  55,
	"END_TXN":                           56,
	"END_TXN_RESPONSE":                  57,
	"END_TXN_ON_PARTITION":              58,
	"END_TXN_ON_PARTITION_RESPONSE":     59,
	"END_TXN_ON_SUBSCRIPTION":           60,
	"END_TXN_ON_SUBSCRIPTION_RESPONSE":  61,
}
View Source 
var CommandAck_AckType_name = map[int32]string{
	0: "Individual",
	1: "Cumulative",
}
View Source 
var CommandAck_AckType_value = map[string]int32{
	"Individual": 0,
	"Cumulative": 1,
}
View Source 
var CommandAck_ValidationError_name = map[int32]string{
	0: "UncompressedSizeCorruption",
	1: "DecompressionError",
	2: "ChecksumMismatch",
	3: "BatchDeSerializeError",
	4: "DecryptionError",
}
View Source 
var CommandAck_ValidationError_value = map[string]int32{
	"UncompressedSizeCorruption": 0,
	"DecompressionError":         1,
	"ChecksumMismatch":           2,
	"BatchDeSerializeError":      3,
	"DecryptionError":            4,
}
View Source 
var CommandGetTopicsOfNamespace_Mode_name = map[int32]string{
	0: "PERSISTENT",
	1: "NON_PERSISTENT",
	2: "ALL",
}
View Source 
var CommandGetTopicsOfNamespace_Mode_value = map[string]int32{
	"PERSISTENT":     0,
	"NON_PERSISTENT": 1,
	"ALL":            2,
}
View Source 
var CommandLookupTopicResponse_LookupType_name = map[int32]string{
	0: "Redirect",
	1: "Connect",
	2: "Failed",
}
View Source 
var CommandLookupTopicResponse_LookupType_value = map[string]int32{
	"Redirect": 0,
	"Connect":  1,
	"Failed":   2,
}
View Source 
var CommandPartitionedTopicMetadataResponse_LookupType_name = map[int32]string{
	0: "Success",
	1: "Failed",
}
View Source 
var CommandPartitionedTopicMetadataResponse_LookupType_value = map[string]int32{
	"Success": 0,
	"Failed":  1,
}
View Source 
var CommandSubscribe_InitialPosition_name = map[int32]string{
	0: "Latest",
	1: "Earliest",
}
View Source 
var CommandSubscribe_InitialPosition_value = map[string]int32{
	"Latest":   0,
	"Earliest": 1,
}
View Source 
var CommandSubscribe_SubType_name = map[int32]string{
	0: "Exclusive",
	1: "Shared",
	2: "Failover",
	3: "Key_Shared",
}
View Source 
var CommandSubscribe_SubType_value = map[string]int32{
	"Exclusive":  0,
	"Shared":     1,
	"Failover":   2,
	"Key_Shared": 3,
}
View Source 
var CompressionType_name = map[int32]string{
	0: "NONE",
	1: "LZ4",
	2: "ZLIB",
	3: "ZSTD",
	4: "SNAPPY",
}
View Source 
var CompressionType_value = map[string]int32{
	"NONE":   0,
	"LZ4":    1,
	"ZLIB":   2,
	"ZSTD":   3,
	"SNAPPY": 4,
}
View Source 
var KeySharedMode_name = map[int32]string{
	0: "AUTO_SPLIT",
	1: "STICKY",
}
View Source 
var KeySharedMode_value = map[string]int32{
	"AUTO_SPLIT": 0,
	"STICKY":     1,
}
View Source 
var ProtocolVersion_name = map[int32]string{
	0:  "v0",
	1:  "v1",
	2:  "v2",
	3:  "v3",
	4:  "v4",
	5:  "v5",
	6:  "v6",
	7:  "v7",
	8:  "v8",
	9:  "v9",
	10: "v10",
	11: "v11",
	12: "v12",
	13: "v13",
	14: "v14",
	15: "v15",
}
View Source 
var ProtocolVersion_value = map[string]int32{
	"v0":  0,
	"v1":  1,
	"v2":  2,
	"v3":  3,
	"v4":  4,
	"v5":  5,
	"v6":  6,
	"v7":  7,
	"v8":  8,
	"v9":  9,
	"v10": 10,
	"v11": 11,
	"v12": 12,
	"v13": 13,
	"v14": 14,
	"v15": 15,
}
View Source 
var Schema_Type_name = map[int32]string{
	0:  "None",
	1:  "String",
	2:  "Json",
	3:  "Protobuf",
	4:  "Avro",
	5:  "Bool",
	6:  "Int8",
	7:  "Int16",
	8:  "Int32",
	9:  "Int64",
	10: "Float",
	11: "Double",
	12: "Date",
	13: "Time",
	14: "Timestamp",
	15: "KeyValue",
}
View Source 
var Schema_Type_value = map[string]int32{
	"None":      0,
	"String":    1,
	"Json":      2,
	"Protobuf":  3,
	"Avro":      4,
	"Bool":      5,
	"Int8":      6,
	"Int16":     7,
	"Int32":     8,
	"Int64":     9,
	"Float":     10,
	"Double":    11,
	"Date":      12,
	"Time":      13,
	"Timestamp": 14,
	"KeyValue":  15,
}
View Source 
var ServerError_name = map[int32]string{
	0:  "UnknownError",
	1:  "MetadataError",
	2:  "PersistenceError",
	3:  "AuthenticationError",
	4:  "AuthorizationError",
	5:  "ConsumerBusy",
	6:  "ServiceNotReady",
	7:  "ProducerBlockedQuotaExceededError",
	8:  "ProducerBlockedQuotaExceededException",
	9:  "ChecksumError",
	10: "UnsupportedVersionError",
	11: "TopicNotFound",
	12: "SubscriptionNotFound",
	13: "ConsumerNotFound",
	14: "TooManyRequests",
	15: "TopicTerminatedError",
	16: "ProducerBusy",
	17: "InvalidTopicName",
	18: "IncompatibleSchema",
	19: "ConsumerAssignError",
	20: "TransactionCoordinatorNotFound",
	21: "InvalidTxnStatus",
}
View Source 
var ServerError_value = map[string]int32{
	"UnknownError":                          0,
	"MetadataError":                         1,
	"PersistenceError":                      2,
	"AuthenticationError":                   3,
	"AuthorizationError":                    4,
	"ConsumerBusy":                          5,
	"ServiceNotReady":                       6,
	"ProducerBlockedQuotaExceededError":     7,
	"ProducerBlockedQuotaExceededException": 8,
	"ChecksumError":                         9,
	"UnsupportedVersionError":               10,
	"TopicNotFound":                         11,
	"SubscriptionNotFound":                  12,
	"ConsumerNotFound":                      13,
	"TooManyRequests":                       14,
	"TopicTerminatedError":                  15,
	"ProducerBusy":                          16,
	"InvalidTopicName":                      17,
	"IncompatibleSchema":                    18,
	"ConsumerAssignError":                   19,
	"TransactionCoordinatorNotFound":        20,
	"InvalidTxnStatus":                      21,
}
View Source 
var TxnAction_name = map[int32]string{
	0: "COMMIT",
	1: "ABORT",
}
View Source 
var TxnAction_value = map[string]int32{
	"COMMIT": 0,
	"ABORT":  1,
}

Functions

This section is empty.

Types

type AuthData 

type AuthData struct {
	AuthMethodName       *string  `protobuf:"bytes,1,opt,name=auth_method_name,json=authMethodName" json:"auth_method_name,omitempty"`
	AuthData             []byte   `protobuf:"bytes,2,opt,name=auth_data,json=authData" json:"auth_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

To support mutual authentication type, such as Sasl, reuse this command to mutual auth.

func (*AuthData) Descriptor 

func (*AuthData) Descriptor() ([]byte, []int)

func (*AuthData) GetAuthData 

func (m *AuthData) GetAuthData() []byte

func (*AuthData) GetAuthMethodName 

func (m *AuthData) GetAuthMethodName() string

func (*AuthData) ProtoMessage 

func (*AuthData) ProtoMessage()

func (*AuthData) Reset 

func (m *AuthData) Reset()

func (*AuthData) String 

func (m *AuthData) String() string

func (*AuthData) XXX_DiscardUnknown 

func (m *AuthData) XXX_DiscardUnknown()

func (*AuthData) XXX_Marshal 

func (m *AuthData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthData) XXX_Merge 

func (m *AuthData) XXX_Merge(src proto.Message)

func (*AuthData) XXX_Size 

func (m *AuthData) XXX_Size() int

func (*AuthData) XXX_Unmarshal 

func (m *AuthData) XXX_Unmarshal(b []byte) error

type AuthMethod 

type AuthMethod int32
const (
	AuthMethod_AuthMethodNone   AuthMethod = 0
	AuthMethod_AuthMethodYcaV1  AuthMethod = 1
	AuthMethod_AuthMethodAthens AuthMethod = 2
)

func (AuthMethod) Enum 

func (x AuthMethod) Enum() *AuthMethod

func (AuthMethod) EnumDescriptor 

func (AuthMethod) EnumDescriptor() ([]byte, []int)

func (AuthMethod) String 

func (x AuthMethod) String() string

func (*AuthMethod) UnmarshalJSON 

func (x *AuthMethod) UnmarshalJSON(data []byte) error

type BaseCommand 

type BaseCommand struct {
	Type                            *BaseCommand_Type                        `protobuf:"varint,1,req,name=type,enum=pulsar.proto.BaseCommand_Type" json:"type,omitempty"`
	Connect                         *CommandConnect                          `protobuf:"bytes,2,opt,name=connect" json:"connect,omitempty"`
	Connected                       *CommandConnected                        `protobuf:"bytes,3,opt,name=connected" json:"connected,omitempty"`
	Subscribe                       *CommandSubscribe                        `protobuf:"bytes,4,opt,name=subscribe" json:"subscribe,omitempty"`
	Producer                        *CommandProducer                         `protobuf:"bytes,5,opt,name=producer" json:"producer,omitempty"`
	Send                            *CommandSend                             `protobuf:"bytes,6,opt,name=send" json:"send,omitempty"`
	SendReceipt                     *CommandSendReceipt                      `protobuf:"bytes,7,opt,name=send_receipt,json=sendReceipt" json:"send_receipt,omitempty"`
	SendError                       *CommandSendError                        `protobuf:"bytes,8,opt,name=send_error,json=sendError" json:"send_error,omitempty"`
	Message                         *CommandMessage                          `protobuf:"bytes,9,opt,name=message" json:"message,omitempty"`
	Ack                             *CommandAck                              `protobuf:"bytes,10,opt,name=ack" json:"ack,omitempty"`
	Flow                            *CommandFlow                             `protobuf:"bytes,11,opt,name=flow" json:"flow,omitempty"`
	Unsubscribe                     *CommandUnsubscribe                      `protobuf:"bytes,12,opt,name=unsubscribe" json:"unsubscribe,omitempty"`
	Success                         *CommandSuccess                          `protobuf:"bytes,13,opt,name=success" json:"success,omitempty"`
	Error                           *CommandError                            `protobuf:"bytes,14,opt,name=error" json:"error,omitempty"`
	CloseProducer                   *CommandCloseProducer                    `protobuf:"bytes,15,opt,name=close_producer,json=closeProducer" json:"close_producer,omitempty"`
	CloseConsumer                   *CommandCloseConsumer                    `protobuf:"bytes,16,opt,name=close_consumer,json=closeConsumer" json:"close_consumer,omitempty"`
	ProducerSuccess                 *CommandProducerSuccess                  `protobuf:"bytes,17,opt,name=producer_success,json=producerSuccess" json:"producer_success,omitempty"`
	Ping                            *CommandPing                             `protobuf:"bytes,18,opt,name=ping" json:"ping,omitempty"`
	Pong                            *CommandPong                             `protobuf:"bytes,19,opt,name=pong" json:"pong,omitempty"`
	RedeliverUnacknowledgedMessages *CommandRedeliverUnacknowledgedMessages  `protobuf:"bytes,20,opt,name=redeliverUnacknowledgedMessages" json:"redeliverUnacknowledgedMessages,omitempty"`
	PartitionMetadata               *CommandPartitionedTopicMetadata         `protobuf:"bytes,21,opt,name=partitionMetadata" json:"partitionMetadata,omitempty"`
	PartitionMetadataResponse       *CommandPartitionedTopicMetadataResponse `protobuf:"bytes,22,opt,name=partitionMetadataResponse" json:"partitionMetadataResponse,omitempty"`
	LookupTopic                     *CommandLookupTopic                      `protobuf:"bytes,23,opt,name=lookupTopic" json:"lookupTopic,omitempty"`
	LookupTopicResponse             *CommandLookupTopicResponse              `protobuf:"bytes,24,opt,name=lookupTopicResponse" json:"lookupTopicResponse,omitempty"`
	ConsumerStats                   *CommandConsumerStats                    `protobuf:"bytes,25,opt,name=consumerStats" json:"consumerStats,omitempty"`
	ConsumerStatsResponse           *CommandConsumerStatsResponse            `protobuf:"bytes,26,opt,name=consumerStatsResponse" json:"consumerStatsResponse,omitempty"`
	ReachedEndOfTopic               *CommandReachedEndOfTopic                `protobuf:"bytes,27,opt,name=reachedEndOfTopic" json:"reachedEndOfTopic,omitempty"`
	Seek                            *CommandSeek                             `protobuf:"bytes,28,opt,name=seek" json:"seek,omitempty"`
	GetLastMessageId                *CommandGetLastMessageId                 `protobuf:"bytes,29,opt,name=getLastMessageId" json:"getLastMessageId,omitempty"`
	GetLastMessageIdResponse        *CommandGetLastMessageIdResponse         `protobuf:"bytes,30,opt,name=getLastMessageIdResponse" json:"getLastMessageIdResponse,omitempty"`
	ActiveConsumerChange            *CommandActiveConsumerChange             `protobuf:"bytes,31,opt,name=active_consumer_change,json=activeConsumerChange" json:"active_consumer_change,omitempty"`
	GetTopicsOfNamespace            *CommandGetTopicsOfNamespace             `protobuf:"bytes,32,opt,name=getTopicsOfNamespace" json:"getTopicsOfNamespace,omitempty"`
	GetTopicsOfNamespaceResponse    *CommandGetTopicsOfNamespaceResponse     `protobuf:"bytes,33,opt,name=getTopicsOfNamespaceResponse" json:"getTopicsOfNamespaceResponse,omitempty"`
	GetSchema                       *CommandGetSchema                        `protobuf:"bytes,34,opt,name=getSchema" json:"getSchema,omitempty"`
	GetSchemaResponse               *CommandGetSchemaResponse                `protobuf:"bytes,35,opt,name=getSchemaResponse" json:"getSchemaResponse,omitempty"`
	AuthChallenge                   *CommandAuthChallenge                    `protobuf:"bytes,36,opt,name=authChallenge" json:"authChallenge,omitempty"`
	AuthResponse                    *CommandAuthResponse                     `protobuf:"bytes,37,opt,name=authResponse" json:"authResponse,omitempty"`
	AckResponse                     *CommandAckResponse                      `protobuf:"bytes,38,opt,name=ackResponse" json:"ackResponse,omitempty"`
	GetOrCreateSchema               *CommandGetOrCreateSchema                `protobuf:"bytes,39,opt,name=getOrCreateSchema" json:"getOrCreateSchema,omitempty"`
	GetOrCreateSchemaResponse       *CommandGetOrCreateSchemaResponse        `protobuf:"bytes,40,opt,name=getOrCreateSchemaResponse" json:"getOrCreateSchemaResponse,omitempty"`
	// transaction related
	NewTxn                       *CommandNewTxn                       `protobuf:"bytes,50,opt,name=newTxn" json:"newTxn,omitempty"`
	NewTxnResponse               *CommandNewTxnResponse               `protobuf:"bytes,51,opt,name=newTxnResponse" json:"newTxnResponse,omitempty"`
	AddPartitionToTxn            *CommandAddPartitionToTxn            `protobuf:"bytes,52,opt,name=addPartitionToTxn" json:"addPartitionToTxn,omitempty"`
	AddPartitionToTxnResponse    *CommandAddPartitionToTxnResponse    `protobuf:"bytes,53,opt,name=addPartitionToTxnResponse" json:"addPartitionToTxnResponse,omitempty"`
	AddSubscriptionToTxn         *CommandAddSubscriptionToTxn         `protobuf:"bytes,54,opt,name=addSubscriptionToTxn" json:"addSubscriptionToTxn,omitempty"`
	AddSubscriptionToTxnResponse *CommandAddSubscriptionToTxnResponse `protobuf:"bytes,55,opt,name=addSubscriptionToTxnResponse" json:"addSubscriptionToTxnResponse,omitempty"`
	EndTxn                       *CommandEndTxn                       `protobuf:"bytes,56,opt,name=endTxn" json:"endTxn,omitempty"`
	EndTxnResponse               *CommandEndTxnResponse               `protobuf:"bytes,57,opt,name=endTxnResponse" json:"endTxnResponse,omitempty"`
	EndTxnOnPartition            *CommandEndTxnOnPartition            `protobuf:"bytes,58,opt,name=endTxnOnPartition" json:"endTxnOnPartition,omitempty"`
	EndTxnOnPartitionResponse    *CommandEndTxnOnPartitionResponse    `protobuf:"bytes,59,opt,name=endTxnOnPartitionResponse" json:"endTxnOnPartitionResponse,omitempty"`
	EndTxnOnSubscription         *CommandEndTxnOnSubscription         `protobuf:"bytes,60,opt,name=endTxnOnSubscription" json:"endTxnOnSubscription,omitempty"`
	EndTxnOnSubscriptionResponse *CommandEndTxnOnSubscriptionResponse `protobuf:"bytes,61,opt,name=endTxnOnSubscriptionResponse" json:"endTxnOnSubscriptionResponse,omitempty"`
	XXX_NoUnkeyedLiteral         struct{}                             `json:"-"`
	XXX_unrecognized             []byte                               `json:"-"`
	XXX_sizecache                int32                                `json:"-"`
}

func (*BaseCommand) Descriptor 

func (*BaseCommand) Descriptor() ([]byte, []int)

func (*BaseCommand) GetAck 

func (m *BaseCommand) GetAck() *CommandAck

func (*BaseCommand) GetAckResponse 

func (m *BaseCommand) GetAckResponse() *CommandAckResponse

func (*BaseCommand) GetActiveConsumerChange 

func (m *BaseCommand) GetActiveConsumerChange() *CommandActiveConsumerChange

func (*BaseCommand) GetAddPartitionToTxn 

func (m *BaseCommand) GetAddPartitionToTxn() *CommandAddPartitionToTxn

func (*BaseCommand) GetAddPartitionToTxnResponse 

func (m *BaseCommand) GetAddPartitionToTxnResponse() *CommandAddPartitionToTxnResponse

func (*BaseCommand) GetAddSubscriptionToTxn 

func (m *BaseCommand) GetAddSubscriptionToTxn() *CommandAddSubscriptionToTxn

func (*BaseCommand) GetAddSubscriptionToTxnResponse 

func (m *BaseCommand) GetAddSubscriptionToTxnResponse() *CommandAddSubscriptionToTxnResponse

func (*BaseCommand) GetAuthChallenge 

func (m *BaseCommand) GetAuthChallenge() *CommandAuthChallenge

func (*BaseCommand) GetAuthResponse 

func (m *BaseCommand) GetAuthResponse() *CommandAuthResponse

func (*BaseCommand) GetCloseConsumer 

func (m *BaseCommand) GetCloseConsumer() *CommandCloseConsumer

func (*BaseCommand) GetCloseProducer 

func (m *BaseCommand) GetCloseProducer() *CommandCloseProducer

func (*BaseCommand) GetConnect 

func (m *BaseCommand) GetConnect() *CommandConnect

func (*BaseCommand) GetConnected 

func (m *BaseCommand) GetConnected() *CommandConnected

func (*BaseCommand) GetConsumerStats 

func (m *BaseCommand) GetConsumerStats() *CommandConsumerStats

func (*BaseCommand) GetConsumerStatsResponse 

func (m *BaseCommand) GetConsumerStatsResponse() *CommandConsumerStatsResponse

func (*BaseCommand) GetEndTxn 

func (m *BaseCommand) GetEndTxn() *CommandEndTxn

func (*BaseCommand) GetEndTxnOnPartition 

func (m *BaseCommand) GetEndTxnOnPartition() *CommandEndTxnOnPartition

func (*BaseCommand) GetEndTxnOnPartitionResponse 

func (m *BaseCommand) GetEndTxnOnPartitionResponse() *CommandEndTxnOnPartitionResponse

func (*BaseCommand) GetEndTxnOnSubscription 

func (m *BaseCommand) GetEndTxnOnSubscription() *CommandEndTxnOnSubscription

func (*BaseCommand) GetEndTxnOnSubscriptionResponse 

func (m *BaseCommand) GetEndTxnOnSubscriptionResponse() *CommandEndTxnOnSubscriptionResponse

func (*BaseCommand) GetEndTxnResponse 

func (m *BaseCommand) GetEndTxnResponse() *CommandEndTxnResponse

func (*BaseCommand) GetError 

func (m *BaseCommand) GetError() *CommandError

func (*BaseCommand) GetFlow 

func (m *BaseCommand) GetFlow() *CommandFlow

func (*BaseCommand) GetGetLastMessageId 

func (m *BaseCommand) GetGetLastMessageId() *CommandGetLastMessageId

func (*BaseCommand) GetGetLastMessageIdResponse 

func (m *BaseCommand) GetGetLastMessageIdResponse() *CommandGetLastMessageIdResponse

func (*BaseCommand) GetGetOrCreateSchema 

func (m *BaseCommand) GetGetOrCreateSchema() *CommandGetOrCreateSchema

func (*BaseCommand) GetGetOrCreateSchemaResponse 

func (m *BaseCommand) GetGetOrCreateSchemaResponse() *CommandGetOrCreateSchemaResponse

func (*BaseCommand) GetGetSchema 

func (m *BaseCommand) GetGetSchema() *CommandGetSchema

func (*BaseCommand) GetGetSchemaResponse 

func (m *BaseCommand) GetGetSchemaResponse() *CommandGetSchemaResponse

func (*BaseCommand) GetGetTopicsOfNamespace 

func (m *BaseCommand) GetGetTopicsOfNamespace() *CommandGetTopicsOfNamespace

func (*BaseCommand) GetGetTopicsOfNamespaceResponse 

func (m *BaseCommand) GetGetTopicsOfNamespaceResponse() *CommandGetTopicsOfNamespaceResponse

func (*BaseCommand) GetLookupTopic 

func (m *BaseCommand) GetLookupTopic() *CommandLookupTopic

func (*BaseCommand) GetLookupTopicResponse 

func (m *BaseCommand) GetLookupTopicResponse() *CommandLookupTopicResponse

func (*BaseCommand) GetMessage 

func (m *BaseCommand) GetMessage() *CommandMessage

func (*BaseCommand) GetNewTxn 

func (m *BaseCommand) GetNewTxn() *CommandNewTxn

func (*BaseCommand) GetNewTxnResponse 

func (m *BaseCommand) GetNewTxnResponse() *CommandNewTxnResponse

func (*BaseCommand) GetPartitionMetadata 

func (m *BaseCommand) GetPartitionMetadata() *CommandPartitionedTopicMetadata

func (*BaseCommand) GetPartitionMetadataResponse 

func (m *BaseCommand) GetPartitionMetadataResponse() *CommandPartitionedTopicMetadataResponse

func (*BaseCommand) GetPing 

func (m *BaseCommand) GetPing() *CommandPing

func (*BaseCommand) GetPong 

func (m *BaseCommand) GetPong() *CommandPong

func (*BaseCommand) GetProducer 

func (m *BaseCommand) GetProducer() *CommandProducer

func (*BaseCommand) GetProducerSuccess 

func (m *BaseCommand) GetProducerSuccess() *CommandProducerSuccess

func (*BaseCommand) GetReachedEndOfTopic 

func (m *BaseCommand) GetReachedEndOfTopic() *CommandReachedEndOfTopic

func (*BaseCommand) GetRedeliverUnacknowledgedMessages 

func (m *BaseCommand) GetRedeliverUnacknowledgedMessages() *CommandRedeliverUnacknowledgedMessages

func (*BaseCommand) GetSeek 

func (m *BaseCommand) GetSeek() *CommandSeek

func (*BaseCommand) GetSend 

func (m *BaseCommand) GetSend() *CommandSend

func (*BaseCommand) GetSendError 

func (m *BaseCommand) GetSendError() *CommandSendError

func (*BaseCommand) GetSendReceipt 

func (m *BaseCommand) GetSendReceipt() *CommandSendReceipt

func (*BaseCommand) GetSubscribe 

func (m *BaseCommand) GetSubscribe() *CommandSubscribe

func (*BaseCommand) GetSuccess 

func (m *BaseCommand) GetSuccess() *CommandSuccess

func (*BaseCommand) GetType 

func (m *BaseCommand) GetType() BaseCommand_Type

func (*BaseCommand) GetUnsubscribe 

func (m *BaseCommand) GetUnsubscribe() *CommandUnsubscribe

func (*BaseCommand) ProtoMessage 

func (*BaseCommand) ProtoMessage()

func (*BaseCommand) Reset 

func (m *BaseCommand) Reset()

func (*BaseCommand) String 

func (m *BaseCommand) String() string

func (*BaseCommand) XXX_DiscardUnknown 

func (m *BaseCommand) XXX_DiscardUnknown()

func (*BaseCommand) XXX_Marshal 

func (m *BaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BaseCommand) XXX_Merge 

func (m *BaseCommand) XXX_Merge(src proto.Message)

func (*BaseCommand) XXX_Size 

func (m *BaseCommand) XXX_Size() int

func (*BaseCommand) XXX_Unmarshal 

func (m *BaseCommand) XXX_Unmarshal(b []byte) error

type BaseCommand_Type 

type BaseCommand_Type int32
const (
	BaseCommand_CONNECT                           BaseCommand_Type = 2
	BaseCommand_CONNECTED                         BaseCommand_Type = 3
	BaseCommand_SUBSCRIBE                         BaseCommand_Type = 4
	BaseCommand_PRODUCER                          BaseCommand_Type = 5
	BaseCommand_SEND                              BaseCommand_Type = 6
	BaseCommand_SEND_RECEIPT                      BaseCommand_Type = 7
	BaseCommand_SEND_ERROR                        BaseCommand_Type = 8
	BaseCommand_MESSAGE                           BaseCommand_Type = 9
	BaseCommand_ACK                               BaseCommand_Type = 10
	BaseCommand_FLOW                              BaseCommand_Type = 11
	BaseCommand_UNSUBSCRIBE                       BaseCommand_Type = 12
	BaseCommand_SUCCESS                           BaseCommand_Type = 13
	BaseCommand_ERROR                             BaseCommand_Type = 14
	BaseCommand_CLOSE_PRODUCER                    BaseCommand_Type = 15
	BaseCommand_CLOSE_CONSUMER                    BaseCommand_Type = 16
	BaseCommand_PRODUCER_SUCCESS                  BaseCommand_Type = 17
	BaseCommand_PING                              BaseCommand_Type = 18
	BaseCommand_PONG                              BaseCommand_Type = 19
	BaseCommand_REDELIVER_UNACKNOWLEDGED_MESSAGES BaseCommand_Type = 20
	BaseCommand_PARTITIONED_METADATA              BaseCommand_Type = 21
	BaseCommand_PARTITIONED_METADATA_RESPONSE     BaseCommand_Type = 22
	BaseCommand_LOOKUP                            BaseCommand_Type = 23
	BaseCommand_LOOKUP_RESPONSE                   BaseCommand_Type = 24
	BaseCommand_CONSUMER_STATS                    BaseCommand_Type = 25
	BaseCommand_CONSUMER_STATS_RESPONSE           BaseCommand_Type = 26
	BaseCommand_REACHED_END_OF_TOPIC              BaseCommand_Type = 27
	BaseCommand_SEEK                              BaseCommand_Type = 28
	BaseCommand_GET_LAST_MESSAGE_ID               BaseCommand_Type = 29
	BaseCommand_GET_LAST_MESSAGE_ID_RESPONSE      BaseCommand_Type = 30
	BaseCommand_ACTIVE_CONSUMER_CHANGE            BaseCommand_Type = 31
	BaseCommand_GET_TOPICS_OF_NAMESPACE           BaseCommand_Type = 32
	BaseCommand_GET_TOPICS_OF_NAMESPACE_RESPONSE  BaseCommand_Type = 33
	BaseCommand_GET_SCHEMA                        BaseCommand_Type = 34
	BaseCommand_GET_SCHEMA_RESPONSE               BaseCommand_Type = 35
	BaseCommand_AUTH_CHALLENGE                    BaseCommand_Type = 36
	BaseCommand_AUTH_RESPONSE                     BaseCommand_Type = 37
	BaseCommand_ACK_RESPONSE                      BaseCommand_Type = 38
	BaseCommand_GET_OR_CREATE_SCHEMA              BaseCommand_Type = 39
	BaseCommand_GET_OR_CREATE_SCHEMA_RESPONSE     BaseCommand_Type = 40
	// transaction related
	BaseCommand_NEW_TXN                          BaseCommand_Type = 50
	BaseCommand_NEW_TXN_RESPONSE                 BaseCommand_Type = 51
	BaseCommand_ADD_PARTITION_TO_TXN             BaseCommand_Type = 52
	BaseCommand_ADD_PARTITION_TO_TXN_RESPONSE    BaseCommand_Type = 53
	BaseCommand_ADD_SUBSCRIPTION_TO_TXN          BaseCommand_Type = 54
	BaseCommand_ADD_SUBSCRIPTION_TO_TXN_RESPONSE BaseCommand_Type = 55
	BaseCommand_END_TXN                          BaseCommand_Type = 56
	BaseCommand_END_TXN_RESPONSE                 BaseCommand_Type = 57
	BaseCommand_END_TXN_ON_PARTITION             BaseCommand_Type = 58
	BaseCommand_END_TXN_ON_PARTITION_RESPONSE    BaseCommand_Type = 59
	BaseCommand_END_TXN_ON_SUBSCRIPTION          BaseCommand_Type = 60
	BaseCommand_END_TXN_ON_SUBSCRIPTION_RESPONSE BaseCommand_Type = 61
)

func (BaseCommand_Type) Enum 

func (x BaseCommand_Type) Enum() *BaseCommand_Type

func (BaseCommand_Type) EnumDescriptor 

func (BaseCommand_Type) EnumDescriptor() ([]byte, []int)

func (BaseCommand_Type) String 

func (x BaseCommand_Type) String() string

func (*BaseCommand_Type) UnmarshalJSON 

func (x *BaseCommand_Type) UnmarshalJSON(data []byte) error

type CommandAck 

type CommandAck struct {
	ConsumerId *uint64             `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	AckType    *CommandAck_AckType `protobuf:"varint,2,req,name=ack_type,json=ackType,enum=pulsar.proto.CommandAck_AckType" json:"ack_type,omitempty"`
	// In case of individual acks, the client can pass a list of message ids
	MessageId            []*MessageIdData            `protobuf:"bytes,3,rep,name=message_id,json=messageId" json:"message_id,omitempty"`
	ValidationError      *CommandAck_ValidationError `` /* 145-byte string literal not displayed */
	Properties           []*KeyLongValue             `protobuf:"bytes,5,rep,name=properties" json:"properties,omitempty"`
	TxnidLeastBits       *uint64                     `protobuf:"varint,6,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64                     `protobuf:"varint,7,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*CommandAck) Descriptor 

func (*CommandAck) Descriptor() ([]byte, []int)

func (*CommandAck) GetAckType 

func (m *CommandAck) GetAckType() CommandAck_AckType

func (*CommandAck) GetConsumerId 

func (m *CommandAck) GetConsumerId() uint64

func (*CommandAck) GetMessageId 

func (m *CommandAck) GetMessageId() []*MessageIdData

func (*CommandAck) GetProperties 

func (m *CommandAck) GetProperties() []*KeyLongValue

func (*CommandAck) GetTxnidLeastBits 

func (m *CommandAck) GetTxnidLeastBits() uint64

func (*CommandAck) GetTxnidMostBits 

func (m *CommandAck) GetTxnidMostBits() uint64

func (*CommandAck) GetValidationError 

func (m *CommandAck) GetValidationError() CommandAck_ValidationError

func (*CommandAck) ProtoMessage 

func (*CommandAck) ProtoMessage()

func (*CommandAck) Reset 

func (m *CommandAck) Reset()

func (*CommandAck) String 

func (m *CommandAck) String() string

func (*CommandAck) XXX_DiscardUnknown 

func (m *CommandAck) XXX_DiscardUnknown()

func (*CommandAck) XXX_Marshal 

func (m *CommandAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAck) XXX_Merge 

func (m *CommandAck) XXX_Merge(src proto.Message)

func (*CommandAck) XXX_Size 

func (m *CommandAck) XXX_Size() int

func (*CommandAck) XXX_Unmarshal 

func (m *CommandAck) XXX_Unmarshal(b []byte) error

type CommandAckResponse 

type CommandAckResponse struct {
	ConsumerId           *uint64      `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandAckResponse) Descriptor 

func (*CommandAckResponse) Descriptor() ([]byte, []int)

func (*CommandAckResponse) GetConsumerId 

func (m *CommandAckResponse) GetConsumerId() uint64

func (*CommandAckResponse) GetError 

func (m *CommandAckResponse) GetError() ServerError

func (*CommandAckResponse) GetMessage 

func (m *CommandAckResponse) GetMessage() string

func (*CommandAckResponse) GetTxnidLeastBits 

func (m *CommandAckResponse) GetTxnidLeastBits() uint64

func (*CommandAckResponse) GetTxnidMostBits 

func (m *CommandAckResponse) GetTxnidMostBits() uint64

func (*CommandAckResponse) ProtoMessage 

func (*CommandAckResponse) ProtoMessage()

func (*CommandAckResponse) Reset 

func (m *CommandAckResponse) Reset()

func (*CommandAckResponse) String 

func (m *CommandAckResponse) String() string

func (*CommandAckResponse) XXX_DiscardUnknown 

func (m *CommandAckResponse) XXX_DiscardUnknown()

func (*CommandAckResponse) XXX_Marshal 

func (m *CommandAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAckResponse) XXX_Merge 

func (m *CommandAckResponse) XXX_Merge(src proto.Message)

func (*CommandAckResponse) XXX_Size 

func (m *CommandAckResponse) XXX_Size() int

func (*CommandAckResponse) XXX_Unmarshal 

func (m *CommandAckResponse) XXX_Unmarshal(b []byte) error

type CommandAck_AckType 

type CommandAck_AckType int32
const (
	CommandAck_Individual CommandAck_AckType = 0
	CommandAck_Cumulative CommandAck_AckType = 1
)

func (CommandAck_AckType) Enum 

func (x CommandAck_AckType) Enum() *CommandAck_AckType

func (CommandAck_AckType) EnumDescriptor 

func (CommandAck_AckType) EnumDescriptor() ([]byte, []int)

func (CommandAck_AckType) String 

func (x CommandAck_AckType) String() string

func (*CommandAck_AckType) UnmarshalJSON 

func (x *CommandAck_AckType) UnmarshalJSON(data []byte) error

type CommandAck_ValidationError 

type CommandAck_ValidationError int32

Acks can contain a flag to indicate the consumer received an invalid message that got discarded before being passed on to the application. 

const (
	CommandAck_UncompressedSizeCorruption CommandAck_ValidationError = 0
	CommandAck_DecompressionError         CommandAck_ValidationError = 1
	CommandAck_ChecksumMismatch           CommandAck_ValidationError = 2
	CommandAck_BatchDeSerializeError      CommandAck_ValidationError = 3
	CommandAck_DecryptionError            CommandAck_ValidationError = 4
)

func (CommandAck_ValidationError) Enum 

func (x CommandAck_ValidationError) Enum() *CommandAck_ValidationError

func (CommandAck_ValidationError) EnumDescriptor 

func (CommandAck_ValidationError) EnumDescriptor() ([]byte, []int)

func (CommandAck_ValidationError) String 

func (x CommandAck_ValidationError) String() string

func (*CommandAck_ValidationError) UnmarshalJSON 

func (x *CommandAck_ValidationError) UnmarshalJSON(data []byte) error

type CommandActiveConsumerChange 

type CommandActiveConsumerChange struct {
	ConsumerId           *uint64  `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	IsActive             *bool    `protobuf:"varint,2,opt,name=is_active,json=isActive,def=0" json:"is_active,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

changes on active consumer

func (*CommandActiveConsumerChange) Descriptor 

func (*CommandActiveConsumerChange) Descriptor() ([]byte, []int)

func (*CommandActiveConsumerChange) GetConsumerId 

func (m *CommandActiveConsumerChange) GetConsumerId() uint64

func (*CommandActiveConsumerChange) GetIsActive 

func (m *CommandActiveConsumerChange) GetIsActive() bool

func (*CommandActiveConsumerChange) ProtoMessage 

func (*CommandActiveConsumerChange) ProtoMessage()

func (*CommandActiveConsumerChange) Reset 

func (m *CommandActiveConsumerChange) Reset()

func (*CommandActiveConsumerChange) String 

func (m *CommandActiveConsumerChange) String() string

func (*CommandActiveConsumerChange) XXX_DiscardUnknown 

func (m *CommandActiveConsumerChange) XXX_DiscardUnknown()

func (*CommandActiveConsumerChange) XXX_Marshal 

func (m *CommandActiveConsumerChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandActiveConsumerChange) XXX_Merge 

func (m *CommandActiveConsumerChange) XXX_Merge(src proto.Message)

func (*CommandActiveConsumerChange) XXX_Size 

func (m *CommandActiveConsumerChange) XXX_Size() int

func (*CommandActiveConsumerChange) XXX_Unmarshal 

func (m *CommandActiveConsumerChange) XXX_Unmarshal(b []byte) error

type CommandAddPartitionToTxn 

type CommandAddPartitionToTxn struct {
	RequestId            *uint64  `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64  `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64  `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Partitions           []string `protobuf:"bytes,4,rep,name=partitions" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandAddPartitionToTxn) Descriptor 

func (*CommandAddPartitionToTxn) Descriptor() ([]byte, []int)

func (*CommandAddPartitionToTxn) GetPartitions 

func (m *CommandAddPartitionToTxn) GetPartitions() []string

func (*CommandAddPartitionToTxn) GetRequestId 

func (m *CommandAddPartitionToTxn) GetRequestId() uint64

func (*CommandAddPartitionToTxn) GetTxnidLeastBits 

func (m *CommandAddPartitionToTxn) GetTxnidLeastBits() uint64

func (*CommandAddPartitionToTxn) GetTxnidMostBits 

func (m *CommandAddPartitionToTxn) GetTxnidMostBits() uint64

func (*CommandAddPartitionToTxn) ProtoMessage 

func (*CommandAddPartitionToTxn) ProtoMessage()

func (*CommandAddPartitionToTxn) Reset 

func (m *CommandAddPartitionToTxn) Reset()

func (*CommandAddPartitionToTxn) String 

func (m *CommandAddPartitionToTxn) String() string

func (*CommandAddPartitionToTxn) XXX_DiscardUnknown 

func (m *CommandAddPartitionToTxn) XXX_DiscardUnknown()

func (*CommandAddPartitionToTxn) XXX_Marshal 

func (m *CommandAddPartitionToTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAddPartitionToTxn) XXX_Merge 

func (m *CommandAddPartitionToTxn) XXX_Merge(src proto.Message)

func (*CommandAddPartitionToTxn) XXX_Size 

func (m *CommandAddPartitionToTxn) XXX_Size() int

func (*CommandAddPartitionToTxn) XXX_Unmarshal 

func (m *CommandAddPartitionToTxn) XXX_Unmarshal(b []byte) error

type CommandAddPartitionToTxnResponse 

type CommandAddPartitionToTxnResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandAddPartitionToTxnResponse) Descriptor 

func (*CommandAddPartitionToTxnResponse) Descriptor() ([]byte, []int)

func (*CommandAddPartitionToTxnResponse) GetError 

func (m *CommandAddPartitionToTxnResponse) GetError() ServerError

func (*CommandAddPartitionToTxnResponse) GetMessage 

func (m *CommandAddPartitionToTxnResponse) GetMessage() string

func (*CommandAddPartitionToTxnResponse) GetRequestId 

func (m *CommandAddPartitionToTxnResponse) GetRequestId() uint64

func (*CommandAddPartitionToTxnResponse) GetTxnidLeastBits 

func (m *CommandAddPartitionToTxnResponse) GetTxnidLeastBits() uint64

func (*CommandAddPartitionToTxnResponse) GetTxnidMostBits 

func (m *CommandAddPartitionToTxnResponse) GetTxnidMostBits() uint64

func (*CommandAddPartitionToTxnResponse) ProtoMessage 

func (*CommandAddPartitionToTxnResponse) ProtoMessage()

func (*CommandAddPartitionToTxnResponse) Reset 

func (m *CommandAddPartitionToTxnResponse) Reset()

func (*CommandAddPartitionToTxnResponse) String 

func (m *CommandAddPartitionToTxnResponse) String() string

func (*CommandAddPartitionToTxnResponse) XXX_DiscardUnknown 

func (m *CommandAddPartitionToTxnResponse) XXX_DiscardUnknown()

func (*CommandAddPartitionToTxnResponse) XXX_Marshal 

func (m *CommandAddPartitionToTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAddPartitionToTxnResponse) XXX_Merge 

func (m *CommandAddPartitionToTxnResponse) XXX_Merge(src proto.Message)

func (*CommandAddPartitionToTxnResponse) XXX_Size 

func (m *CommandAddPartitionToTxnResponse) XXX_Size() int

func (*CommandAddPartitionToTxnResponse) XXX_Unmarshal 

func (m *CommandAddPartitionToTxnResponse) XXX_Unmarshal(b []byte) error

type CommandAddSubscriptionToTxn 

type CommandAddSubscriptionToTxn struct {
	RequestId            *uint64         `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64         `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64         `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Subscription         []*Subscription `protobuf:"bytes,4,rep,name=subscription" json:"subscription,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CommandAddSubscriptionToTxn) Descriptor 

func (*CommandAddSubscriptionToTxn) Descriptor() ([]byte, []int)

func (*CommandAddSubscriptionToTxn) GetRequestId 

func (m *CommandAddSubscriptionToTxn) GetRequestId() uint64

func (*CommandAddSubscriptionToTxn) GetSubscription 

func (m *CommandAddSubscriptionToTxn) GetSubscription() []*Subscription

func (*CommandAddSubscriptionToTxn) GetTxnidLeastBits 

func (m *CommandAddSubscriptionToTxn) GetTxnidLeastBits() uint64

func (*CommandAddSubscriptionToTxn) GetTxnidMostBits 

func (m *CommandAddSubscriptionToTxn) GetTxnidMostBits() uint64

func (*CommandAddSubscriptionToTxn) ProtoMessage 

func (*CommandAddSubscriptionToTxn) ProtoMessage()

func (*CommandAddSubscriptionToTxn) Reset 

func (m *CommandAddSubscriptionToTxn) Reset()

func (*CommandAddSubscriptionToTxn) String 

func (m *CommandAddSubscriptionToTxn) String() string

func (*CommandAddSubscriptionToTxn) XXX_DiscardUnknown 

func (m *CommandAddSubscriptionToTxn) XXX_DiscardUnknown()

func (*CommandAddSubscriptionToTxn) XXX_Marshal 

func (m *CommandAddSubscriptionToTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAddSubscriptionToTxn) XXX_Merge 

func (m *CommandAddSubscriptionToTxn) XXX_Merge(src proto.Message)

func (*CommandAddSubscriptionToTxn) XXX_Size 

func (m *CommandAddSubscriptionToTxn) XXX_Size() int

func (*CommandAddSubscriptionToTxn) XXX_Unmarshal 

func (m *CommandAddSubscriptionToTxn) XXX_Unmarshal(b []byte) error

type CommandAddSubscriptionToTxnResponse 

type CommandAddSubscriptionToTxnResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandAddSubscriptionToTxnResponse) Descriptor 

func (*CommandAddSubscriptionToTxnResponse) Descriptor() ([]byte, []int)

func (*CommandAddSubscriptionToTxnResponse) GetError 

func (m *CommandAddSubscriptionToTxnResponse) GetError() ServerError

func (*CommandAddSubscriptionToTxnResponse) GetMessage 

func (m *CommandAddSubscriptionToTxnResponse) GetMessage() string

func (*CommandAddSubscriptionToTxnResponse) GetRequestId 

func (m *CommandAddSubscriptionToTxnResponse) GetRequestId() uint64

func (*CommandAddSubscriptionToTxnResponse) GetTxnidLeastBits 

func (m *CommandAddSubscriptionToTxnResponse) GetTxnidLeastBits() uint64

func (*CommandAddSubscriptionToTxnResponse) GetTxnidMostBits 

func (m *CommandAddSubscriptionToTxnResponse) GetTxnidMostBits() uint64

func (*CommandAddSubscriptionToTxnResponse) ProtoMessage 

func (*CommandAddSubscriptionToTxnResponse) ProtoMessage()

func (*CommandAddSubscriptionToTxnResponse) Reset 

func (m *CommandAddSubscriptionToTxnResponse) Reset()

func (*CommandAddSubscriptionToTxnResponse) String 

func (m *CommandAddSubscriptionToTxnResponse) String() string

func (*CommandAddSubscriptionToTxnResponse) XXX_DiscardUnknown 

func (m *CommandAddSubscriptionToTxnResponse) XXX_DiscardUnknown()

func (*CommandAddSubscriptionToTxnResponse) XXX_Marshal 

func (m *CommandAddSubscriptionToTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAddSubscriptionToTxnResponse) XXX_Merge 

func (m *CommandAddSubscriptionToTxnResponse) XXX_Merge(src proto.Message)

func (*CommandAddSubscriptionToTxnResponse) XXX_Size 

func (m *CommandAddSubscriptionToTxnResponse) XXX_Size() int

func (*CommandAddSubscriptionToTxnResponse) XXX_Unmarshal 

func (m *CommandAddSubscriptionToTxnResponse) XXX_Unmarshal(b []byte) error

type CommandAuthChallenge 

type CommandAuthChallenge struct {
	ServerVersion        *string   `protobuf:"bytes,1,opt,name=server_version,json=serverVersion" json:"server_version,omitempty"`
	Challenge            *AuthData `protobuf:"bytes,2,opt,name=challenge" json:"challenge,omitempty"`
	ProtocolVersion      *int32    `protobuf:"varint,3,opt,name=protocol_version,json=protocolVersion,def=0" json:"protocol_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CommandAuthChallenge) Descriptor 

func (*CommandAuthChallenge) Descriptor() ([]byte, []int)

func (*CommandAuthChallenge) GetChallenge 

func (m *CommandAuthChallenge) GetChallenge() *AuthData

func (*CommandAuthChallenge) GetProtocolVersion 

func (m *CommandAuthChallenge) GetProtocolVersion() int32

func (*CommandAuthChallenge) GetServerVersion 

func (m *CommandAuthChallenge) GetServerVersion() string

func (*CommandAuthChallenge) ProtoMessage 

func (*CommandAuthChallenge) ProtoMessage()

func (*CommandAuthChallenge) Reset 

func (m *CommandAuthChallenge) Reset()

func (*CommandAuthChallenge) String 

func (m *CommandAuthChallenge) String() string

func (*CommandAuthChallenge) XXX_DiscardUnknown 

func (m *CommandAuthChallenge) XXX_DiscardUnknown()

func (*CommandAuthChallenge) XXX_Marshal 

func (m *CommandAuthChallenge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAuthChallenge) XXX_Merge 

func (m *CommandAuthChallenge) XXX_Merge(src proto.Message)

func (*CommandAuthChallenge) XXX_Size 

func (m *CommandAuthChallenge) XXX_Size() int

func (*CommandAuthChallenge) XXX_Unmarshal 

func (m *CommandAuthChallenge) XXX_Unmarshal(b []byte) error

type CommandAuthResponse 

type CommandAuthResponse struct {
	ClientVersion        *string   `protobuf:"bytes,1,opt,name=client_version,json=clientVersion" json:"client_version,omitempty"`
	Response             *AuthData `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"`
	ProtocolVersion      *int32    `protobuf:"varint,3,opt,name=protocol_version,json=protocolVersion,def=0" json:"protocol_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CommandAuthResponse) Descriptor 

func (*CommandAuthResponse) Descriptor() ([]byte, []int)

func (*CommandAuthResponse) GetClientVersion 

func (m *CommandAuthResponse) GetClientVersion() string

func (*CommandAuthResponse) GetProtocolVersion 

func (m *CommandAuthResponse) GetProtocolVersion() int32

func (*CommandAuthResponse) GetResponse 

func (m *CommandAuthResponse) GetResponse() *AuthData

func (*CommandAuthResponse) ProtoMessage 

func (*CommandAuthResponse) ProtoMessage()

func (*CommandAuthResponse) Reset 

func (m *CommandAuthResponse) Reset()

func (*CommandAuthResponse) String 

func (m *CommandAuthResponse) String() string

func (*CommandAuthResponse) XXX_DiscardUnknown 

func (m *CommandAuthResponse) XXX_DiscardUnknown()

func (*CommandAuthResponse) XXX_Marshal 

func (m *CommandAuthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandAuthResponse) XXX_Merge 

func (m *CommandAuthResponse) XXX_Merge(src proto.Message)

func (*CommandAuthResponse) XXX_Size 

func (m *CommandAuthResponse) XXX_Size() int

func (*CommandAuthResponse) XXX_Unmarshal 

func (m *CommandAuthResponse) XXX_Unmarshal(b []byte) error

type CommandCloseConsumer 

type CommandCloseConsumer struct {
	ConsumerId           *uint64  `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	RequestId            *uint64  `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandCloseConsumer) Descriptor 

func (*CommandCloseConsumer) Descriptor() ([]byte, []int)

func (*CommandCloseConsumer) GetConsumerId 

func (m *CommandCloseConsumer) GetConsumerId() uint64

func (*CommandCloseConsumer) GetRequestId 

func (m *CommandCloseConsumer) GetRequestId() uint64

func (*CommandCloseConsumer) ProtoMessage 

func (*CommandCloseConsumer) ProtoMessage()

func (*CommandCloseConsumer) Reset 

func (m *CommandCloseConsumer) Reset()

func (*CommandCloseConsumer) String 

func (m *CommandCloseConsumer) String() string

func (*CommandCloseConsumer) XXX_DiscardUnknown 

func (m *CommandCloseConsumer) XXX_DiscardUnknown()

func (*CommandCloseConsumer) XXX_Marshal 

func (m *CommandCloseConsumer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandCloseConsumer) XXX_Merge 

func (m *CommandCloseConsumer) XXX_Merge(src proto.Message)

func (*CommandCloseConsumer) XXX_Size 

func (m *CommandCloseConsumer) XXX_Size() int

func (*CommandCloseConsumer) XXX_Unmarshal 

func (m *CommandCloseConsumer) XXX_Unmarshal(b []byte) error

type CommandCloseProducer 

type CommandCloseProducer struct {
	ProducerId           *uint64  `protobuf:"varint,1,req,name=producer_id,json=producerId" json:"producer_id,omitempty"`
	RequestId            *uint64  `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandCloseProducer) Descriptor 

func (*CommandCloseProducer) Descriptor() ([]byte, []int)

func (*CommandCloseProducer) GetProducerId 

func (m *CommandCloseProducer) GetProducerId() uint64

func (*CommandCloseProducer) GetRequestId 

func (m *CommandCloseProducer) GetRequestId() uint64

func (*CommandCloseProducer) ProtoMessage 

func (*CommandCloseProducer) ProtoMessage()

func (*CommandCloseProducer) Reset 

func (m *CommandCloseProducer) Reset()

func (*CommandCloseProducer) String 

func (m *CommandCloseProducer) String() string

func (*CommandCloseProducer) XXX_DiscardUnknown 

func (m *CommandCloseProducer) XXX_DiscardUnknown()

func (*CommandCloseProducer) XXX_Marshal 

func (m *CommandCloseProducer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandCloseProducer) XXX_Merge 

func (m *CommandCloseProducer) XXX_Merge(src proto.Message)

func (*CommandCloseProducer) XXX_Size 

func (m *CommandCloseProducer) XXX_Size() int

func (*CommandCloseProducer) XXX_Unmarshal 

func (m *CommandCloseProducer) XXX_Unmarshal(b []byte) error

type CommandConnect 

type CommandConnect struct {
	ClientVersion   *string     `protobuf:"bytes,1,req,name=client_version,json=clientVersion" json:"client_version,omitempty"`
	AuthMethod      *AuthMethod `protobuf:"varint,2,opt,name=auth_method,json=authMethod,enum=pulsar.proto.AuthMethod" json:"auth_method,omitempty"`
	AuthMethodName  *string     `protobuf:"bytes,5,opt,name=auth_method_name,json=authMethodName" json:"auth_method_name,omitempty"`
	AuthData        []byte      `protobuf:"bytes,3,opt,name=auth_data,json=authData" json:"auth_data,omitempty"`
	ProtocolVersion *int32      `protobuf:"varint,4,opt,name=protocol_version,json=protocolVersion,def=0" json:"protocol_version,omitempty"`
	// Client can ask to be proxyied to a specific broker
	// This is only honored by a Pulsar proxy
	ProxyToBrokerUrl *string `protobuf:"bytes,6,opt,name=proxy_to_broker_url,json=proxyToBrokerUrl" json:"proxy_to_broker_url,omitempty"`
	// Original principal that was verified by
	// a Pulsar proxy. In this case the auth info above
	// will be the auth of the proxy itself
	OriginalPrincipal *string `protobuf:"bytes,7,opt,name=original_principal,json=originalPrincipal" json:"original_principal,omitempty"`
	// Original auth role and auth Method that was passed
	// to the proxy. In this case the auth info above
	// will be the auth of the proxy itself
	OriginalAuthData   *string `protobuf:"bytes,8,opt,name=original_auth_data,json=originalAuthData" json:"original_auth_data,omitempty"`
	OriginalAuthMethod *string `protobuf:"bytes,9,opt,name=original_auth_method,json=originalAuthMethod" json:"original_auth_method,omitempty"`
	// Feature flags
	FeatureFlags         *FeatureFlags `protobuf:"bytes,10,opt,name=feature_flags,json=featureFlags" json:"feature_flags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CommandConnect) Descriptor 

func (*CommandConnect) Descriptor() ([]byte, []int)

func (*CommandConnect) GetAuthData 

func (m *CommandConnect) GetAuthData() []byte

func (*CommandConnect) GetAuthMethod 

func (m *CommandConnect) GetAuthMethod() AuthMethod

func (*CommandConnect) GetAuthMethodName 

func (m *CommandConnect) GetAuthMethodName() string

func (*CommandConnect) GetClientVersion 

func (m *CommandConnect) GetClientVersion() string

func (*CommandConnect) GetFeatureFlags 

func (m *CommandConnect) GetFeatureFlags() *FeatureFlags

func (*CommandConnect) GetOriginalAuthData 

func (m *CommandConnect) GetOriginalAuthData() string

func (*CommandConnect) GetOriginalAuthMethod 

func (m *CommandConnect) GetOriginalAuthMethod() string

func (*CommandConnect) GetOriginalPrincipal 

func (m *CommandConnect) GetOriginalPrincipal() string

func (*CommandConnect) GetProtocolVersion 

func (m *CommandConnect) GetProtocolVersion() int32

func (*CommandConnect) GetProxyToBrokerUrl 

func (m *CommandConnect) GetProxyToBrokerUrl() string

func (*CommandConnect) ProtoMessage 

func (*CommandConnect) ProtoMessage()

func (*CommandConnect) Reset 

func (m *CommandConnect) Reset()

func (*CommandConnect) String 

func (m *CommandConnect) String() string

func (*CommandConnect) XXX_DiscardUnknown 

func (m *CommandConnect) XXX_DiscardUnknown()

func (*CommandConnect) XXX_Marshal 

func (m *CommandConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandConnect) XXX_Merge 

func (m *CommandConnect) XXX_Merge(src proto.Message)

func (*CommandConnect) XXX_Size 

func (m *CommandConnect) XXX_Size() int

func (*CommandConnect) XXX_Unmarshal 

func (m *CommandConnect) XXX_Unmarshal(b []byte) error

type CommandConnected 

type CommandConnected struct {
	ServerVersion        *string  `protobuf:"bytes,1,req,name=server_version,json=serverVersion" json:"server_version,omitempty"`
	ProtocolVersion      *int32   `protobuf:"varint,2,opt,name=protocol_version,json=protocolVersion,def=0" json:"protocol_version,omitempty"`
	MaxMessageSize       *int32   `protobuf:"varint,3,opt,name=max_message_size,json=maxMessageSize" json:"max_message_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandConnected) Descriptor 

func (*CommandConnected) Descriptor() ([]byte, []int)

func (*CommandConnected) GetMaxMessageSize 

func (m *CommandConnected) GetMaxMessageSize() int32

func (*CommandConnected) GetProtocolVersion 

func (m *CommandConnected) GetProtocolVersion() int32

func (*CommandConnected) GetServerVersion 

func (m *CommandConnected) GetServerVersion() string

func (*CommandConnected) ProtoMessage 

func (*CommandConnected) ProtoMessage()

func (*CommandConnected) Reset 

func (m *CommandConnected) Reset()

func (*CommandConnected) String 

func (m *CommandConnected) String() string

func (*CommandConnected) XXX_DiscardUnknown 

func (m *CommandConnected) XXX_DiscardUnknown()

func (*CommandConnected) XXX_Marshal 

func (m *CommandConnected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandConnected) XXX_Merge 

func (m *CommandConnected) XXX_Merge(src proto.Message)

func (*CommandConnected) XXX_Size 

func (m *CommandConnected) XXX_Size() int

func (*CommandConnected) XXX_Unmarshal 

func (m *CommandConnected) XXX_Unmarshal(b []byte) error

type CommandConsumerStats 

type CommandConsumerStats struct {
	RequestId *uint64 `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	// required string topic_name         = 2;
	// required string subscription_name  = 3;
	ConsumerId           *uint64  `protobuf:"varint,4,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandConsumerStats) Descriptor 

func (*CommandConsumerStats) Descriptor() ([]byte, []int)

func (*CommandConsumerStats) GetConsumerId 

func (m *CommandConsumerStats) GetConsumerId() uint64

func (*CommandConsumerStats) GetRequestId 

func (m *CommandConsumerStats) GetRequestId() uint64

func (*CommandConsumerStats) ProtoMessage 

func (*CommandConsumerStats) ProtoMessage()

func (*CommandConsumerStats) Reset 

func (m *CommandConsumerStats) Reset()

func (*CommandConsumerStats) String 

func (m *CommandConsumerStats) String() string

func (*CommandConsumerStats) XXX_DiscardUnknown 

func (m *CommandConsumerStats) XXX_DiscardUnknown()

func (*CommandConsumerStats) XXX_Marshal 

func (m *CommandConsumerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandConsumerStats) XXX_Merge 

func (m *CommandConsumerStats) XXX_Merge(src proto.Message)

func (*CommandConsumerStats) XXX_Size 

func (m *CommandConsumerStats) XXX_Size() int

func (*CommandConsumerStats) XXX_Unmarshal 

func (m *CommandConsumerStats) XXX_Unmarshal(b []byte) error

type CommandConsumerStatsResponse 

type CommandConsumerStatsResponse struct {
	RequestId    *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	ErrorCode    *ServerError `protobuf:"varint,2,opt,name=error_code,json=errorCode,enum=pulsar.proto.ServerError" json:"error_code,omitempty"`
	ErrorMessage *string      `protobuf:"bytes,3,opt,name=error_message,json=errorMessage" json:"error_message,omitempty"`
	/// Total rate of messages delivered to the consumer. msg/s
	MsgRateOut *float64 `protobuf:"fixed64,4,opt,name=msgRateOut" json:"msgRateOut,omitempty"`
	/// Total throughput delivered to the consumer. bytes/s
	MsgThroughputOut *float64 `protobuf:"fixed64,5,opt,name=msgThroughputOut" json:"msgThroughputOut,omitempty"`
	/// Total rate of messages redelivered by this consumer. msg/s
	MsgRateRedeliver *float64 `protobuf:"fixed64,6,opt,name=msgRateRedeliver" json:"msgRateRedeliver,omitempty"`
	/// Name of the consumer
	ConsumerName *string `protobuf:"bytes,7,opt,name=consumerName" json:"consumerName,omitempty"`
	/// Number of available message permits for the consumer
	AvailablePermits *uint64 `protobuf:"varint,8,opt,name=availablePermits" json:"availablePermits,omitempty"`
	/// Number of unacknowledged messages for the consumer
	UnackedMessages *uint64 `protobuf:"varint,9,opt,name=unackedMessages" json:"unackedMessages,omitempty"`
	/// Flag to verify if consumer is blocked due to reaching threshold of unacked messages
	BlockedConsumerOnUnackedMsgs *bool `protobuf:"varint,10,opt,name=blockedConsumerOnUnackedMsgs" json:"blockedConsumerOnUnackedMsgs,omitempty"`
	/// Address of this consumer
	Address *string `protobuf:"bytes,11,opt,name=address" json:"address,omitempty"`
	/// Timestamp of connection
	ConnectedSince *string `protobuf:"bytes,12,opt,name=connectedSince" json:"connectedSince,omitempty"`
	/// Whether this subscription is Exclusive or Shared or Failover
	Type *string `protobuf:"bytes,13,opt,name=type" json:"type,omitempty"`
	/// Total rate of messages expired on this subscription. msg/s
	MsgRateExpired *float64 `protobuf:"fixed64,14,opt,name=msgRateExpired" json:"msgRateExpired,omitempty"`
	/// Number of messages in the subscription backlog
	MsgBacklog           *uint64  `protobuf:"varint,15,opt,name=msgBacklog" json:"msgBacklog,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandConsumerStatsResponse) Descriptor 

func (*CommandConsumerStatsResponse) Descriptor() ([]byte, []int)

func (*CommandConsumerStatsResponse) GetAddress 

func (m *CommandConsumerStatsResponse) GetAddress() string

func (*CommandConsumerStatsResponse) GetAvailablePermits 

func (m *CommandConsumerStatsResponse) GetAvailablePermits() uint64

func (*CommandConsumerStatsResponse) GetBlockedConsumerOnUnackedMsgs 

func (m *CommandConsumerStatsResponse) GetBlockedConsumerOnUnackedMsgs() bool

func (*CommandConsumerStatsResponse) GetConnectedSince 

func (m *CommandConsumerStatsResponse) GetConnectedSince() string

func (*CommandConsumerStatsResponse) GetConsumerName 

func (m *CommandConsumerStatsResponse) GetConsumerName() string

func (*CommandConsumerStatsResponse) GetErrorCode 

func (m *CommandConsumerStatsResponse) GetErrorCode() ServerError

func (*CommandConsumerStatsResponse) GetErrorMessage 

func (m *CommandConsumerStatsResponse) GetErrorMessage() string

func (*CommandConsumerStatsResponse) GetMsgBacklog 

func (m *CommandConsumerStatsResponse) GetMsgBacklog() uint64

func (*CommandConsumerStatsResponse) GetMsgRateExpired 

func (m *CommandConsumerStatsResponse) GetMsgRateExpired() float64

func (*CommandConsumerStatsResponse) GetMsgRateOut 

func (m *CommandConsumerStatsResponse) GetMsgRateOut() float64

func (*CommandConsumerStatsResponse) GetMsgRateRedeliver 

func (m *CommandConsumerStatsResponse) GetMsgRateRedeliver() float64

func (*CommandConsumerStatsResponse) GetMsgThroughputOut 

func (m *CommandConsumerStatsResponse) GetMsgThroughputOut() float64

func (*CommandConsumerStatsResponse) GetRequestId 

func (m *CommandConsumerStatsResponse) GetRequestId() uint64

func (*CommandConsumerStatsResponse) GetType 

func (m *CommandConsumerStatsResponse) GetType() string

func (*CommandConsumerStatsResponse) GetUnackedMessages 

func (m *CommandConsumerStatsResponse) GetUnackedMessages() uint64

func (*CommandConsumerStatsResponse) ProtoMessage 

func (*CommandConsumerStatsResponse) ProtoMessage()

func (*CommandConsumerStatsResponse) Reset 

func (m *CommandConsumerStatsResponse) Reset()

func (*CommandConsumerStatsResponse) String 

func (m *CommandConsumerStatsResponse) String() string

func (*CommandConsumerStatsResponse) XXX_DiscardUnknown 

func (m *CommandConsumerStatsResponse) XXX_DiscardUnknown()

func (*CommandConsumerStatsResponse) XXX_Marshal 

func (m *CommandConsumerStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandConsumerStatsResponse) XXX_Merge 

func (m *CommandConsumerStatsResponse) XXX_Merge(src proto.Message)

func (*CommandConsumerStatsResponse) XXX_Size 

func (m *CommandConsumerStatsResponse) XXX_Size() int

func (*CommandConsumerStatsResponse) XXX_Unmarshal 

func (m *CommandConsumerStatsResponse) XXX_Unmarshal(b []byte) error

type CommandEndTxn 

type CommandEndTxn struct {
	RequestId            *uint64    `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64    `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64    `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	TxnAction            *TxnAction `protobuf:"varint,4,opt,name=txn_action,json=txnAction,enum=pulsar.proto.TxnAction" json:"txn_action,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CommandEndTxn) Descriptor 

func (*CommandEndTxn) Descriptor() ([]byte, []int)

func (*CommandEndTxn) GetRequestId 

func (m *CommandEndTxn) GetRequestId() uint64

func (*CommandEndTxn) GetTxnAction 

func (m *CommandEndTxn) GetTxnAction() TxnAction

func (*CommandEndTxn) GetTxnidLeastBits 

func (m *CommandEndTxn) GetTxnidLeastBits() uint64

func (*CommandEndTxn) GetTxnidMostBits 

func (m *CommandEndTxn) GetTxnidMostBits() uint64

func (*CommandEndTxn) ProtoMessage 

func (*CommandEndTxn) ProtoMessage()

func (*CommandEndTxn) Reset 

func (m *CommandEndTxn) Reset()

func (*CommandEndTxn) String 

func (m *CommandEndTxn) String() string

func (*CommandEndTxn) XXX_DiscardUnknown 

func (m *CommandEndTxn) XXX_DiscardUnknown()

func (*CommandEndTxn) XXX_Marshal 

func (m *CommandEndTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandEndTxn) XXX_Merge 

func (m *CommandEndTxn) XXX_Merge(src proto.Message)

func (*CommandEndTxn) XXX_Size 

func (m *CommandEndTxn) XXX_Size() int

func (*CommandEndTxn) XXX_Unmarshal 

func (m *CommandEndTxn) XXX_Unmarshal(b []byte) error

type CommandEndTxnOnPartition 

type CommandEndTxnOnPartition struct {
	RequestId            *uint64    `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64    `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64    `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Topic                *string    `protobuf:"bytes,4,opt,name=topic" json:"topic,omitempty"`
	TxnAction            *TxnAction `protobuf:"varint,5,opt,name=txn_action,json=txnAction,enum=pulsar.proto.TxnAction" json:"txn_action,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CommandEndTxnOnPartition) Descriptor 

func (*CommandEndTxnOnPartition) Descriptor() ([]byte, []int)

func (*CommandEndTxnOnPartition) GetRequestId 

func (m *CommandEndTxnOnPartition) GetRequestId() uint64

func (*CommandEndTxnOnPartition) GetTopic 

func (m *CommandEndTxnOnPartition) GetTopic() string

func (*CommandEndTxnOnPartition) GetTxnAction 

func (m *CommandEndTxnOnPartition) GetTxnAction() TxnAction

func (*CommandEndTxnOnPartition) GetTxnidLeastBits 

func (m *CommandEndTxnOnPartition) GetTxnidLeastBits() uint64

func (*CommandEndTxnOnPartition) GetTxnidMostBits 

func (m *CommandEndTxnOnPartition) GetTxnidMostBits() uint64

func (*CommandEndTxnOnPartition) ProtoMessage 

func (*CommandEndTxnOnPartition) ProtoMessage()

func (*CommandEndTxnOnPartition) Reset 

func (m *CommandEndTxnOnPartition) Reset()

func (*CommandEndTxnOnPartition) String 

func (m *CommandEndTxnOnPartition) String() string

func (*CommandEndTxnOnPartition) XXX_DiscardUnknown 

func (m *CommandEndTxnOnPartition) XXX_DiscardUnknown()

func (*CommandEndTxnOnPartition) XXX_Marshal 

func (m *CommandEndTxnOnPartition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandEndTxnOnPartition) XXX_Merge 

func (m *CommandEndTxnOnPartition) XXX_Merge(src proto.Message)

func (*CommandEndTxnOnPartition) XXX_Size 

func (m *CommandEndTxnOnPartition) XXX_Size() int

func (*CommandEndTxnOnPartition) XXX_Unmarshal 

func (m *CommandEndTxnOnPartition) XXX_Unmarshal(b []byte) error

type CommandEndTxnOnPartitionResponse 

type CommandEndTxnOnPartitionResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandEndTxnOnPartitionResponse) Descriptor 

func (*CommandEndTxnOnPartitionResponse) Descriptor() ([]byte, []int)

func (*CommandEndTxnOnPartitionResponse) GetError 

func (m *CommandEndTxnOnPartitionResponse) GetError() ServerError

func (*CommandEndTxnOnPartitionResponse) GetMessage 

func (m *CommandEndTxnOnPartitionResponse) GetMessage() string

func (*CommandEndTxnOnPartitionResponse) GetRequestId 

func (m *CommandEndTxnOnPartitionResponse) GetRequestId() uint64

func (*CommandEndTxnOnPartitionResponse) GetTxnidLeastBits 

func (m *CommandEndTxnOnPartitionResponse) GetTxnidLeastBits() uint64

func (*CommandEndTxnOnPartitionResponse) GetTxnidMostBits 

func (m *CommandEndTxnOnPartitionResponse) GetTxnidMostBits() uint64

func (*CommandEndTxnOnPartitionResponse) ProtoMessage 

func (*CommandEndTxnOnPartitionResponse) ProtoMessage()

func (*CommandEndTxnOnPartitionResponse) Reset 

func (m *CommandEndTxnOnPartitionResponse) Reset()

func (*CommandEndTxnOnPartitionResponse) String 

func (m *CommandEndTxnOnPartitionResponse) String() string

func (*CommandEndTxnOnPartitionResponse) XXX_DiscardUnknown 

func (m *CommandEndTxnOnPartitionResponse) XXX_DiscardUnknown()

func (*CommandEndTxnOnPartitionResponse) XXX_Marshal 

func (m *CommandEndTxnOnPartitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandEndTxnOnPartitionResponse) XXX_Merge 

func (m *CommandEndTxnOnPartitionResponse) XXX_Merge(src proto.Message)

func (*CommandEndTxnOnPartitionResponse) XXX_Size 

func (m *CommandEndTxnOnPartitionResponse) XXX_Size() int

func (*CommandEndTxnOnPartitionResponse) XXX_Unmarshal 

func (m *CommandEndTxnOnPartitionResponse) XXX_Unmarshal(b []byte) error

type CommandEndTxnOnSubscription 

type CommandEndTxnOnSubscription struct {
	RequestId            *uint64       `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64       `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64       `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Subscription         *Subscription `protobuf:"bytes,4,opt,name=subscription" json:"subscription,omitempty"`
	TxnAction            *TxnAction    `protobuf:"varint,5,opt,name=txn_action,json=txnAction,enum=pulsar.proto.TxnAction" json:"txn_action,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CommandEndTxnOnSubscription) Descriptor 

func (*CommandEndTxnOnSubscription) Descriptor() ([]byte, []int)

func (*CommandEndTxnOnSubscription) GetRequestId 

func (m *CommandEndTxnOnSubscription) GetRequestId() uint64

func (*CommandEndTxnOnSubscription) GetSubscription 

func (m *CommandEndTxnOnSubscription) GetSubscription() *Subscription

func (*CommandEndTxnOnSubscription) GetTxnAction 

func (m *CommandEndTxnOnSubscription) GetTxnAction() TxnAction

func (*CommandEndTxnOnSubscription) GetTxnidLeastBits 

func (m *CommandEndTxnOnSubscription) GetTxnidLeastBits() uint64

func (*CommandEndTxnOnSubscription) GetTxnidMostBits 

func (m *CommandEndTxnOnSubscription) GetTxnidMostBits() uint64

func (*CommandEndTxnOnSubscription) ProtoMessage 

func (*CommandEndTxnOnSubscription) ProtoMessage()

func (*CommandEndTxnOnSubscription) Reset 

func (m *CommandEndTxnOnSubscription) Reset()

func (*CommandEndTxnOnSubscription) String 

func (m *CommandEndTxnOnSubscription) String() string

func (*CommandEndTxnOnSubscription) XXX_DiscardUnknown 

func (m *CommandEndTxnOnSubscription) XXX_DiscardUnknown()

func (*CommandEndTxnOnSubscription) XXX_Marshal 

func (m *CommandEndTxnOnSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandEndTxnOnSubscription) XXX_Merge 

func (m *CommandEndTxnOnSubscription) XXX_Merge(src proto.Message)

func (*CommandEndTxnOnSubscription) XXX_Size 

func (m *CommandEndTxnOnSubscription) XXX_Size() int

func (*CommandEndTxnOnSubscription) XXX_Unmarshal 

func (m *CommandEndTxnOnSubscription) XXX_Unmarshal(b []byte) error

type CommandEndTxnOnSubscriptionResponse 

type CommandEndTxnOnSubscriptionResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandEndTxnOnSubscriptionResponse) Descriptor 

func (*CommandEndTxnOnSubscriptionResponse) Descriptor() ([]byte, []int)

func (*CommandEndTxnOnSubscriptionResponse) GetError 

func (m *CommandEndTxnOnSubscriptionResponse) GetError() ServerError

func (*CommandEndTxnOnSubscriptionResponse) GetMessage 

func (m *CommandEndTxnOnSubscriptionResponse) GetMessage() string

func (*CommandEndTxnOnSubscriptionResponse) GetRequestId 

func (m *CommandEndTxnOnSubscriptionResponse) GetRequestId() uint64

func (*CommandEndTxnOnSubscriptionResponse) GetTxnidLeastBits 

func (m *CommandEndTxnOnSubscriptionResponse) GetTxnidLeastBits() uint64

func (*CommandEndTxnOnSubscriptionResponse) GetTxnidMostBits 

func (m *CommandEndTxnOnSubscriptionResponse) GetTxnidMostBits() uint64

func (*CommandEndTxnOnSubscriptionResponse) ProtoMessage 

func (*CommandEndTxnOnSubscriptionResponse) ProtoMessage()

func (*CommandEndTxnOnSubscriptionResponse) Reset 

func (m *CommandEndTxnOnSubscriptionResponse) Reset()

func (*CommandEndTxnOnSubscriptionResponse) String 

func (m *CommandEndTxnOnSubscriptionResponse) String() string

func (*CommandEndTxnOnSubscriptionResponse) XXX_DiscardUnknown 

func (m *CommandEndTxnOnSubscriptionResponse) XXX_DiscardUnknown()

func (*CommandEndTxnOnSubscriptionResponse) XXX_Marshal 

func (m *CommandEndTxnOnSubscriptionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandEndTxnOnSubscriptionResponse) XXX_Merge 

func (m *CommandEndTxnOnSubscriptionResponse) XXX_Merge(src proto.Message)

func (*CommandEndTxnOnSubscriptionResponse) XXX_Size 

func (m *CommandEndTxnOnSubscriptionResponse) XXX_Size() int

func (*CommandEndTxnOnSubscriptionResponse) XXX_Unmarshal 

func (m *CommandEndTxnOnSubscriptionResponse) XXX_Unmarshal(b []byte) error

type CommandEndTxnResponse 

type CommandEndTxnResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandEndTxnResponse) Descriptor 

func (*CommandEndTxnResponse) Descriptor() ([]byte, []int)

func (*CommandEndTxnResponse) GetError 

func (m *CommandEndTxnResponse) GetError() ServerError

func (*CommandEndTxnResponse) GetMessage 

func (m *CommandEndTxnResponse) GetMessage() string

func (*CommandEndTxnResponse) GetRequestId 

func (m *CommandEndTxnResponse) GetRequestId() uint64

func (*CommandEndTxnResponse) GetTxnidLeastBits 

func (m *CommandEndTxnResponse) GetTxnidLeastBits() uint64

func (*CommandEndTxnResponse) GetTxnidMostBits 

func (m *CommandEndTxnResponse) GetTxnidMostBits() uint64

func (*CommandEndTxnResponse) ProtoMessage 

func (*CommandEndTxnResponse) ProtoMessage()

func (*CommandEndTxnResponse) Reset 

func (m *CommandEndTxnResponse) Reset()

func (*CommandEndTxnResponse) String 

func (m *CommandEndTxnResponse) String() string

func (*CommandEndTxnResponse) XXX_DiscardUnknown 

func (m *CommandEndTxnResponse) XXX_DiscardUnknown()

func (*CommandEndTxnResponse) XXX_Marshal 

func (m *CommandEndTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandEndTxnResponse) XXX_Merge 

func (m *CommandEndTxnResponse) XXX_Merge(src proto.Message)

func (*CommandEndTxnResponse) XXX_Size 

func (m *CommandEndTxnResponse) XXX_Size() int

func (*CommandEndTxnResponse) XXX_Unmarshal 

func (m *CommandEndTxnResponse) XXX_Unmarshal(b []byte) error

type CommandError 

type CommandError struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Error                *ServerError `protobuf:"varint,2,req,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,3,req,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandError) Descriptor 

func (*CommandError) Descriptor() ([]byte, []int)

func (*CommandError) GetError 

func (m *CommandError) GetError() ServerError

func (*CommandError) GetMessage 

func (m *CommandError) GetMessage() string

func (*CommandError) GetRequestId 

func (m *CommandError) GetRequestId() uint64

func (*CommandError) ProtoMessage 

func (*CommandError) ProtoMessage()

func (*CommandError) Reset 

func (m *CommandError) Reset()

func (*CommandError) String 

func (m *CommandError) String() string

func (*CommandError) XXX_DiscardUnknown 

func (m *CommandError) XXX_DiscardUnknown()

func (*CommandError) XXX_Marshal 

func (m *CommandError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandError) XXX_Merge 

func (m *CommandError) XXX_Merge(src proto.Message)

func (*CommandError) XXX_Size 

func (m *CommandError) XXX_Size() int

func (*CommandError) XXX_Unmarshal 

func (m *CommandError) XXX_Unmarshal(b []byte) error

type CommandFlow 

type CommandFlow struct {
	ConsumerId *uint64 `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	// Max number of messages to prefetch, in addition
	// of any number previously specified
	MessagePermits       *uint32  `protobuf:"varint,2,req,name=messagePermits" json:"messagePermits,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandFlow) Descriptor 

func (*CommandFlow) Descriptor() ([]byte, []int)

func (*CommandFlow) GetConsumerId 

func (m *CommandFlow) GetConsumerId() uint64

func (*CommandFlow) GetMessagePermits 

func (m *CommandFlow) GetMessagePermits() uint32

func (*CommandFlow) ProtoMessage 

func (*CommandFlow) ProtoMessage()

func (*CommandFlow) Reset 

func (m *CommandFlow) Reset()

func (*CommandFlow) String 

func (m *CommandFlow) String() string

func (*CommandFlow) XXX_DiscardUnknown 

func (m *CommandFlow) XXX_DiscardUnknown()

func (*CommandFlow) XXX_Marshal 

func (m *CommandFlow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandFlow) XXX_Merge 

func (m *CommandFlow) XXX_Merge(src proto.Message)

func (*CommandFlow) XXX_Size 

func (m *CommandFlow) XXX_Size() int

func (*CommandFlow) XXX_Unmarshal 

func (m *CommandFlow) XXX_Unmarshal(b []byte) error

type CommandGetLastMessageId 

type CommandGetLastMessageId struct {
	ConsumerId           *uint64  `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	RequestId            *uint64  `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandGetLastMessageId) Descriptor 

func (*CommandGetLastMessageId) Descriptor() ([]byte, []int)

func (*CommandGetLastMessageId) GetConsumerId 

func (m *CommandGetLastMessageId) GetConsumerId() uint64

func (*CommandGetLastMessageId) GetRequestId 

func (m *CommandGetLastMessageId) GetRequestId() uint64

func (*CommandGetLastMessageId) ProtoMessage 

func (*CommandGetLastMessageId) ProtoMessage()

func (*CommandGetLastMessageId) Reset 

func (m *CommandGetLastMessageId) Reset()

func (*CommandGetLastMessageId) String 

func (m *CommandGetLastMessageId) String() string

func (*CommandGetLastMessageId) XXX_DiscardUnknown 

func (m *CommandGetLastMessageId) XXX_DiscardUnknown()

func (*CommandGetLastMessageId) XXX_Marshal 

func (m *CommandGetLastMessageId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetLastMessageId) XXX_Merge 

func (m *CommandGetLastMessageId) XXX_Merge(src proto.Message)

func (*CommandGetLastMessageId) XXX_Size 

func (m *CommandGetLastMessageId) XXX_Size() int

func (*CommandGetLastMessageId) XXX_Unmarshal 

func (m *CommandGetLastMessageId) XXX_Unmarshal(b []byte) error

type CommandGetLastMessageIdResponse 

type CommandGetLastMessageIdResponse struct {
	LastMessageId        *MessageIdData `protobuf:"bytes,1,req,name=last_message_id,json=lastMessageId" json:"last_message_id,omitempty"`
	RequestId            *uint64        `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CommandGetLastMessageIdResponse) Descriptor 

func (*CommandGetLastMessageIdResponse) Descriptor() ([]byte, []int)

func (*CommandGetLastMessageIdResponse) GetLastMessageId 

func (m *CommandGetLastMessageIdResponse) GetLastMessageId() *MessageIdData

func (*CommandGetLastMessageIdResponse) GetRequestId 

func (m *CommandGetLastMessageIdResponse) GetRequestId() uint64

func (*CommandGetLastMessageIdResponse) ProtoMessage 

func (*CommandGetLastMessageIdResponse) ProtoMessage()

func (*CommandGetLastMessageIdResponse) Reset 

func (m *CommandGetLastMessageIdResponse) Reset()

func (*CommandGetLastMessageIdResponse) String 

func (m *CommandGetLastMessageIdResponse) String() string

func (*CommandGetLastMessageIdResponse) XXX_DiscardUnknown 

func (m *CommandGetLastMessageIdResponse) XXX_DiscardUnknown()

func (*CommandGetLastMessageIdResponse) XXX_Marshal 

func (m *CommandGetLastMessageIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetLastMessageIdResponse) XXX_Merge 

func (m *CommandGetLastMessageIdResponse) XXX_Merge(src proto.Message)

func (*CommandGetLastMessageIdResponse) XXX_Size 

func (m *CommandGetLastMessageIdResponse) XXX_Size() int

func (*CommandGetLastMessageIdResponse) XXX_Unmarshal 

func (m *CommandGetLastMessageIdResponse) XXX_Unmarshal(b []byte) error

type CommandGetOrCreateSchema 

type CommandGetOrCreateSchema struct {
	RequestId            *uint64  `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Topic                *string  `protobuf:"bytes,2,req,name=topic" json:"topic,omitempty"`
	Schema               *Schema  `protobuf:"bytes,3,req,name=schema" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandGetOrCreateSchema) Descriptor 

func (*CommandGetOrCreateSchema) Descriptor() ([]byte, []int)

func (*CommandGetOrCreateSchema) GetRequestId 

func (m *CommandGetOrCreateSchema) GetRequestId() uint64

func (*CommandGetOrCreateSchema) GetSchema 

func (m *CommandGetOrCreateSchema) GetSchema() *Schema

func (*CommandGetOrCreateSchema) GetTopic 

func (m *CommandGetOrCreateSchema) GetTopic() string

func (*CommandGetOrCreateSchema) ProtoMessage 

func (*CommandGetOrCreateSchema) ProtoMessage()

func (*CommandGetOrCreateSchema) Reset 

func (m *CommandGetOrCreateSchema) Reset()

func (*CommandGetOrCreateSchema) String 

func (m *CommandGetOrCreateSchema) String() string

func (*CommandGetOrCreateSchema) XXX_DiscardUnknown 

func (m *CommandGetOrCreateSchema) XXX_DiscardUnknown()

func (*CommandGetOrCreateSchema) XXX_Marshal 

func (m *CommandGetOrCreateSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetOrCreateSchema) XXX_Merge 

func (m *CommandGetOrCreateSchema) XXX_Merge(src proto.Message)

func (*CommandGetOrCreateSchema) XXX_Size 

func (m *CommandGetOrCreateSchema) XXX_Size() int

func (*CommandGetOrCreateSchema) XXX_Unmarshal 

func (m *CommandGetOrCreateSchema) XXX_Unmarshal(b []byte) error

type CommandGetOrCreateSchemaResponse 

type CommandGetOrCreateSchemaResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	ErrorCode            *ServerError `protobuf:"varint,2,opt,name=error_code,json=errorCode,enum=pulsar.proto.ServerError" json:"error_code,omitempty"`
	ErrorMessage         *string      `protobuf:"bytes,3,opt,name=error_message,json=errorMessage" json:"error_message,omitempty"`
	SchemaVersion        []byte       `protobuf:"bytes,4,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandGetOrCreateSchemaResponse) Descriptor 

func (*CommandGetOrCreateSchemaResponse) Descriptor() ([]byte, []int)

func (*CommandGetOrCreateSchemaResponse) GetErrorCode 

func (m *CommandGetOrCreateSchemaResponse) GetErrorCode() ServerError

func (*CommandGetOrCreateSchemaResponse) GetErrorMessage 

func (m *CommandGetOrCreateSchemaResponse) GetErrorMessage() string

func (*CommandGetOrCreateSchemaResponse) GetRequestId 

func (m *CommandGetOrCreateSchemaResponse) GetRequestId() uint64

func (*CommandGetOrCreateSchemaResponse) GetSchemaVersion 

func (m *CommandGetOrCreateSchemaResponse) GetSchemaVersion() []byte

func (*CommandGetOrCreateSchemaResponse) ProtoMessage 

func (*CommandGetOrCreateSchemaResponse) ProtoMessage()

func (*CommandGetOrCreateSchemaResponse) Reset 

func (m *CommandGetOrCreateSchemaResponse) Reset()

func (*CommandGetOrCreateSchemaResponse) String 

func (m *CommandGetOrCreateSchemaResponse) String() string

func (*CommandGetOrCreateSchemaResponse) XXX_DiscardUnknown 

func (m *CommandGetOrCreateSchemaResponse) XXX_DiscardUnknown()

func (*CommandGetOrCreateSchemaResponse) XXX_Marshal 

func (m *CommandGetOrCreateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetOrCreateSchemaResponse) XXX_Merge 

func (m *CommandGetOrCreateSchemaResponse) XXX_Merge(src proto.Message)

func (*CommandGetOrCreateSchemaResponse) XXX_Size 

func (m *CommandGetOrCreateSchemaResponse) XXX_Size() int

func (*CommandGetOrCreateSchemaResponse) XXX_Unmarshal 

func (m *CommandGetOrCreateSchemaResponse) XXX_Unmarshal(b []byte) error

type CommandGetSchema 

type CommandGetSchema struct {
	RequestId            *uint64  `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Topic                *string  `protobuf:"bytes,2,req,name=topic" json:"topic,omitempty"`
	SchemaVersion        []byte   `protobuf:"bytes,3,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandGetSchema) Descriptor 

func (*CommandGetSchema) Descriptor() ([]byte, []int)

func (*CommandGetSchema) GetRequestId 

func (m *CommandGetSchema) GetRequestId() uint64

func (*CommandGetSchema) GetSchemaVersion 

func (m *CommandGetSchema) GetSchemaVersion() []byte

func (*CommandGetSchema) GetTopic 

func (m *CommandGetSchema) GetTopic() string

func (*CommandGetSchema) ProtoMessage 

func (*CommandGetSchema) ProtoMessage()

func (*CommandGetSchema) Reset 

func (m *CommandGetSchema) Reset()

func (*CommandGetSchema) String 

func (m *CommandGetSchema) String() string

func (*CommandGetSchema) XXX_DiscardUnknown 

func (m *CommandGetSchema) XXX_DiscardUnknown()

func (*CommandGetSchema) XXX_Marshal 

func (m *CommandGetSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetSchema) XXX_Merge 

func (m *CommandGetSchema) XXX_Merge(src proto.Message)

func (*CommandGetSchema) XXX_Size 

func (m *CommandGetSchema) XXX_Size() int

func (*CommandGetSchema) XXX_Unmarshal 

func (m *CommandGetSchema) XXX_Unmarshal(b []byte) error

type CommandGetSchemaResponse 

type CommandGetSchemaResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	ErrorCode            *ServerError `protobuf:"varint,2,opt,name=error_code,json=errorCode,enum=pulsar.proto.ServerError" json:"error_code,omitempty"`
	ErrorMessage         *string      `protobuf:"bytes,3,opt,name=error_message,json=errorMessage" json:"error_message,omitempty"`
	Schema               *Schema      `protobuf:"bytes,4,opt,name=schema" json:"schema,omitempty"`
	SchemaVersion        []byte       `protobuf:"bytes,5,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandGetSchemaResponse) Descriptor 

func (*CommandGetSchemaResponse) Descriptor() ([]byte, []int)

func (*CommandGetSchemaResponse) GetErrorCode 

func (m *CommandGetSchemaResponse) GetErrorCode() ServerError

func (*CommandGetSchemaResponse) GetErrorMessage 

func (m *CommandGetSchemaResponse) GetErrorMessage() string

func (*CommandGetSchemaResponse) GetRequestId 

func (m *CommandGetSchemaResponse) GetRequestId() uint64

func (*CommandGetSchemaResponse) GetSchema 

func (m *CommandGetSchemaResponse) GetSchema() *Schema

func (*CommandGetSchemaResponse) GetSchemaVersion 

func (m *CommandGetSchemaResponse) GetSchemaVersion() []byte

func (*CommandGetSchemaResponse) ProtoMessage 

func (*CommandGetSchemaResponse) ProtoMessage()

func (*CommandGetSchemaResponse) Reset 

func (m *CommandGetSchemaResponse) Reset()

func (*CommandGetSchemaResponse) String 

func (m *CommandGetSchemaResponse) String() string

func (*CommandGetSchemaResponse) XXX_DiscardUnknown 

func (m *CommandGetSchemaResponse) XXX_DiscardUnknown()

func (*CommandGetSchemaResponse) XXX_Marshal 

func (m *CommandGetSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetSchemaResponse) XXX_Merge 

func (m *CommandGetSchemaResponse) XXX_Merge(src proto.Message)

func (*CommandGetSchemaResponse) XXX_Size 

func (m *CommandGetSchemaResponse) XXX_Size() int

func (*CommandGetSchemaResponse) XXX_Unmarshal 

func (m *CommandGetSchemaResponse) XXX_Unmarshal(b []byte) error

type CommandGetTopicsOfNamespace 

type CommandGetTopicsOfNamespace struct {
	RequestId            *uint64                           `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Namespace            *string                           `protobuf:"bytes,2,req,name=namespace" json:"namespace,omitempty"`
	Mode                 *CommandGetTopicsOfNamespace_Mode `protobuf:"varint,3,opt,name=mode,enum=pulsar.proto.CommandGetTopicsOfNamespace_Mode,def=0" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*CommandGetTopicsOfNamespace) Descriptor 

func (*CommandGetTopicsOfNamespace) Descriptor() ([]byte, []int)

func (*CommandGetTopicsOfNamespace) GetMode 

func (m *CommandGetTopicsOfNamespace) GetMode() CommandGetTopicsOfNamespace_Mode

func (*CommandGetTopicsOfNamespace) GetNamespace 

func (m *CommandGetTopicsOfNamespace) GetNamespace() string

func (*CommandGetTopicsOfNamespace) GetRequestId 

func (m *CommandGetTopicsOfNamespace) GetRequestId() uint64

func (*CommandGetTopicsOfNamespace) ProtoMessage 

func (*CommandGetTopicsOfNamespace) ProtoMessage()

func (*CommandGetTopicsOfNamespace) Reset 

func (m *CommandGetTopicsOfNamespace) Reset()

func (*CommandGetTopicsOfNamespace) String 

func (m *CommandGetTopicsOfNamespace) String() string

func (*CommandGetTopicsOfNamespace) XXX_DiscardUnknown 

func (m *CommandGetTopicsOfNamespace) XXX_DiscardUnknown()

func (*CommandGetTopicsOfNamespace) XXX_Marshal 

func (m *CommandGetTopicsOfNamespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetTopicsOfNamespace) XXX_Merge 

func (m *CommandGetTopicsOfNamespace) XXX_Merge(src proto.Message)

func (*CommandGetTopicsOfNamespace) XXX_Size 

func (m *CommandGetTopicsOfNamespace) XXX_Size() int

func (*CommandGetTopicsOfNamespace) XXX_Unmarshal 

func (m *CommandGetTopicsOfNamespace) XXX_Unmarshal(b []byte) error

type CommandGetTopicsOfNamespaceResponse 

type CommandGetTopicsOfNamespaceResponse struct {
	RequestId            *uint64  `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Topics               []string `protobuf:"bytes,2,rep,name=topics" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandGetTopicsOfNamespaceResponse) Descriptor 

func (*CommandGetTopicsOfNamespaceResponse) Descriptor() ([]byte, []int)

func (*CommandGetTopicsOfNamespaceResponse) GetRequestId 

func (m *CommandGetTopicsOfNamespaceResponse) GetRequestId() uint64

func (*CommandGetTopicsOfNamespaceResponse) GetTopics 

func (m *CommandGetTopicsOfNamespaceResponse) GetTopics() []string

func (*CommandGetTopicsOfNamespaceResponse) ProtoMessage 

func (*CommandGetTopicsOfNamespaceResponse) ProtoMessage()

func (*CommandGetTopicsOfNamespaceResponse) Reset 

func (m *CommandGetTopicsOfNamespaceResponse) Reset()

func (*CommandGetTopicsOfNamespaceResponse) String 

func (m *CommandGetTopicsOfNamespaceResponse) String() string

func (*CommandGetTopicsOfNamespaceResponse) XXX_DiscardUnknown 

func (m *CommandGetTopicsOfNamespaceResponse) XXX_DiscardUnknown()

func (*CommandGetTopicsOfNamespaceResponse) XXX_Marshal 

func (m *CommandGetTopicsOfNamespaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandGetTopicsOfNamespaceResponse) XXX_Merge 

func (m *CommandGetTopicsOfNamespaceResponse) XXX_Merge(src proto.Message)

func (*CommandGetTopicsOfNamespaceResponse) XXX_Size 

func (m *CommandGetTopicsOfNamespaceResponse) XXX_Size() int

func (*CommandGetTopicsOfNamespaceResponse) XXX_Unmarshal 

func (m *CommandGetTopicsOfNamespaceResponse) XXX_Unmarshal(b []byte) error

type CommandGetTopicsOfNamespace_Mode 

type CommandGetTopicsOfNamespace_Mode int32
const (
	CommandGetTopicsOfNamespace_PERSISTENT     CommandGetTopicsOfNamespace_Mode = 0
	CommandGetTopicsOfNamespace_NON_PERSISTENT CommandGetTopicsOfNamespace_Mode = 1
	CommandGetTopicsOfNamespace_ALL            CommandGetTopicsOfNamespace_Mode = 2
)
const Default_CommandGetTopicsOfNamespace_Mode CommandGetTopicsOfNamespace_Mode = CommandGetTopicsOfNamespace_PERSISTENT

func (CommandGetTopicsOfNamespace_Mode) Enum 

func (x CommandGetTopicsOfNamespace_Mode) Enum() *CommandGetTopicsOfNamespace_Mode

func (CommandGetTopicsOfNamespace_Mode) EnumDescriptor 

func (CommandGetTopicsOfNamespace_Mode) EnumDescriptor() ([]byte, []int)

func (CommandGetTopicsOfNamespace_Mode) String 

func (x CommandGetTopicsOfNamespace_Mode) String() string

func (*CommandGetTopicsOfNamespace_Mode) UnmarshalJSON 

func (x *CommandGetTopicsOfNamespace_Mode) UnmarshalJSON(data []byte) error

type CommandLookupTopic 

type CommandLookupTopic struct {
	Topic         *string `protobuf:"bytes,1,req,name=topic" json:"topic,omitempty"`
	RequestId     *uint64 `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Authoritative *bool   `protobuf:"varint,3,opt,name=authoritative,def=0" json:"authoritative,omitempty"`
	// TODO - Remove original_principal, original_auth_data, original_auth_method
	// Original principal that was verified by
	// a Pulsar proxy.
	OriginalPrincipal *string `protobuf:"bytes,4,opt,name=original_principal,json=originalPrincipal" json:"original_principal,omitempty"`
	// Original auth role and auth Method that was passed
	// to the proxy.
	OriginalAuthData     *string  `protobuf:"bytes,5,opt,name=original_auth_data,json=originalAuthData" json:"original_auth_data,omitempty"`
	OriginalAuthMethod   *string  `protobuf:"bytes,6,opt,name=original_auth_method,json=originalAuthMethod" json:"original_auth_method,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandLookupTopic) Descriptor 

func (*CommandLookupTopic) Descriptor() ([]byte, []int)

func (*CommandLookupTopic) GetAuthoritative 

func (m *CommandLookupTopic) GetAuthoritative() bool

func (*CommandLookupTopic) GetOriginalAuthData 

func (m *CommandLookupTopic) GetOriginalAuthData() string

func (*CommandLookupTopic) GetOriginalAuthMethod 

func (m *CommandLookupTopic) GetOriginalAuthMethod() string

func (*CommandLookupTopic) GetOriginalPrincipal 

func (m *CommandLookupTopic) GetOriginalPrincipal() string

func (*CommandLookupTopic) GetRequestId 

func (m *CommandLookupTopic) GetRequestId() uint64

func (*CommandLookupTopic) GetTopic 

func (m *CommandLookupTopic) GetTopic() string

func (*CommandLookupTopic) ProtoMessage 

func (*CommandLookupTopic) ProtoMessage()

func (*CommandLookupTopic) Reset 

func (m *CommandLookupTopic) Reset()

func (*CommandLookupTopic) String 

func (m *CommandLookupTopic) String() string

func (*CommandLookupTopic) XXX_DiscardUnknown 

func (m *CommandLookupTopic) XXX_DiscardUnknown()

func (*CommandLookupTopic) XXX_Marshal 

func (m *CommandLookupTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandLookupTopic) XXX_Merge 

func (m *CommandLookupTopic) XXX_Merge(src proto.Message)

func (*CommandLookupTopic) XXX_Size 

func (m *CommandLookupTopic) XXX_Size() int

func (*CommandLookupTopic) XXX_Unmarshal 

func (m *CommandLookupTopic) XXX_Unmarshal(b []byte) error

type CommandLookupTopicResponse 

type CommandLookupTopicResponse struct {
	BrokerServiceUrl    *string                                `protobuf:"bytes,1,opt,name=brokerServiceUrl" json:"brokerServiceUrl,omitempty"`
	BrokerServiceUrlTls *string                                `protobuf:"bytes,2,opt,name=brokerServiceUrlTls" json:"brokerServiceUrlTls,omitempty"`
	Response            *CommandLookupTopicResponse_LookupType `protobuf:"varint,3,opt,name=response,enum=pulsar.proto.CommandLookupTopicResponse_LookupType" json:"response,omitempty"`
	RequestId           *uint64                                `protobuf:"varint,4,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Authoritative       *bool                                  `protobuf:"varint,5,opt,name=authoritative,def=0" json:"authoritative,omitempty"`
	Error               *ServerError                           `protobuf:"varint,6,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message             *string                                `protobuf:"bytes,7,opt,name=message" json:"message,omitempty"`
	// If it's true, indicates to the client that it must
	// always connect through the service url after the
	// lookup has been completed.
	ProxyThroughServiceUrl *bool    `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*CommandLookupTopicResponse) Descriptor 

func (*CommandLookupTopicResponse) Descriptor() ([]byte, []int)

func (*CommandLookupTopicResponse) GetAuthoritative 

func (m *CommandLookupTopicResponse) GetAuthoritative() bool

func (*CommandLookupTopicResponse) GetBrokerServiceUrl 

func (m *CommandLookupTopicResponse) GetBrokerServiceUrl() string

func (*CommandLookupTopicResponse) GetBrokerServiceUrlTls 

func (m *CommandLookupTopicResponse) GetBrokerServiceUrlTls() string

func (*CommandLookupTopicResponse) GetError 

func (m *CommandLookupTopicResponse) GetError() ServerError

func (*CommandLookupTopicResponse) GetMessage 

func (m *CommandLookupTopicResponse) GetMessage() string

func (*CommandLookupTopicResponse) GetProxyThroughServiceUrl 

func (m *CommandLookupTopicResponse) GetProxyThroughServiceUrl() bool

func (*CommandLookupTopicResponse) GetRequestId 

func (m *CommandLookupTopicResponse) GetRequestId() uint64

func (*CommandLookupTopicResponse) GetResponse 

func (m *CommandLookupTopicResponse) GetResponse() CommandLookupTopicResponse_LookupType

func (*CommandLookupTopicResponse) ProtoMessage 

func (*CommandLookupTopicResponse) ProtoMessage()

func (*CommandLookupTopicResponse) Reset 

func (m *CommandLookupTopicResponse) Reset()

func (*CommandLookupTopicResponse) String 

func (m *CommandLookupTopicResponse) String() string

func (*CommandLookupTopicResponse) XXX_DiscardUnknown 

func (m *CommandLookupTopicResponse) XXX_DiscardUnknown()

func (*CommandLookupTopicResponse) XXX_Marshal 

func (m *CommandLookupTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandLookupTopicResponse) XXX_Merge 

func (m *CommandLookupTopicResponse) XXX_Merge(src proto.Message)

func (*CommandLookupTopicResponse) XXX_Size 

func (m *CommandLookupTopicResponse) XXX_Size() int

func (*CommandLookupTopicResponse) XXX_Unmarshal 

func (m *CommandLookupTopicResponse) XXX_Unmarshal(b []byte) error

type CommandLookupTopicResponse_LookupType 

type CommandLookupTopicResponse_LookupType int32
const (
	CommandLookupTopicResponse_Redirect CommandLookupTopicResponse_LookupType = 0
	CommandLookupTopicResponse_Connect  CommandLookupTopicResponse_LookupType = 1
	CommandLookupTopicResponse_Failed   CommandLookupTopicResponse_LookupType = 2
)

func (CommandLookupTopicResponse_LookupType) Enum 

func (x CommandLookupTopicResponse_LookupType) Enum() *CommandLookupTopicResponse_LookupType

func (CommandLookupTopicResponse_LookupType) EnumDescriptor 

func (CommandLookupTopicResponse_LookupType) EnumDescriptor() ([]byte, []int)

func (CommandLookupTopicResponse_LookupType) String 

func (x CommandLookupTopicResponse_LookupType) String() string

func (*CommandLookupTopicResponse_LookupType) UnmarshalJSON 

func (x *CommandLookupTopicResponse_LookupType) UnmarshalJSON(data []byte) error

type CommandMessage 

type CommandMessage struct {
	ConsumerId           *uint64        `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	MessageId            *MessageIdData `protobuf:"bytes,2,req,name=message_id,json=messageId" json:"message_id,omitempty"`
	RedeliveryCount      *uint32        `protobuf:"varint,3,opt,name=redelivery_count,json=redeliveryCount,def=0" json:"redelivery_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CommandMessage) Descriptor 

func (*CommandMessage) Descriptor() ([]byte, []int)

func (*CommandMessage) GetConsumerId 

func (m *CommandMessage) GetConsumerId() uint64

func (*CommandMessage) GetMessageId 

func (m *CommandMessage) GetMessageId() *MessageIdData

func (*CommandMessage) GetRedeliveryCount 

func (m *CommandMessage) GetRedeliveryCount() uint32

func (*CommandMessage) ProtoMessage 

func (*CommandMessage) ProtoMessage()

func (*CommandMessage) Reset 

func (m *CommandMessage) Reset()

func (*CommandMessage) String 

func (m *CommandMessage) String() string

func (*CommandMessage) XXX_DiscardUnknown 

func (m *CommandMessage) XXX_DiscardUnknown()

func (*CommandMessage) XXX_Marshal 

func (m *CommandMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandMessage) XXX_Merge 

func (m *CommandMessage) XXX_Merge(src proto.Message)

func (*CommandMessage) XXX_Size 

func (m *CommandMessage) XXX_Size() int

func (*CommandMessage) XXX_Unmarshal 

func (m *CommandMessage) XXX_Unmarshal(b []byte) error

type CommandNewTxn 

type CommandNewTxn struct {
	RequestId            *uint64  `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnTtlSeconds        *uint64  `protobuf:"varint,2,opt,name=txn_ttl_seconds,json=txnTtlSeconds,def=0" json:"txn_ttl_seconds,omitempty"`
	TcId                 *uint64  `protobuf:"varint,3,opt,name=tc_id,json=tcId,def=0" json:"tc_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandNewTxn) Descriptor 

func (*CommandNewTxn) Descriptor() ([]byte, []int)

func (*CommandNewTxn) GetRequestId 

func (m *CommandNewTxn) GetRequestId() uint64

func (*CommandNewTxn) GetTcId 

func (m *CommandNewTxn) GetTcId() uint64

func (*CommandNewTxn) GetTxnTtlSeconds 

func (m *CommandNewTxn) GetTxnTtlSeconds() uint64

func (*CommandNewTxn) ProtoMessage 

func (*CommandNewTxn) ProtoMessage()

func (*CommandNewTxn) Reset 

func (m *CommandNewTxn) Reset()

func (*CommandNewTxn) String 

func (m *CommandNewTxn) String() string

func (*CommandNewTxn) XXX_DiscardUnknown 

func (m *CommandNewTxn) XXX_DiscardUnknown()

func (*CommandNewTxn) XXX_Marshal 

func (m *CommandNewTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandNewTxn) XXX_Merge 

func (m *CommandNewTxn) XXX_Merge(src proto.Message)

func (*CommandNewTxn) XXX_Size 

func (m *CommandNewTxn) XXX_Size() int

func (*CommandNewTxn) XXX_Unmarshal 

func (m *CommandNewTxn) XXX_Unmarshal(b []byte) error

type CommandNewTxnResponse 

type CommandNewTxnResponse struct {
	RequestId            *uint64      `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	TxnidLeastBits       *uint64      `protobuf:"varint,2,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits        *uint64      `protobuf:"varint,3,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	Error                *ServerError `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandNewTxnResponse) Descriptor 

func (*CommandNewTxnResponse) Descriptor() ([]byte, []int)

func (*CommandNewTxnResponse) GetError 

func (m *CommandNewTxnResponse) GetError() ServerError

func (*CommandNewTxnResponse) GetMessage 

func (m *CommandNewTxnResponse) GetMessage() string

func (*CommandNewTxnResponse) GetRequestId 

func (m *CommandNewTxnResponse) GetRequestId() uint64

func (*CommandNewTxnResponse) GetTxnidLeastBits 

func (m *CommandNewTxnResponse) GetTxnidLeastBits() uint64

func (*CommandNewTxnResponse) GetTxnidMostBits 

func (m *CommandNewTxnResponse) GetTxnidMostBits() uint64

func (*CommandNewTxnResponse) ProtoMessage 

func (*CommandNewTxnResponse) ProtoMessage()

func (*CommandNewTxnResponse) Reset 

func (m *CommandNewTxnResponse) Reset()

func (*CommandNewTxnResponse) String 

func (m *CommandNewTxnResponse) String() string

func (*CommandNewTxnResponse) XXX_DiscardUnknown 

func (m *CommandNewTxnResponse) XXX_DiscardUnknown()

func (*CommandNewTxnResponse) XXX_Marshal 

func (m *CommandNewTxnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandNewTxnResponse) XXX_Merge 

func (m *CommandNewTxnResponse) XXX_Merge(src proto.Message)

func (*CommandNewTxnResponse) XXX_Size 

func (m *CommandNewTxnResponse) XXX_Size() int

func (*CommandNewTxnResponse) XXX_Unmarshal 

func (m *CommandNewTxnResponse) XXX_Unmarshal(b []byte) error

type CommandPartitionedTopicMetadata 

type CommandPartitionedTopicMetadata struct {
	Topic     *string `protobuf:"bytes,1,req,name=topic" json:"topic,omitempty"`
	RequestId *uint64 `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	// TODO - Remove original_principal, original_auth_data, original_auth_method
	// Original principal that was verified by
	// a Pulsar proxy.
	OriginalPrincipal *string `protobuf:"bytes,3,opt,name=original_principal,json=originalPrincipal" json:"original_principal,omitempty"`
	// Original auth role and auth Method that was passed
	// to the proxy.
	OriginalAuthData     *string  `protobuf:"bytes,4,opt,name=original_auth_data,json=originalAuthData" json:"original_auth_data,omitempty"`
	OriginalAuthMethod   *string  `protobuf:"bytes,5,opt,name=original_auth_method,json=originalAuthMethod" json:"original_auth_method,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandPartitionedTopicMetadata) Descriptor 

func (*CommandPartitionedTopicMetadata) Descriptor() ([]byte, []int)

func (*CommandPartitionedTopicMetadata) GetOriginalAuthData 

func (m *CommandPartitionedTopicMetadata) GetOriginalAuthData() string

func (*CommandPartitionedTopicMetadata) GetOriginalAuthMethod 

func (m *CommandPartitionedTopicMetadata) GetOriginalAuthMethod() string

func (*CommandPartitionedTopicMetadata) GetOriginalPrincipal 

func (m *CommandPartitionedTopicMetadata) GetOriginalPrincipal() string

func (*CommandPartitionedTopicMetadata) GetRequestId 

func (m *CommandPartitionedTopicMetadata) GetRequestId() uint64

func (*CommandPartitionedTopicMetadata) GetTopic 

func (m *CommandPartitionedTopicMetadata) GetTopic() string

func (*CommandPartitionedTopicMetadata) ProtoMessage 

func (*CommandPartitionedTopicMetadata) ProtoMessage()

func (*CommandPartitionedTopicMetadata) Reset 

func (m *CommandPartitionedTopicMetadata) Reset()

func (*CommandPartitionedTopicMetadata) String 

func (m *CommandPartitionedTopicMetadata) String() string

func (*CommandPartitionedTopicMetadata) XXX_DiscardUnknown 

func (m *CommandPartitionedTopicMetadata) XXX_DiscardUnknown()

func (*CommandPartitionedTopicMetadata) XXX_Marshal 

func (m *CommandPartitionedTopicMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandPartitionedTopicMetadata) XXX_Merge 

func (m *CommandPartitionedTopicMetadata) XXX_Merge(src proto.Message)

func (*CommandPartitionedTopicMetadata) XXX_Size 

func (m *CommandPartitionedTopicMetadata) XXX_Size() int

func (*CommandPartitionedTopicMetadata) XXX_Unmarshal 

func (m *CommandPartitionedTopicMetadata) XXX_Unmarshal(b []byte) error

type CommandPartitionedTopicMetadataResponse 

type CommandPartitionedTopicMetadataResponse struct {
	Partitions           *uint32                                             `protobuf:"varint,1,opt,name=partitions" json:"partitions,omitempty"`
	RequestId            *uint64                                             `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Response             *CommandPartitionedTopicMetadataResponse_LookupType `` /* 132-byte string literal not displayed */
	Error                *ServerError                                        `protobuf:"varint,4,opt,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string                                             `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                            `json:"-"`
	XXX_unrecognized     []byte                                              `json:"-"`
	XXX_sizecache        int32                                               `json:"-"`
}

func (*CommandPartitionedTopicMetadataResponse) Descriptor 

func (*CommandPartitionedTopicMetadataResponse) Descriptor() ([]byte, []int)

func (*CommandPartitionedTopicMetadataResponse) GetError 

func (m *CommandPartitionedTopicMetadataResponse) GetError() ServerError

func (*CommandPartitionedTopicMetadataResponse) GetMessage 

func (m *CommandPartitionedTopicMetadataResponse) GetMessage() string

func (*CommandPartitionedTopicMetadataResponse) GetPartitions 

func (m *CommandPartitionedTopicMetadataResponse) GetPartitions() uint32

func (*CommandPartitionedTopicMetadataResponse) GetRequestId 

func (m *CommandPartitionedTopicMetadataResponse) GetRequestId() uint64

func (*CommandPartitionedTopicMetadataResponse) GetResponse 

func (m *CommandPartitionedTopicMetadataResponse) GetResponse() CommandPartitionedTopicMetadataResponse_LookupType

func (*CommandPartitionedTopicMetadataResponse) ProtoMessage 

func (*CommandPartitionedTopicMetadataResponse) ProtoMessage()

func (*CommandPartitionedTopicMetadataResponse) Reset 

func (m *CommandPartitionedTopicMetadataResponse) Reset()

func (*CommandPartitionedTopicMetadataResponse) String 

func (m *CommandPartitionedTopicMetadataResponse) String() string

func (*CommandPartitionedTopicMetadataResponse) XXX_DiscardUnknown 

func (m *CommandPartitionedTopicMetadataResponse) XXX_DiscardUnknown()

func (*CommandPartitionedTopicMetadataResponse) XXX_Marshal 

func (m *CommandPartitionedTopicMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandPartitionedTopicMetadataResponse) XXX_Merge 

func (m *CommandPartitionedTopicMetadataResponse) XXX_Merge(src proto.Message)

func (*CommandPartitionedTopicMetadataResponse) XXX_Size 

func (m *CommandPartitionedTopicMetadataResponse) XXX_Size() int

func (*CommandPartitionedTopicMetadataResponse) XXX_Unmarshal 

func (m *CommandPartitionedTopicMetadataResponse) XXX_Unmarshal(b []byte) error

type CommandPartitionedTopicMetadataResponse_LookupType 

type CommandPartitionedTopicMetadataResponse_LookupType int32
const (
	CommandPartitionedTopicMetadataResponse_Success CommandPartitionedTopicMetadataResponse_LookupType = 0
	CommandPartitionedTopicMetadataResponse_Failed  CommandPartitionedTopicMetadataResponse_LookupType = 1
)

func (CommandPartitionedTopicMetadataResponse_LookupType) Enum 

func (x CommandPartitionedTopicMetadataResponse_LookupType) Enum() *CommandPartitionedTopicMetadataResponse_LookupType

func (CommandPartitionedTopicMetadataResponse_LookupType) EnumDescriptor 

func (CommandPartitionedTopicMetadataResponse_LookupType) EnumDescriptor() ([]byte, []int)

func (CommandPartitionedTopicMetadataResponse_LookupType) String 

func (x CommandPartitionedTopicMetadataResponse_LookupType) String() string

func (*CommandPartitionedTopicMetadataResponse_LookupType) UnmarshalJSON 

func (x *CommandPartitionedTopicMetadataResponse_LookupType) UnmarshalJSON(data []byte) error

type CommandPing 

type CommandPing struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Commands to probe the state of connection. When either client or broker doesn't receive commands for certain amount of time, they will send a Ping probe.

func (*CommandPing) Descriptor 

func (*CommandPing) Descriptor() ([]byte, []int)

func (*CommandPing) ProtoMessage 

func (*CommandPing) ProtoMessage()

func (*CommandPing) Reset 

func (m *CommandPing) Reset()

func (*CommandPing) String 

func (m *CommandPing) String() string

func (*CommandPing) XXX_DiscardUnknown 

func (m *CommandPing) XXX_DiscardUnknown()

func (*CommandPing) XXX_Marshal 

func (m *CommandPing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandPing) XXX_Merge 

func (m *CommandPing) XXX_Merge(src proto.Message)

func (*CommandPing) XXX_Size 

func (m *CommandPing) XXX_Size() int

func (*CommandPing) XXX_Unmarshal 

func (m *CommandPing) XXX_Unmarshal(b []byte) error

type CommandPong 

type CommandPong struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandPong) Descriptor 

func (*CommandPong) Descriptor() ([]byte, []int)

func (*CommandPong) ProtoMessage 

func (*CommandPong) ProtoMessage()

func (*CommandPong) Reset 

func (m *CommandPong) Reset()

func (*CommandPong) String 

func (m *CommandPong) String() string

func (*CommandPong) XXX_DiscardUnknown 

func (m *CommandPong) XXX_DiscardUnknown()

func (*CommandPong) XXX_Marshal 

func (m *CommandPong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandPong) XXX_Merge 

func (m *CommandPong) XXX_Merge(src proto.Message)

func (*CommandPong) XXX_Size 

func (m *CommandPong) XXX_Size() int

func (*CommandPong) XXX_Unmarshal 

func (m *CommandPong) XXX_Unmarshal(b []byte) error

type CommandProducer 

type CommandProducer struct {
	Topic      *string `protobuf:"bytes,1,req,name=topic" json:"topic,omitempty"`
	ProducerId *uint64 `protobuf:"varint,2,req,name=producer_id,json=producerId" json:"producer_id,omitempty"`
	RequestId  *uint64 `protobuf:"varint,3,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	/// If a producer name is specified, the name will be used,
	/// otherwise the broker will generate a unique name
	ProducerName *string `protobuf:"bytes,4,opt,name=producer_name,json=producerName" json:"producer_name,omitempty"`
	Encrypted    *bool   `protobuf:"varint,5,opt,name=encrypted,def=0" json:"encrypted,omitempty"`
	/// Add optional metadata key=value to this producer
	Metadata []*KeyValue `protobuf:"bytes,6,rep,name=metadata" json:"metadata,omitempty"`
	Schema   *Schema     `protobuf:"bytes,7,opt,name=schema" json:"schema,omitempty"`
	// If producer reconnect to broker, the epoch of this producer will +1
	Epoch *uint64 `protobuf:"varint,8,opt,name=epoch,def=0" json:"epoch,omitempty"`
	// Indicate the name of the producer is generated or user provided
	// Use default true here is in order to be forward compatible with the client
	UserProvidedProducerName *bool    `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{} `json:"-"`
	XXX_unrecognized         []byte   `json:"-"`
	XXX_sizecache            int32    `json:"-"`
}

/ Create a new Producer on a topic, assigning the given producer_id, / all messages sent with this producer_id will be persisted on the topic

func (*CommandProducer) Descriptor 

func (*CommandProducer) Descriptor() ([]byte, []int)

func (*CommandProducer) GetEncrypted 

func (m *CommandProducer) GetEncrypted() bool

func (*CommandProducer) GetEpoch 

func (m *CommandProducer) GetEpoch() uint64

func (*CommandProducer) GetMetadata 

func (m *CommandProducer) GetMetadata() []*KeyValue

func (*CommandProducer) GetProducerId 

func (m *CommandProducer) GetProducerId() uint64

func (*CommandProducer) GetProducerName 

func (m *CommandProducer) GetProducerName() string

func (*CommandProducer) GetRequestId 

func (m *CommandProducer) GetRequestId() uint64

func (*CommandProducer) GetSchema 

func (m *CommandProducer) GetSchema() *Schema

func (*CommandProducer) GetTopic 

func (m *CommandProducer) GetTopic() string

func (*CommandProducer) GetUserProvidedProducerName 

func (m *CommandProducer) GetUserProvidedProducerName() bool

func (*CommandProducer) ProtoMessage 

func (*CommandProducer) ProtoMessage()

func (*CommandProducer) Reset 

func (m *CommandProducer) Reset()

func (*CommandProducer) String 

func (m *CommandProducer) String() string

func (*CommandProducer) XXX_DiscardUnknown 

func (m *CommandProducer) XXX_DiscardUnknown()

func (*CommandProducer) XXX_Marshal 

func (m *CommandProducer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandProducer) XXX_Merge 

func (m *CommandProducer) XXX_Merge(src proto.Message)

func (*CommandProducer) XXX_Size 

func (m *CommandProducer) XXX_Size() int

func (*CommandProducer) XXX_Unmarshal 

func (m *CommandProducer) XXX_Unmarshal(b []byte) error

type CommandProducerSuccess 

type CommandProducerSuccess struct {
	RequestId    *uint64 `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	ProducerName *string `protobuf:"bytes,2,req,name=producer_name,json=producerName" json:"producer_name,omitempty"`
	// The last sequence id that was stored by this producer in the previous session
	// This will only be meaningful if deduplication has been enabled.
	LastSequenceId       *int64   `protobuf:"varint,3,opt,name=last_sequence_id,json=lastSequenceId,def=-1" json:"last_sequence_id,omitempty"`
	SchemaVersion        []byte   `protobuf:"bytes,4,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

/ Response from CommandProducer

func (*CommandProducerSuccess) Descriptor 

func (*CommandProducerSuccess) Descriptor() ([]byte, []int)

func (*CommandProducerSuccess) GetLastSequenceId 

func (m *CommandProducerSuccess) GetLastSequenceId() int64

func (*CommandProducerSuccess) GetProducerName 

func (m *CommandProducerSuccess) GetProducerName() string

func (*CommandProducerSuccess) GetRequestId 

func (m *CommandProducerSuccess) GetRequestId() uint64

func (*CommandProducerSuccess) GetSchemaVersion 

func (m *CommandProducerSuccess) GetSchemaVersion() []byte

func (*CommandProducerSuccess) ProtoMessage 

func (*CommandProducerSuccess) ProtoMessage()

func (*CommandProducerSuccess) Reset 

func (m *CommandProducerSuccess) Reset()

func (*CommandProducerSuccess) String 

func (m *CommandProducerSuccess) String() string

func (*CommandProducerSuccess) XXX_DiscardUnknown 

func (m *CommandProducerSuccess) XXX_DiscardUnknown()

func (*CommandProducerSuccess) XXX_Marshal 

func (m *CommandProducerSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandProducerSuccess) XXX_Merge 

func (m *CommandProducerSuccess) XXX_Merge(src proto.Message)

func (*CommandProducerSuccess) XXX_Size 

func (m *CommandProducerSuccess) XXX_Size() int

func (*CommandProducerSuccess) XXX_Unmarshal 

func (m *CommandProducerSuccess) XXX_Unmarshal(b []byte) error

type CommandReachedEndOfTopic 

type CommandReachedEndOfTopic struct {
	ConsumerId           *uint64  `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message sent by broker to client when a topic has been forcefully terminated and there are no more messages left to consume

func (*CommandReachedEndOfTopic) Descriptor 

func (*CommandReachedEndOfTopic) Descriptor() ([]byte, []int)

func (*CommandReachedEndOfTopic) GetConsumerId 

func (m *CommandReachedEndOfTopic) GetConsumerId() uint64

func (*CommandReachedEndOfTopic) ProtoMessage 

func (*CommandReachedEndOfTopic) ProtoMessage()

func (*CommandReachedEndOfTopic) Reset 

func (m *CommandReachedEndOfTopic) Reset()

func (*CommandReachedEndOfTopic) String 

func (m *CommandReachedEndOfTopic) String() string

func (*CommandReachedEndOfTopic) XXX_DiscardUnknown 

func (m *CommandReachedEndOfTopic) XXX_DiscardUnknown()

func (*CommandReachedEndOfTopic) XXX_Marshal 

func (m *CommandReachedEndOfTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandReachedEndOfTopic) XXX_Merge 

func (m *CommandReachedEndOfTopic) XXX_Merge(src proto.Message)

func (*CommandReachedEndOfTopic) XXX_Size 

func (m *CommandReachedEndOfTopic) XXX_Size() int

func (*CommandReachedEndOfTopic) XXX_Unmarshal 

func (m *CommandReachedEndOfTopic) XXX_Unmarshal(b []byte) error

type CommandRedeliverUnacknowledgedMessages 

type CommandRedeliverUnacknowledgedMessages struct {
	ConsumerId           *uint64          `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	MessageIds           []*MessageIdData `protobuf:"bytes,2,rep,name=message_ids,json=messageIds" json:"message_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CommandRedeliverUnacknowledgedMessages) Descriptor 

func (*CommandRedeliverUnacknowledgedMessages) Descriptor() ([]byte, []int)

func (*CommandRedeliverUnacknowledgedMessages) GetConsumerId 

func (m *CommandRedeliverUnacknowledgedMessages) GetConsumerId() uint64

func (*CommandRedeliverUnacknowledgedMessages) GetMessageIds 

func (m *CommandRedeliverUnacknowledgedMessages) GetMessageIds() []*MessageIdData

func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage 

func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage()

func (*CommandRedeliverUnacknowledgedMessages) Reset 

func (m *CommandRedeliverUnacknowledgedMessages) Reset()

func (*CommandRedeliverUnacknowledgedMessages) String 

func (m *CommandRedeliverUnacknowledgedMessages) String() string

func (*CommandRedeliverUnacknowledgedMessages) XXX_DiscardUnknown 

func (m *CommandRedeliverUnacknowledgedMessages) XXX_DiscardUnknown()

func (*CommandRedeliverUnacknowledgedMessages) XXX_Marshal 

func (m *CommandRedeliverUnacknowledgedMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandRedeliverUnacknowledgedMessages) XXX_Merge 

func (m *CommandRedeliverUnacknowledgedMessages) XXX_Merge(src proto.Message)

func (*CommandRedeliverUnacknowledgedMessages) XXX_Size 

func (m *CommandRedeliverUnacknowledgedMessages) XXX_Size() int

func (*CommandRedeliverUnacknowledgedMessages) XXX_Unmarshal 

func (m *CommandRedeliverUnacknowledgedMessages) XXX_Unmarshal(b []byte) error

type CommandSeek 

type CommandSeek struct {
	ConsumerId           *uint64        `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	RequestId            *uint64        `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	MessageId            *MessageIdData `protobuf:"bytes,3,opt,name=message_id,json=messageId" json:"message_id,omitempty"`
	MessagePublishTime   *uint64        `protobuf:"varint,4,opt,name=message_publish_time,json=messagePublishTime" json:"message_publish_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Reset an existing consumer to a particular message id

func (*CommandSeek) Descriptor 

func (*CommandSeek) Descriptor() ([]byte, []int)

func (*CommandSeek) GetConsumerId 

func (m *CommandSeek) GetConsumerId() uint64

func (*CommandSeek) GetMessageId 

func (m *CommandSeek) GetMessageId() *MessageIdData

func (*CommandSeek) GetMessagePublishTime 

func (m *CommandSeek) GetMessagePublishTime() uint64

func (*CommandSeek) GetRequestId 

func (m *CommandSeek) GetRequestId() uint64

func (*CommandSeek) ProtoMessage 

func (*CommandSeek) ProtoMessage()

func (*CommandSeek) Reset 

func (m *CommandSeek) Reset()

func (*CommandSeek) String 

func (m *CommandSeek) String() string

func (*CommandSeek) XXX_DiscardUnknown 

func (m *CommandSeek) XXX_DiscardUnknown()

func (*CommandSeek) XXX_Marshal 

func (m *CommandSeek) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSeek) XXX_Merge 

func (m *CommandSeek) XXX_Merge(src proto.Message)

func (*CommandSeek) XXX_Size 

func (m *CommandSeek) XXX_Size() int

func (*CommandSeek) XXX_Unmarshal 

func (m *CommandSeek) XXX_Unmarshal(b []byte) error

type CommandSend 

type CommandSend struct {
	ProducerId     *uint64 `protobuf:"varint,1,req,name=producer_id,json=producerId" json:"producer_id,omitempty"`
	SequenceId     *uint64 `protobuf:"varint,2,req,name=sequence_id,json=sequenceId" json:"sequence_id,omitempty"`
	NumMessages    *int32  `protobuf:"varint,3,opt,name=num_messages,json=numMessages,def=1" json:"num_messages,omitempty"`
	TxnidLeastBits *uint64 `protobuf:"varint,4,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits  *uint64 `protobuf:"varint,5,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	/// Add highest sequence id to support batch message with external sequence id
	HighestSequenceId    *uint64  `protobuf:"varint,6,opt,name=highest_sequence_id,json=highestSequenceId,def=0" json:"highest_sequence_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandSend) Descriptor 

func (*CommandSend) Descriptor() ([]byte, []int)

func (*CommandSend) GetHighestSequenceId 

func (m *CommandSend) GetHighestSequenceId() uint64

func (*CommandSend) GetNumMessages 

func (m *CommandSend) GetNumMessages() int32

func (*CommandSend) GetProducerId 

func (m *CommandSend) GetProducerId() uint64

func (*CommandSend) GetSequenceId 

func (m *CommandSend) GetSequenceId() uint64

func (*CommandSend) GetTxnidLeastBits 

func (m *CommandSend) GetTxnidLeastBits() uint64

func (*CommandSend) GetTxnidMostBits 

func (m *CommandSend) GetTxnidMostBits() uint64

func (*CommandSend) ProtoMessage 

func (*CommandSend) ProtoMessage()

func (*CommandSend) Reset 

func (m *CommandSend) Reset()

func (*CommandSend) String 

func (m *CommandSend) String() string

func (*CommandSend) XXX_DiscardUnknown 

func (m *CommandSend) XXX_DiscardUnknown()

func (*CommandSend) XXX_Marshal 

func (m *CommandSend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSend) XXX_Merge 

func (m *CommandSend) XXX_Merge(src proto.Message)

func (*CommandSend) XXX_Size 

func (m *CommandSend) XXX_Size() int

func (*CommandSend) XXX_Unmarshal 

func (m *CommandSend) XXX_Unmarshal(b []byte) error

type CommandSendError 

type CommandSendError struct {
	ProducerId           *uint64      `protobuf:"varint,1,req,name=producer_id,json=producerId" json:"producer_id,omitempty"`
	SequenceId           *uint64      `protobuf:"varint,2,req,name=sequence_id,json=sequenceId" json:"sequence_id,omitempty"`
	Error                *ServerError `protobuf:"varint,3,req,name=error,enum=pulsar.proto.ServerError" json:"error,omitempty"`
	Message              *string      `protobuf:"bytes,4,req,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommandSendError) Descriptor 

func (*CommandSendError) Descriptor() ([]byte, []int)

func (*CommandSendError) GetError 

func (m *CommandSendError) GetError() ServerError

func (*CommandSendError) GetMessage 

func (m *CommandSendError) GetMessage() string

func (*CommandSendError) GetProducerId 

func (m *CommandSendError) GetProducerId() uint64

func (*CommandSendError) GetSequenceId 

func (m *CommandSendError) GetSequenceId() uint64

func (*CommandSendError) ProtoMessage 

func (*CommandSendError) ProtoMessage()

func (*CommandSendError) Reset 

func (m *CommandSendError) Reset()

func (*CommandSendError) String 

func (m *CommandSendError) String() string

func (*CommandSendError) XXX_DiscardUnknown 

func (m *CommandSendError) XXX_DiscardUnknown()

func (*CommandSendError) XXX_Marshal 

func (m *CommandSendError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSendError) XXX_Merge 

func (m *CommandSendError) XXX_Merge(src proto.Message)

func (*CommandSendError) XXX_Size 

func (m *CommandSendError) XXX_Size() int

func (*CommandSendError) XXX_Unmarshal 

func (m *CommandSendError) XXX_Unmarshal(b []byte) error

type CommandSendReceipt 

type CommandSendReceipt struct {
	ProducerId           *uint64        `protobuf:"varint,1,req,name=producer_id,json=producerId" json:"producer_id,omitempty"`
	SequenceId           *uint64        `protobuf:"varint,2,req,name=sequence_id,json=sequenceId" json:"sequence_id,omitempty"`
	MessageId            *MessageIdData `protobuf:"bytes,3,opt,name=message_id,json=messageId" json:"message_id,omitempty"`
	HighestSequenceId    *uint64        `protobuf:"varint,4,opt,name=highest_sequence_id,json=highestSequenceId,def=0" json:"highest_sequence_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CommandSendReceipt) Descriptor 

func (*CommandSendReceipt) Descriptor() ([]byte, []int)

func (*CommandSendReceipt) GetHighestSequenceId 

func (m *CommandSendReceipt) GetHighestSequenceId() uint64

func (*CommandSendReceipt) GetMessageId 

func (m *CommandSendReceipt) GetMessageId() *MessageIdData

func (*CommandSendReceipt) GetProducerId 

func (m *CommandSendReceipt) GetProducerId() uint64

func (*CommandSendReceipt) GetSequenceId 

func (m *CommandSendReceipt) GetSequenceId() uint64

func (*CommandSendReceipt) ProtoMessage 

func (*CommandSendReceipt) ProtoMessage()

func (*CommandSendReceipt) Reset 

func (m *CommandSendReceipt) Reset()

func (*CommandSendReceipt) String 

func (m *CommandSendReceipt) String() string

func (*CommandSendReceipt) XXX_DiscardUnknown 

func (m *CommandSendReceipt) XXX_DiscardUnknown()

func (*CommandSendReceipt) XXX_Marshal 

func (m *CommandSendReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSendReceipt) XXX_Merge 

func (m *CommandSendReceipt) XXX_Merge(src proto.Message)

func (*CommandSendReceipt) XXX_Size 

func (m *CommandSendReceipt) XXX_Size() int

func (*CommandSendReceipt) XXX_Unmarshal 

func (m *CommandSendReceipt) XXX_Unmarshal(b []byte) error

type CommandSubscribe 

type CommandSubscribe struct {
	Topic         *string                   `protobuf:"bytes,1,req,name=topic" json:"topic,omitempty"`
	Subscription  *string                   `protobuf:"bytes,2,req,name=subscription" json:"subscription,omitempty"`
	SubType       *CommandSubscribe_SubType `protobuf:"varint,3,req,name=subType,enum=pulsar.proto.CommandSubscribe_SubType" json:"subType,omitempty"`
	ConsumerId    *uint64                   `protobuf:"varint,4,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	RequestId     *uint64                   `protobuf:"varint,5,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	ConsumerName  *string                   `protobuf:"bytes,6,opt,name=consumer_name,json=consumerName" json:"consumer_name,omitempty"`
	PriorityLevel *int32                    `protobuf:"varint,7,opt,name=priority_level,json=priorityLevel" json:"priority_level,omitempty"`
	// Signal wether the subscription should be backed by a
	// durable cursor or not
	Durable *bool `protobuf:"varint,8,opt,name=durable,def=1" json:"durable,omitempty"`
	// If specified, the subscription will position the cursor
	// markd-delete position  on the particular message id and
	// will send messages from that point
	StartMessageId *MessageIdData `protobuf:"bytes,9,opt,name=start_message_id,json=startMessageId" json:"start_message_id,omitempty"`
	/// Add optional metadata key=value to this consumer
	Metadata      []*KeyValue `protobuf:"bytes,10,rep,name=metadata" json:"metadata,omitempty"`
	ReadCompacted *bool       `protobuf:"varint,11,opt,name=read_compacted,json=readCompacted" json:"read_compacted,omitempty"`
	Schema        *Schema     `protobuf:"bytes,12,opt,name=schema" json:"schema,omitempty"`
	// Signal whether the subscription will initialize on latest
	// or not -- earliest
	InitialPosition *CommandSubscribe_InitialPosition `` /* 135-byte string literal not displayed */
	// Mark the subscription as "replicated". Pulsar will make sure
	// to periodically sync the state of replicated subscriptions
	// across different clusters (when using geo-replication).
	ReplicateSubscriptionState *bool `` /* 136-byte string literal not displayed */
	// If true, the subscribe operation will cause a topic to be
	// created if it does not exist already (and if topic auto-creation
	// is allowed by broker.
	// If false, the subscribe operation will fail if the topic
	// does not exist.
	ForceTopicCreation *bool `protobuf:"varint,15,opt,name=force_topic_creation,json=forceTopicCreation,def=1" json:"force_topic_creation,omitempty"`
	// If specified, the subscription will reset cursor's position back
	// to specified seconds and  will send messages from that point
	StartMessageRollbackDurationSec *uint64        `` /* 161-byte string literal not displayed */
	KeySharedMeta                   *KeySharedMeta `protobuf:"bytes,17,opt,name=keySharedMeta" json:"keySharedMeta,omitempty"`
	XXX_NoUnkeyedLiteral            struct{}       `json:"-"`
	XXX_unrecognized                []byte         `json:"-"`
	XXX_sizecache                   int32          `json:"-"`
}

func (*CommandSubscribe) Descriptor 

func (*CommandSubscribe) Descriptor() ([]byte, []int)

func (*CommandSubscribe) GetConsumerId 

func (m *CommandSubscribe) GetConsumerId() uint64

func (*CommandSubscribe) GetConsumerName 

func (m *CommandSubscribe) GetConsumerName() string

func (*CommandSubscribe) GetDurable 

func (m *CommandSubscribe) GetDurable() bool

func (*CommandSubscribe) GetForceTopicCreation 

func (m *CommandSubscribe) GetForceTopicCreation() bool

func (*CommandSubscribe) GetInitialPosition 

func (m *CommandSubscribe) GetInitialPosition() CommandSubscribe_InitialPosition

func (*CommandSubscribe) GetKeySharedMeta 

func (m *CommandSubscribe) GetKeySharedMeta() *KeySharedMeta

func (*CommandSubscribe) GetMetadata 

func (m *CommandSubscribe) GetMetadata() []*KeyValue

func (*CommandSubscribe) GetPriorityLevel 

func (m *CommandSubscribe) GetPriorityLevel() int32

func (*CommandSubscribe) GetReadCompacted 

func (m *CommandSubscribe) GetReadCompacted() bool

func (*CommandSubscribe) GetReplicateSubscriptionState 

func (m *CommandSubscribe) GetReplicateSubscriptionState() bool

func (*CommandSubscribe) GetRequestId 

func (m *CommandSubscribe) GetRequestId() uint64

func (*CommandSubscribe) GetSchema 

func (m *CommandSubscribe) GetSchema() *Schema

func (*CommandSubscribe) GetStartMessageId 

func (m *CommandSubscribe) GetStartMessageId() *MessageIdData

func (*CommandSubscribe) GetStartMessageRollbackDurationSec 

func (m *CommandSubscribe) GetStartMessageRollbackDurationSec() uint64

func (*CommandSubscribe) GetSubType 

func (m *CommandSubscribe) GetSubType() CommandSubscribe_SubType

func (*CommandSubscribe) GetSubscription 

func (m *CommandSubscribe) GetSubscription() string

func (*CommandSubscribe) GetTopic 

func (m *CommandSubscribe) GetTopic() string

func (*CommandSubscribe) ProtoMessage 

func (*CommandSubscribe) ProtoMessage()

func (*CommandSubscribe) Reset 

func (m *CommandSubscribe) Reset()

func (*CommandSubscribe) String 

func (m *CommandSubscribe) String() string

func (*CommandSubscribe) XXX_DiscardUnknown 

func (m *CommandSubscribe) XXX_DiscardUnknown()

func (*CommandSubscribe) XXX_Marshal 

func (m *CommandSubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSubscribe) XXX_Merge 

func (m *CommandSubscribe) XXX_Merge(src proto.Message)

func (*CommandSubscribe) XXX_Size 

func (m *CommandSubscribe) XXX_Size() int

func (*CommandSubscribe) XXX_Unmarshal 

func (m *CommandSubscribe) XXX_Unmarshal(b []byte) error

type CommandSubscribe_InitialPosition 

type CommandSubscribe_InitialPosition int32
const (
	CommandSubscribe_Latest   CommandSubscribe_InitialPosition = 0
	CommandSubscribe_Earliest CommandSubscribe_InitialPosition = 1
)
const Default_CommandSubscribe_InitialPosition CommandSubscribe_InitialPosition = CommandSubscribe_Latest

func (CommandSubscribe_InitialPosition) Enum 

func (x CommandSubscribe_InitialPosition) Enum() *CommandSubscribe_InitialPosition

func (CommandSubscribe_InitialPosition) EnumDescriptor 

func (CommandSubscribe_InitialPosition) EnumDescriptor() ([]byte, []int)

func (CommandSubscribe_InitialPosition) String 

func (x CommandSubscribe_InitialPosition) String() string

func (*CommandSubscribe_InitialPosition) UnmarshalJSON 

func (x *CommandSubscribe_InitialPosition) UnmarshalJSON(data []byte) error

type CommandSubscribe_SubType 

type CommandSubscribe_SubType int32
const (
	CommandSubscribe_Exclusive  CommandSubscribe_SubType = 0
	CommandSubscribe_Shared     CommandSubscribe_SubType = 1
	CommandSubscribe_Failover   CommandSubscribe_SubType = 2
	CommandSubscribe_Key_Shared CommandSubscribe_SubType = 3
)

func (CommandSubscribe_SubType) Enum 

func (x CommandSubscribe_SubType) Enum() *CommandSubscribe_SubType

func (CommandSubscribe_SubType) EnumDescriptor 

func (CommandSubscribe_SubType) EnumDescriptor() ([]byte, []int)

func (CommandSubscribe_SubType) String 

func (x CommandSubscribe_SubType) String() string

func (*CommandSubscribe_SubType) UnmarshalJSON 

func (x *CommandSubscribe_SubType) UnmarshalJSON(data []byte) error

type CommandSuccess 

type CommandSuccess struct {
	RequestId            *uint64  `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	Schema               *Schema  `protobuf:"bytes,2,opt,name=schema" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandSuccess) Descriptor 

func (*CommandSuccess) Descriptor() ([]byte, []int)

func (*CommandSuccess) GetRequestId 

func (m *CommandSuccess) GetRequestId() uint64

func (*CommandSuccess) GetSchema 

func (m *CommandSuccess) GetSchema() *Schema

func (*CommandSuccess) ProtoMessage 

func (*CommandSuccess) ProtoMessage()

func (*CommandSuccess) Reset 

func (m *CommandSuccess) Reset()

func (*CommandSuccess) String 

func (m *CommandSuccess) String() string

func (*CommandSuccess) XXX_DiscardUnknown 

func (m *CommandSuccess) XXX_DiscardUnknown()

func (*CommandSuccess) XXX_Marshal 

func (m *CommandSuccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandSuccess) XXX_Merge 

func (m *CommandSuccess) XXX_Merge(src proto.Message)

func (*CommandSuccess) XXX_Size 

func (m *CommandSuccess) XXX_Size() int

func (*CommandSuccess) XXX_Unmarshal 

func (m *CommandSuccess) XXX_Unmarshal(b []byte) error

type CommandUnsubscribe 

type CommandUnsubscribe struct {
	ConsumerId           *uint64  `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	RequestId            *uint64  `protobuf:"varint,2,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandUnsubscribe) Descriptor 

func (*CommandUnsubscribe) Descriptor() ([]byte, []int)

func (*CommandUnsubscribe) GetConsumerId 

func (m *CommandUnsubscribe) GetConsumerId() uint64

func (*CommandUnsubscribe) GetRequestId 

func (m *CommandUnsubscribe) GetRequestId() uint64

func (*CommandUnsubscribe) ProtoMessage 

func (*CommandUnsubscribe) ProtoMessage()

func (*CommandUnsubscribe) Reset 

func (m *CommandUnsubscribe) Reset()

func (*CommandUnsubscribe) String 

func (m *CommandUnsubscribe) String() string

func (*CommandUnsubscribe) XXX_DiscardUnknown 

func (m *CommandUnsubscribe) XXX_DiscardUnknown()

func (*CommandUnsubscribe) XXX_Marshal 

func (m *CommandUnsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandUnsubscribe) XXX_Merge 

func (m *CommandUnsubscribe) XXX_Merge(src proto.Message)

func (*CommandUnsubscribe) XXX_Size 

func (m *CommandUnsubscribe) XXX_Size() int

func (*CommandUnsubscribe) XXX_Unmarshal 

func (m *CommandUnsubscribe) XXX_Unmarshal(b []byte) error

type CompressionType 

type CompressionType int32
const (
	CompressionType_NONE   CompressionType = 0
	CompressionType_LZ4    CompressionType = 1
	CompressionType_ZLIB   CompressionType = 2
	CompressionType_ZSTD   CompressionType = 3
	CompressionType_SNAPPY CompressionType = 4
)
const Default_MessageMetadata_Compression CompressionType = CompressionType_NONE

func (CompressionType) Enum 

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor 

func (CompressionType) EnumDescriptor() ([]byte, []int)

func (CompressionType) String 

func (x CompressionType) String() string

func (*CompressionType) UnmarshalJSON 

func (x *CompressionType) UnmarshalJSON(data []byte) error

type EncryptionKeys 

type EncryptionKeys struct {
	Key                  *string     `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value                []byte      `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	Metadata             []*KeyValue `protobuf:"bytes,3,rep,name=metadata" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*EncryptionKeys) Descriptor 

func (*EncryptionKeys) Descriptor() ([]byte, []int)

func (*EncryptionKeys) GetKey 

func (m *EncryptionKeys) GetKey() string

func (*EncryptionKeys) GetMetadata 

func (m *EncryptionKeys) GetMetadata() []*KeyValue

func (*EncryptionKeys) GetValue 

func (m *EncryptionKeys) GetValue() []byte

func (*EncryptionKeys) ProtoMessage 

func (*EncryptionKeys) ProtoMessage()

func (*EncryptionKeys) Reset 

func (m *EncryptionKeys) Reset()

func (*EncryptionKeys) String 

func (m *EncryptionKeys) String() string

func (*EncryptionKeys) XXX_DiscardUnknown 

func (m *EncryptionKeys) XXX_DiscardUnknown()

func (*EncryptionKeys) XXX_Marshal 

func (m *EncryptionKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EncryptionKeys) XXX_Merge 

func (m *EncryptionKeys) XXX_Merge(src proto.Message)

func (*EncryptionKeys) XXX_Size 

func (m *EncryptionKeys) XXX_Size() int

func (*EncryptionKeys) XXX_Unmarshal 

func (m *EncryptionKeys) XXX_Unmarshal(b []byte) error

type FeatureFlags 

type FeatureFlags struct {
	SupportsAuthRefresh  *bool    `protobuf:"varint,1,opt,name=supports_auth_refresh,json=supportsAuthRefresh,def=0" json:"supports_auth_refresh,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FeatureFlags) Descriptor 

func (*FeatureFlags) Descriptor() ([]byte, []int)

func (*FeatureFlags) GetSupportsAuthRefresh 

func (m *FeatureFlags) GetSupportsAuthRefresh() bool

func (*FeatureFlags) ProtoMessage 

func (*FeatureFlags) ProtoMessage()

func (*FeatureFlags) Reset 

func (m *FeatureFlags) Reset()

func (*FeatureFlags) String 

func (m *FeatureFlags) String() string

func (*FeatureFlags) XXX_DiscardUnknown 

func (m *FeatureFlags) XXX_DiscardUnknown()

func (*FeatureFlags) XXX_Marshal 

func (m *FeatureFlags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureFlags) XXX_Merge 

func (m *FeatureFlags) XXX_Merge(src proto.Message)

func (*FeatureFlags) XXX_Size 

func (m *FeatureFlags) XXX_Size() int

func (*FeatureFlags) XXX_Unmarshal 

func (m *FeatureFlags) XXX_Unmarshal(b []byte) error

type IntRange 

type IntRange struct {
	Start                *int32   `protobuf:"varint,1,req,name=start" json:"start,omitempty"`
	End                  *int32   `protobuf:"varint,2,req,name=end" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IntRange) Descriptor 

func (*IntRange) Descriptor() ([]byte, []int)

func (*IntRange) GetEnd 

func (m *IntRange) GetEnd() int32

func (*IntRange) GetStart 

func (m *IntRange) GetStart() int32

func (*IntRange) ProtoMessage 

func (*IntRange) ProtoMessage()

func (*IntRange) Reset 

func (m *IntRange) Reset()

func (*IntRange) String 

func (m *IntRange) String() string

func (*IntRange) XXX_DiscardUnknown 

func (m *IntRange) XXX_DiscardUnknown()

func (*IntRange) XXX_Marshal 

func (m *IntRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IntRange) XXX_Merge 

func (m *IntRange) XXX_Merge(src proto.Message)

func (*IntRange) XXX_Size 

func (m *IntRange) XXX_Size() int

func (*IntRange) XXX_Unmarshal 

func (m *IntRange) XXX_Unmarshal(b []byte) error

type KeyLongValue 

type KeyLongValue struct {
	Key                  *string  `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value                *uint64  `protobuf:"varint,2,req,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyLongValue) Descriptor 

func (*KeyLongValue) Descriptor() ([]byte, []int)

func (*KeyLongValue) GetKey 

func (m *KeyLongValue) GetKey() string

func (*KeyLongValue) GetValue 

func (m *KeyLongValue) GetValue() uint64

func (*KeyLongValue) ProtoMessage 

func (*KeyLongValue) ProtoMessage()

func (*KeyLongValue) Reset 

func (m *KeyLongValue) Reset()

func (*KeyLongValue) String 

func (m *KeyLongValue) String() string

func (*KeyLongValue) XXX_DiscardUnknown 

func (m *KeyLongValue) XXX_DiscardUnknown()

func (*KeyLongValue) XXX_Marshal 

func (m *KeyLongValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyLongValue) XXX_Merge 

func (m *KeyLongValue) XXX_Merge(src proto.Message)

func (*KeyLongValue) XXX_Size 

func (m *KeyLongValue) XXX_Size() int

func (*KeyLongValue) XXX_Unmarshal 

func (m *KeyLongValue) XXX_Unmarshal(b []byte) error

type KeySharedMeta 

type KeySharedMeta struct {
	KeySharedMode        *KeySharedMode `protobuf:"varint,1,req,name=keySharedMode,enum=pulsar.proto.KeySharedMode" json:"keySharedMode,omitempty"`
	HashRanges           []*IntRange    `protobuf:"bytes,3,rep,name=hashRanges" json:"hashRanges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*KeySharedMeta) Descriptor 

func (*KeySharedMeta) Descriptor() ([]byte, []int)

func (*KeySharedMeta) GetHashRanges 

func (m *KeySharedMeta) GetHashRanges() []*IntRange

func (*KeySharedMeta) GetKeySharedMode 

func (m *KeySharedMeta) GetKeySharedMode() KeySharedMode

func (*KeySharedMeta) ProtoMessage 

func (*KeySharedMeta) ProtoMessage()

func (*KeySharedMeta) Reset 

func (m *KeySharedMeta) Reset()

func (*KeySharedMeta) String 

func (m *KeySharedMeta) String() string

func (*KeySharedMeta) XXX_DiscardUnknown 

func (m *KeySharedMeta) XXX_DiscardUnknown()

func (*KeySharedMeta) XXX_Marshal 

func (m *KeySharedMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeySharedMeta) XXX_Merge 

func (m *KeySharedMeta) XXX_Merge(src proto.Message)

func (*KeySharedMeta) XXX_Size 

func (m *KeySharedMeta) XXX_Size() int

func (*KeySharedMeta) XXX_Unmarshal 

func (m *KeySharedMeta) XXX_Unmarshal(b []byte) error

type KeySharedMode 

type KeySharedMode int32
const (
	KeySharedMode_AUTO_SPLIT KeySharedMode = 0
	KeySharedMode_STICKY     KeySharedMode = 1
)

func (KeySharedMode) Enum 

func (x KeySharedMode) Enum() *KeySharedMode

func (KeySharedMode) EnumDescriptor 

func (KeySharedMode) EnumDescriptor() ([]byte, []int)

func (KeySharedMode) String 

func (x KeySharedMode) String() string

func (*KeySharedMode) UnmarshalJSON 

func (x *KeySharedMode) UnmarshalJSON(data []byte) error

type KeyValue 

type KeyValue struct {
	Key                  *string  `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value                *string  `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValue) Descriptor 

func (*KeyValue) Descriptor() ([]byte, []int)

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() string

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValue) XXX_Merge 

func (m *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

func (m *KeyValue) XXX_Unmarshal(b []byte) error

type MessageIdData 

type MessageIdData struct {
	LedgerId             *uint64  `protobuf:"varint,1,req,name=ledgerId" json:"ledgerId,omitempty"`
	EntryId              *uint64  `protobuf:"varint,2,req,name=entryId" json:"entryId,omitempty"`
	Partition            *int32   `protobuf:"varint,3,opt,name=partition,def=-1" json:"partition,omitempty"`
	BatchIndex           *int32   `protobuf:"varint,4,opt,name=batch_index,json=batchIndex,def=-1" json:"batch_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageIdData) Descriptor 

func (*MessageIdData) Descriptor() ([]byte, []int)

func (*MessageIdData) GetBatchIndex 

func (m *MessageIdData) GetBatchIndex() int32

func (*MessageIdData) GetEntryId 

func (m *MessageIdData) GetEntryId() uint64

func (*MessageIdData) GetLedgerId 

func (m *MessageIdData) GetLedgerId() uint64

func (*MessageIdData) GetPartition 

func (m *MessageIdData) GetPartition() int32

func (*MessageIdData) ProtoMessage 

func (*MessageIdData) ProtoMessage()

func (*MessageIdData) Reset 

func (m *MessageIdData) Reset()

func (*MessageIdData) String 

func (m *MessageIdData) String() string

func (*MessageIdData) XXX_DiscardUnknown 

func (m *MessageIdData) XXX_DiscardUnknown()

func (*MessageIdData) XXX_Marshal 

func (m *MessageIdData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageIdData) XXX_Merge 

func (m *MessageIdData) XXX_Merge(src proto.Message)

func (*MessageIdData) XXX_Size 

func (m *MessageIdData) XXX_Size() int

func (*MessageIdData) XXX_Unmarshal 

func (m *MessageIdData) XXX_Unmarshal(b []byte) error

type MessageMetadata 

type MessageMetadata struct {
	ProducerName *string     `protobuf:"bytes,1,req,name=producer_name,json=producerName" json:"producer_name,omitempty"`
	SequenceId   *uint64     `protobuf:"varint,2,req,name=sequence_id,json=sequenceId" json:"sequence_id,omitempty"`
	PublishTime  *uint64     `protobuf:"varint,3,req,name=publish_time,json=publishTime" json:"publish_time,omitempty"`
	Properties   []*KeyValue `protobuf:"bytes,4,rep,name=properties" json:"properties,omitempty"`
	// Property set on replicated message,
	// includes the source cluster name
	ReplicatedFrom *string `protobuf:"bytes,5,opt,name=replicated_from,json=replicatedFrom" json:"replicated_from,omitempty"`
	//key to decide partition for the msg
	PartitionKey *string `protobuf:"bytes,6,opt,name=partition_key,json=partitionKey" json:"partition_key,omitempty"`
	// Override namespace's replication
	ReplicateTo      []string         `protobuf:"bytes,7,rep,name=replicate_to,json=replicateTo" json:"replicate_to,omitempty"`
	Compression      *CompressionType `protobuf:"varint,8,opt,name=compression,enum=pulsar.proto.CompressionType,def=0" json:"compression,omitempty"`
	UncompressedSize *uint32          `protobuf:"varint,9,opt,name=uncompressed_size,json=uncompressedSize,def=0" json:"uncompressed_size,omitempty"`
	// Removed below checksum field from Metadata as
	// it should be part of send-command which keeps checksum of header + payload
	//optional sfixed64 checksum = 10;
	// differentiate single and batch message metadata
	NumMessagesInBatch *int32 `protobuf:"varint,11,opt,name=num_messages_in_batch,json=numMessagesInBatch,def=1" json:"num_messages_in_batch,omitempty"`
	// the timestamp that this event occurs. it is typically set by applications.
	// if this field is omitted, `publish_time` can be used for the purpose of `event_time`.
	EventTime *uint64 `protobuf:"varint,12,opt,name=event_time,json=eventTime,def=0" json:"event_time,omitempty"`
	// Contains encryption key name, encrypted key and metadata to describe the key
	EncryptionKeys []*EncryptionKeys `protobuf:"bytes,13,rep,name=encryption_keys,json=encryptionKeys" json:"encryption_keys,omitempty"`
	// Algorithm used to encrypt data key
	EncryptionAlgo *string `protobuf:"bytes,14,opt,name=encryption_algo,json=encryptionAlgo" json:"encryption_algo,omitempty"`
	// Additional parameters required by encryption
	EncryptionParam        []byte `protobuf:"bytes,15,opt,name=encryption_param,json=encryptionParam" json:"encryption_param,omitempty"`
	SchemaVersion          []byte `protobuf:"bytes,16,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	PartitionKeyB64Encoded *bool  `` /* 132-byte string literal not displayed */
	// Specific a key to overwrite the message key which used for ordering dispatch in Key_Shared mode.
	OrderingKey []byte `protobuf:"bytes,18,opt,name=ordering_key,json=orderingKey" json:"ordering_key,omitempty"`
	// Mark the message to be delivered at or after the specified timestamp
	DeliverAtTime *int64 `protobuf:"varint,19,opt,name=deliver_at_time,json=deliverAtTime" json:"deliver_at_time,omitempty"`
	// Identify whether a message is a "marker" message used for
	// internal metadata instead of application published data.
	// Markers will generally not be propagated back to clients
	MarkerType *int32 `protobuf:"varint,20,opt,name=marker_type,json=markerType" json:"marker_type,omitempty"`
	// transaction related message info
	TxnidLeastBits *uint64 `protobuf:"varint,22,opt,name=txnid_least_bits,json=txnidLeastBits,def=0" json:"txnid_least_bits,omitempty"`
	TxnidMostBits  *uint64 `protobuf:"varint,23,opt,name=txnid_most_bits,json=txnidMostBits,def=0" json:"txnid_most_bits,omitempty"`
	/// Add highest sequence id to support batch message with external sequence id
	HighestSequenceId    *uint64  `protobuf:"varint,24,opt,name=highest_sequence_id,json=highestSequenceId,def=0" json:"highest_sequence_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageMetadata) Descriptor 

func (*MessageMetadata) Descriptor() ([]byte, []int)

func (*MessageMetadata) GetCompression 

func (m *MessageMetadata) GetCompression() CompressionType

func (*MessageMetadata) GetDeliverAtTime 

func (m *MessageMetadata) GetDeliverAtTime() int64

func (*MessageMetadata) GetEncryptionAlgo 

func (m *MessageMetadata) GetEncryptionAlgo() string

func (*MessageMetadata) GetEncryptionKeys 

func (m *MessageMetadata) GetEncryptionKeys() []*EncryptionKeys

func (*MessageMetadata) GetEncryptionParam 

func (m *MessageMetadata) GetEncryptionParam() []byte

func (*MessageMetadata) GetEventTime 

func (m *MessageMetadata) GetEventTime() uint64

func (*MessageMetadata) GetHighestSequenceId 

func (m *MessageMetadata) GetHighestSequenceId() uint64

func (*MessageMetadata) GetMarkerType 

func (m *MessageMetadata) GetMarkerType() int32

func (*MessageMetadata) GetNumMessagesInBatch 

func (m *MessageMetadata) GetNumMessagesInBatch() int32

func (*MessageMetadata) GetOrderingKey 

func (m *MessageMetadata) GetOrderingKey() []byte

func (*MessageMetadata) GetPartitionKey 

func (m *MessageMetadata) GetPartitionKey() string

func (*MessageMetadata) GetPartitionKeyB64Encoded 

func (m *MessageMetadata) GetPartitionKeyB64Encoded() bool

func (*MessageMetadata) GetProducerName 

func (m *MessageMetadata) GetProducerName() string

func (*MessageMetadata) GetProperties 

func (m *MessageMetadata) GetProperties() []*KeyValue

func (*MessageMetadata) GetPublishTime 

func (m *MessageMetadata) GetPublishTime() uint64

func (*MessageMetadata) GetReplicateTo 

func (m *MessageMetadata) GetReplicateTo() []string

func (*MessageMetadata) GetReplicatedFrom 

func (m *MessageMetadata) GetReplicatedFrom() string

func (*MessageMetadata) GetSchemaVersion 

func (m *MessageMetadata) GetSchemaVersion() []byte

func (*MessageMetadata) GetSequenceId 

func (m *MessageMetadata) GetSequenceId() uint64

func (*MessageMetadata) GetTxnidLeastBits 

func (m *MessageMetadata) GetTxnidLeastBits() uint64

func (*MessageMetadata) GetTxnidMostBits 

func (m *MessageMetadata) GetTxnidMostBits() uint64

func (*MessageMetadata) GetUncompressedSize 

func (m *MessageMetadata) GetUncompressedSize() uint32

func (*MessageMetadata) ProtoMessage 

func (*MessageMetadata) ProtoMessage()

func (*MessageMetadata) Reset 

func (m *MessageMetadata) Reset()

func (*MessageMetadata) String 

func (m *MessageMetadata) String() string

func (*MessageMetadata) XXX_DiscardUnknown 

func (m *MessageMetadata) XXX_DiscardUnknown()

func (*MessageMetadata) XXX_Marshal 

func (m *MessageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageMetadata) XXX_Merge 

func (m *MessageMetadata) XXX_Merge(src proto.Message)

func (*MessageMetadata) XXX_Size 

func (m *MessageMetadata) XXX_Size() int

func (*MessageMetadata) XXX_Unmarshal 

func (m *MessageMetadata) XXX_Unmarshal(b []byte) error

type ProtocolVersion 

type ProtocolVersion int32

Each protocol version identify new features that are incrementally added to the protocol 

const (
	ProtocolVersion_v0  ProtocolVersion = 0
	ProtocolVersion_v1  ProtocolVersion = 1
	ProtocolVersion_v2  ProtocolVersion = 2
	ProtocolVersion_v3  ProtocolVersion = 3
	ProtocolVersion_v4  ProtocolVersion = 4
	ProtocolVersion_v5  ProtocolVersion = 5
	ProtocolVersion_v6  ProtocolVersion = 6
	ProtocolVersion_v7  ProtocolVersion = 7
	ProtocolVersion_v8  ProtocolVersion = 8
	ProtocolVersion_v9  ProtocolVersion = 9
	ProtocolVersion_v10 ProtocolVersion = 10
	ProtocolVersion_v11 ProtocolVersion = 11
	ProtocolVersion_v12 ProtocolVersion = 12
	// Added CommandActiveConsumerChange
	// Added CommandGetTopicsOfNamespace
	ProtocolVersion_v13 ProtocolVersion = 13
	ProtocolVersion_v14 ProtocolVersion = 14
	// Added Key_Shared subscription
	ProtocolVersion_v15 ProtocolVersion = 15
)

func (ProtocolVersion) Enum 

func (x ProtocolVersion) Enum() *ProtocolVersion

func (ProtocolVersion) EnumDescriptor 

func (ProtocolVersion) EnumDescriptor() ([]byte, []int)

func (ProtocolVersion) String 

func (x ProtocolVersion) String() string

func (*ProtocolVersion) UnmarshalJSON 

func (x *ProtocolVersion) UnmarshalJSON(data []byte) error

type Schema 

type Schema struct {
	Name                 *string      `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	SchemaData           []byte       `protobuf:"bytes,3,req,name=schema_data,json=schemaData" json:"schema_data,omitempty"`
	Type                 *Schema_Type `protobuf:"varint,4,req,name=type,enum=pulsar.proto.Schema_Type" json:"type,omitempty"`
	Properties           []*KeyValue  `protobuf:"bytes,5,rep,name=properties" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Schema) Descriptor 

func (*Schema) Descriptor() ([]byte, []int)

func (*Schema) GetName 

func (m *Schema) GetName() string

func (*Schema) GetProperties 

func (m *Schema) GetProperties() []*KeyValue

func (*Schema) GetSchemaData 

func (m *Schema) GetSchemaData() []byte

func (*Schema) GetType 

func (m *Schema) GetType() Schema_Type

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schema) XXX_Merge 

func (m *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_Size 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal 

func (m *Schema) XXX_Unmarshal(b []byte) error

type Schema_Type 

type Schema_Type int32
const (
	Schema_None      Schema_Type = 0
	Schema_String    Schema_Type = 1
	Schema_Json      Schema_Type = 2
	Schema_Protobuf  Schema_Type = 3
	Schema_Avro      Schema_Type = 4
	Schema_Bool      Schema_Type = 5
	Schema_Int8      Schema_Type = 6
	Schema_Int16     Schema_Type = 7
	Schema_Int32     Schema_Type = 8
	Schema_Int64     Schema_Type = 9
	Schema_Float     Schema_Type = 10
	Schema_Double    Schema_Type = 11
	Schema_Date      Schema_Type = 12
	Schema_Time      Schema_Type = 13
	Schema_Timestamp Schema_Type = 14
	Schema_KeyValue  Schema_Type = 15
)

func (Schema_Type) Enum 

func (x Schema_Type) Enum() *Schema_Type

func (Schema_Type) EnumDescriptor 

func (Schema_Type) EnumDescriptor() ([]byte, []int)

func (Schema_Type) String 

func (x Schema_Type) String() string

func (*Schema_Type) UnmarshalJSON 

func (x *Schema_Type) UnmarshalJSON(data []byte) error

type ServerError 

type ServerError int32
const (
	ServerError_UnknownError        ServerError = 0
	ServerError_MetadataError       ServerError = 1
	ServerError_PersistenceError    ServerError = 2
	ServerError_AuthenticationError ServerError = 3
	ServerError_AuthorizationError  ServerError = 4
	ServerError_ConsumerBusy        ServerError = 5
	// other consumers are connected
	ServerError_ServiceNotReady                       ServerError = 6
	ServerError_ProducerBlockedQuotaExceededError     ServerError = 7
	ServerError_ProducerBlockedQuotaExceededException ServerError = 8
	ServerError_ChecksumError                         ServerError = 9
	ServerError_UnsupportedVersionError               ServerError = 10
	ServerError_TopicNotFound                         ServerError = 11
	ServerError_SubscriptionNotFound                  ServerError = 12
	ServerError_ConsumerNotFound                      ServerError = 13
	ServerError_TooManyRequests                       ServerError = 14
	ServerError_TopicTerminatedError                  ServerError = 15
	ServerError_ProducerBusy                          ServerError = 16
	ServerError_InvalidTopicName                      ServerError = 17
	ServerError_IncompatibleSchema                    ServerError = 18
	ServerError_ConsumerAssignError                   ServerError = 19
	ServerError_TransactionCoordinatorNotFound        ServerError = 20
	ServerError_InvalidTxnStatus                      ServerError = 21
)

func (ServerError) Enum 

func (x ServerError) Enum() *ServerError

func (ServerError) EnumDescriptor 

func (ServerError) EnumDescriptor() ([]byte, []int)

func (ServerError) String 

func (x ServerError) String() string

func (*ServerError) UnmarshalJSON 

func (x *ServerError) UnmarshalJSON(data []byte) error

type SingleMessageMetadata 

type SingleMessageMetadata struct {
	Properties   []*KeyValue `protobuf:"bytes,1,rep,name=properties" json:"properties,omitempty"`
	PartitionKey *string     `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey" json:"partition_key,omitempty"`
	PayloadSize  *int32      `protobuf:"varint,3,req,name=payload_size,json=payloadSize" json:"payload_size,omitempty"`
	CompactedOut *bool       `protobuf:"varint,4,opt,name=compacted_out,json=compactedOut,def=0" json:"compacted_out,omitempty"`
	// the timestamp that this event occurs. it is typically set by applications.
	// if this field is omitted, `publish_time` can be used for the purpose of `event_time`.
	EventTime              *uint64 `protobuf:"varint,5,opt,name=event_time,json=eventTime,def=0" json:"event_time,omitempty"`
	PartitionKeyB64Encoded *bool   `` /* 131-byte string literal not displayed */
	// Specific a key to overwrite the message key which used for ordering dispatch in Key_Shared mode.
	OrderingKey []byte `protobuf:"bytes,7,opt,name=ordering_key,json=orderingKey" json:"ordering_key,omitempty"`
	// Allows consumer retrieve the sequence id that the producer set.
	SequenceId           *uint64  `protobuf:"varint,8,opt,name=sequence_id,json=sequenceId" json:"sequence_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SingleMessageMetadata) Descriptor 

func (*SingleMessageMetadata) Descriptor() ([]byte, []int)

func (*SingleMessageMetadata) GetCompactedOut 

func (m *SingleMessageMetadata) GetCompactedOut() bool

func (*SingleMessageMetadata) GetEventTime 

func (m *SingleMessageMetadata) GetEventTime() uint64

func (*SingleMessageMetadata) GetOrderingKey 

func (m *SingleMessageMetadata) GetOrderingKey() []byte

func (*SingleMessageMetadata) GetPartitionKey 

func (m *SingleMessageMetadata) GetPartitionKey() string

func (*SingleMessageMetadata) GetPartitionKeyB64Encoded 

func (m *SingleMessageMetadata) GetPartitionKeyB64Encoded() bool

func (*SingleMessageMetadata) GetPayloadSize 

func (m *SingleMessageMetadata) GetPayloadSize() int32

func (*SingleMessageMetadata) GetProperties 

func (m *SingleMessageMetadata) GetProperties() []*KeyValue

func (*SingleMessageMetadata) GetSequenceId 

func (m *SingleMessageMetadata) GetSequenceId() uint64

func (*SingleMessageMetadata) ProtoMessage 

func (*SingleMessageMetadata) ProtoMessage()

func (*SingleMessageMetadata) Reset 

func (m *SingleMessageMetadata) Reset()

func (*SingleMessageMetadata) String 

func (m *SingleMessageMetadata) String() string

func (*SingleMessageMetadata) XXX_DiscardUnknown 

func (m *SingleMessageMetadata) XXX_DiscardUnknown()

func (*SingleMessageMetadata) XXX_Marshal 

func (m *SingleMessageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SingleMessageMetadata) XXX_Merge 

func (m *SingleMessageMetadata) XXX_Merge(src proto.Message)

func (*SingleMessageMetadata) XXX_Size 

func (m *SingleMessageMetadata) XXX_Size() int

func (*SingleMessageMetadata) XXX_Unmarshal 

func (m *SingleMessageMetadata) XXX_Unmarshal(b []byte) error

type Subscription 

type Subscription struct {
	Topic                *string  `protobuf:"bytes,1,req,name=topic" json:"topic,omitempty"`
	Subscription         *string  `protobuf:"bytes,2,req,name=subscription" json:"subscription,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Subscription) Descriptor 

func (*Subscription) Descriptor() ([]byte, []int)

func (*Subscription) GetSubscription 

func (m *Subscription) GetSubscription() string

func (*Subscription) GetTopic 

func (m *Subscription) GetTopic() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscription) XXX_Merge 

func (m *Subscription) XXX_Merge(src proto.Message)

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

func (m *Subscription) XXX_Unmarshal(b []byte) error

type TxnAction 

type TxnAction int32
const (
	TxnAction_COMMIT TxnAction = 0
	TxnAction_ABORT  TxnAction = 1
)

func (TxnAction) Enum 

func (x TxnAction) Enum() *TxnAction

func (TxnAction) EnumDescriptor 

func (TxnAction) EnumDescriptor() ([]byte, []int)

func (TxnAction) String 

func (x TxnAction) String() string

func (*TxnAction) UnmarshalJSON 

func (x *TxnAction) UnmarshalJSON(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.