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: 0

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 (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 (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 (CommandAck_ValidationError) EnumDescriptor

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

func (CommandAck_ValidationError) 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 (*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 (*CommandGetLastMessageIdResponse) 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 (*CommandGetTopicsOfNamespaceResponse) ProtoMessage

func (*CommandGetTopicsOfNamespaceResponse) ProtoMessage()

func (*CommandGetTopicsOfNamespaceResponse) Reset

func (*CommandGetTopicsOfNamespaceResponse) 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 (*CommandGetTopicsOfNamespaceResponse) XXX_Size

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 (*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 (*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 (CommandLookupTopicResponse_LookupType) EnumDescriptor

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

func (CommandLookupTopicResponse_LookupType) 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 (*CommandPartitionedTopicMetadata) ProtoMessage

func (*CommandPartitionedTopicMetadata) ProtoMessage()

func (*CommandPartitionedTopicMetadata) Reset

func (*CommandPartitionedTopicMetadata) 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 (*CommandPartitionedTopicMetadataResponse) GetMessage

func (*CommandPartitionedTopicMetadataResponse) GetPartitions

func (*CommandPartitionedTopicMetadataResponse) GetRequestId

func (*CommandPartitionedTopicMetadataResponse) GetResponse

func (*CommandPartitionedTopicMetadataResponse) ProtoMessage

func (*CommandPartitionedTopicMetadataResponse) Reset

func (*CommandPartitionedTopicMetadataResponse) 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 (*CommandPartitionedTopicMetadataResponse) XXX_Size

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 (CommandPartitionedTopicMetadataResponse_LookupType) EnumDescriptor

func (CommandPartitionedTopicMetadataResponse_LookupType) String

func (*CommandPartitionedTopicMetadataResponse_LookupType) UnmarshalJSON

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 (*CommandRedeliverUnacknowledgedMessages) GetMessageIds

func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage

func (*CommandRedeliverUnacknowledgedMessages) Reset

func (*CommandRedeliverUnacknowledgedMessages) 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 (*CommandRedeliverUnacknowledgedMessages) XXX_Size

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 (*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 (CommandSubscribe_InitialPosition) EnumDescriptor

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

func (CommandSubscribe_InitialPosition) 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 (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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL