api

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2019 License: Apache-2.0 Imports: 3 Imported by: 12

Documentation

Overview

Package api provides the protocol buffer messages that Pulsar uses for the client/broker wire protocol. See "Pulsar binary protocol specification" for more information. https://pulsar.incubator.apache.org/docs/latest/project/BinaryProtocol/

The protocol definition files are part of the main Pulsar source, located within the Pulsar repository at: https://github.com/apache/incubator-pulsar/tree/master/pulsar-common/src/main/proto

The generated Go code was created from the source Pulsar files at git: 

tag:      v2.0.1-incubating
revision: fd47532380d770e4fd78cabe71dea293fc2f0e06

Files generated by the protoc-gen-go program should not be modified.

Index

Constants

View Source 
const Default_CommandActiveConsumerChange_IsActive bool = false
View Source 
const Default_CommandConnect_ProtocolVersion int32 = 0
View Source 
const Default_CommandConnected_ProtocolVersion int32 = 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_CommandProducerSuccess_LastSequenceId int64 = -1
View Source 
const Default_CommandProducer_Encrypted bool = false
View Source 
const Default_CommandSend_NumMessages int32 = 1
View Source 
const Default_CommandSubscribe_Durable bool = true
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_NumMessagesInBatch int32 = 1
View Source 
const Default_MessageMetadata_UncompressedSize uint32 = 0
View Source 
const Default_SingleMessageMetadata_CompactedOut bool = false
View Source 
const Default_SingleMessageMetadata_EventTime uint64 = 0

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",
}
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,
}
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 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",
}
View Source 
var CommandSubscribe_SubType_value = map[string]int32{
	"Exclusive": 0,
	"Shared":    1,
	"Failover":  2,
}
View Source 
var CompressionType_name = map[int32]string{
	0: "NONE",
	1: "LZ4",
	2: "ZLIB",
}
View Source 
var CompressionType_value = map[string]int32{
	"NONE": 0,
	"LZ4":  1,
	"ZLIB": 2,
}
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",
}
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,
}
View Source 
var Schema_Type_name = map[int32]string{
	0: "None",
	1: "String",
	2: "Json",
}
View Source 
var Schema_Type_value = map[string]int32{
	"None":   0,
	"String": 1,
	"Json":   2,
}
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",
}
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,
}

Functions

This section is empty.

Types

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"`
	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) GetActiveConsumerChange 

func (m *BaseCommand) GetActiveConsumerChange() *CommandActiveConsumerChange

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) 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) 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) 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 (dst *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
)

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"`
	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) 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 (dst *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 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 (dst *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 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 (dst *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 (dst *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"`
	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) 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 (dst *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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandConnected) Descriptor 

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

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 (dst *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 (dst *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 (dst *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 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 (dst *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 (dst *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 (dst *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 (dst *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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandGetTopicsOfNamespace) Descriptor 

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

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 (dst *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 (dst *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 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"`
	// 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 (dst *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 (dst *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"`
	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) 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 (dst *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 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"`
	// 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 (dst *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 (dst *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 (dst *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 (dst *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"`
	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) 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) 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 (dst *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 (dst *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 (dst *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 (dst *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"`
	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) 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 (dst *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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandSend) Descriptor 

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

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) 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 (dst *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 (dst *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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CommandSendReceipt) Descriptor 

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

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 (dst *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 wthether the subscription will initialize on latest
	// or not -- earliest
	InitialPosition      *CommandSubscribe_InitialPosition `` /* 135-byte string literal not displayed */
	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) GetInitialPosition 

func (m *CommandSubscribe) GetInitialPosition() CommandSubscribe_InitialPosition

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) GetRequestId 

func (m *CommandSubscribe) GetRequestId() uint64

func (*CommandSubscribe) GetSchema 

func (m *CommandSubscribe) GetSchema() *Schema

func (*CommandSubscribe) GetStartMessageId 

func (m *CommandSubscribe) GetStartMessageId() *MessageIdData

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 (dst *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
)

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 (dst *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 (dst *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
)
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 (dst *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 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 (dst *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 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 (dst *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 (dst *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"`
	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) 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) GetNumMessagesInBatch 

func (m *MessageMetadata) GetNumMessagesInBatch() int32

func (*MessageMetadata) GetPartitionKey 

func (m *MessageMetadata) GetPartitionKey() string

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) 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 (dst *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
)

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 (dst *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
)

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
)

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"`
	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) GetPartitionKey 

func (m *SingleMessageMetadata) GetPartitionKey() string

func (*SingleMessageMetadata) GetPayloadSize 

func (m *SingleMessageMetadata) GetPayloadSize() int32

func (*SingleMessageMetadata) GetProperties 

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

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 (dst *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

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.