pulsar_proto

package
v0.0.0-...-54a44df Latest Latest
Warning

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

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

Documentation

Overview

Package pulsar_proto is a generated protocol buffer package.

It is generated from these files: 

PulsarApi.proto

It has these top-level messages: 

MessageIdData
KeyValue
MessageMetadata
SingleMessageMetadata
CommandConnect
CommandConnected
CommandSubscribe
CommandPartitionedTopicMetadata
CommandPartitionedTopicMetadataResponse
CommandLookupTopic
CommandLookupTopicResponse
CommandProducer
CommandSend
CommandSendReceipt
CommandSendError
CommandMessage
CommandAck
CommandFlow
CommandUnsubscribe
CommandReachedEndOfTopic
CommandCloseProducer
CommandCloseConsumer
CommandRedeliverUnacknowledgedMessages
CommandSuccess
CommandProducerSuccess
CommandError
CommandPing
CommandPong
CommandConsumerStats
CommandConsumerStatsResponse
BaseCommand

Index

Constants

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_CommandLookupTopic_Authoritative 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_NumMessagesInBatch int32 = 1
View Source 
const Default_MessageMetadata_UncompressedSize uint32 = 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",
}
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,
}
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",
}
View Source 
var CommandAck_ValidationError_value = map[string]int32{
	"UncompressedSizeCorruption": 0,
	"DecompressionError":         1,
	"ChecksumMismatch":           2,
	"BatchDeSerializeError":      3,
}
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_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",
}
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,
}
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",
}
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,
}

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"`
	XXX_unrecognized                []byte                                   `json:"-"`
}

func (*BaseCommand) Descriptor 

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

func (*BaseCommand) GetAck 

func (m *BaseCommand) GetAck() *CommandAck

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

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
)

func (BaseCommand_Type) Enum 

func (x BaseCommand_Type) Enum() *BaseCommand_Type

func (BaseCommand_Type) EnumDescriptor 

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

func (BaseCommand_Type) String 

func (x BaseCommand_Type) String() string

func (*BaseCommand_Type) UnmarshalJSON 

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

type CommandAck 

type CommandAck struct {
	ConsumerId       *uint64                     `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	AckType          *CommandAck_AckType         `protobuf:"varint,2,req,name=ack_type,json=ackType,enum=pulsar.proto.CommandAck_AckType" json:"ack_type,omitempty"`
	MessageId        *MessageIdData              `protobuf:"bytes,3,req,name=message_id,json=messageId" json:"message_id,omitempty"`
	ValidationError  *CommandAck_ValidationError `` /* 145-byte string literal not displayed */
	XXX_unrecognized []byte                      `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) 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

type CommandAck_AckType 

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

func (CommandAck_AckType) Enum 

func (x CommandAck_AckType) Enum() *CommandAck_AckType

func (CommandAck_AckType) EnumDescriptor 

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

func (CommandAck_AckType) String 

func (x CommandAck_AckType) String() string

func (*CommandAck_AckType) UnmarshalJSON 

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

type CommandAck_ValidationError 

type CommandAck_ValidationError int32

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

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

func (CommandAck_ValidationError) Enum 

func (x CommandAck_ValidationError) Enum() *CommandAck_ValidationError

func (CommandAck_ValidationError) EnumDescriptor 

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

func (CommandAck_ValidationError) String 

func (x CommandAck_ValidationError) String() string

func (*CommandAck_ValidationError) UnmarshalJSON 

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

type 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_unrecognized []byte  `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

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_unrecognized []byte  `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

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"`
	XXX_unrecognized []byte      `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) GetProtocolVersion 

func (m *CommandConnect) GetProtocolVersion() int32

func (*CommandConnect) ProtoMessage 

func (*CommandConnect) ProtoMessage()

func (*CommandConnect) Reset 

func (m *CommandConnect) Reset()

func (*CommandConnect) String 

func (m *CommandConnect) String() string

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_unrecognized []byte  `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

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_unrecognized []byte  `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

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_unrecognized []byte  `json:"-"`
}

func (*CommandConsumerStatsResponse) Descriptor 

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

func (*CommandConsumerStatsResponse) GetAddress 

func (m *CommandConsumerStatsResponse) GetAddress() string

func (*CommandConsumerStatsResponse) GetAvailablePermits 

func (m *CommandConsumerStatsResponse) GetAvailablePermits() uint64

func (*CommandConsumerStatsResponse) GetBlockedConsumerOnUnackedMsgs 

func (m *CommandConsumerStatsResponse) GetBlockedConsumerOnUnackedMsgs() bool

func (*CommandConsumerStatsResponse) GetConnectedSince 

func (m *CommandConsumerStatsResponse) GetConnectedSince() string

func (*CommandConsumerStatsResponse) GetConsumerName 

func (m *CommandConsumerStatsResponse) GetConsumerName() string

func (*CommandConsumerStatsResponse) GetErrorCode 

func (m *CommandConsumerStatsResponse) GetErrorCode() ServerError

func (*CommandConsumerStatsResponse) GetErrorMessage 

func (m *CommandConsumerStatsResponse) GetErrorMessage() string

func (*CommandConsumerStatsResponse) GetMsgBacklog 

func (m *CommandConsumerStatsResponse) GetMsgBacklog() uint64

func (*CommandConsumerStatsResponse) GetMsgRateExpired 

func (m *CommandConsumerStatsResponse) GetMsgRateExpired() float64

func (*CommandConsumerStatsResponse) GetMsgRateOut 

func (m *CommandConsumerStatsResponse) GetMsgRateOut() float64

func (*CommandConsumerStatsResponse) GetMsgRateRedeliver 

func (m *CommandConsumerStatsResponse) GetMsgRateRedeliver() float64

func (*CommandConsumerStatsResponse) GetMsgThroughputOut 

func (m *CommandConsumerStatsResponse) GetMsgThroughputOut() float64

func (*CommandConsumerStatsResponse) GetRequestId 

func (m *CommandConsumerStatsResponse) GetRequestId() uint64

func (*CommandConsumerStatsResponse) GetType 

func (m *CommandConsumerStatsResponse) GetType() string

func (*CommandConsumerStatsResponse) GetUnackedMessages 

func (m *CommandConsumerStatsResponse) GetUnackedMessages() uint64

func (*CommandConsumerStatsResponse) ProtoMessage 

func (*CommandConsumerStatsResponse) ProtoMessage()

func (*CommandConsumerStatsResponse) Reset 

func (m *CommandConsumerStatsResponse) Reset()

func (*CommandConsumerStatsResponse) String 

func (m *CommandConsumerStatsResponse) String() string

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_unrecognized []byte       `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

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_unrecognized []byte  `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

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CommandLookupTopic) Descriptor 

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

func (*CommandLookupTopic) GetAuthoritative 

func (m *CommandLookupTopic) GetAuthoritative() bool

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

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"`
	XXX_unrecognized    []byte                                 `json:"-"`
}

func (*CommandLookupTopicResponse) Descriptor 

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

func (*CommandLookupTopicResponse) GetAuthoritative 

func (m *CommandLookupTopicResponse) GetAuthoritative() bool

func (*CommandLookupTopicResponse) GetBrokerServiceUrl 

func (m *CommandLookupTopicResponse) GetBrokerServiceUrl() string

func (*CommandLookupTopicResponse) GetBrokerServiceUrlTls 

func (m *CommandLookupTopicResponse) GetBrokerServiceUrlTls() string

func (*CommandLookupTopicResponse) GetError 

func (m *CommandLookupTopicResponse) GetError() ServerError

func (*CommandLookupTopicResponse) GetMessage 

func (m *CommandLookupTopicResponse) GetMessage() string

func (*CommandLookupTopicResponse) GetRequestId 

func (m *CommandLookupTopicResponse) GetRequestId() uint64

func (*CommandLookupTopicResponse) GetResponse 

func (m *CommandLookupTopicResponse) GetResponse() CommandLookupTopicResponse_LookupType

func (*CommandLookupTopicResponse) ProtoMessage 

func (*CommandLookupTopicResponse) ProtoMessage()

func (*CommandLookupTopicResponse) Reset 

func (m *CommandLookupTopicResponse) Reset()

func (*CommandLookupTopicResponse) String 

func (m *CommandLookupTopicResponse) String() string

type CommandLookupTopicResponse_LookupType 

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

func (CommandLookupTopicResponse_LookupType) Enum 

func (x CommandLookupTopicResponse_LookupType) Enum() *CommandLookupTopicResponse_LookupType

func (CommandLookupTopicResponse_LookupType) EnumDescriptor 

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

func (CommandLookupTopicResponse_LookupType) String 

func (x CommandLookupTopicResponse_LookupType) String() string

func (*CommandLookupTopicResponse_LookupType) UnmarshalJSON 

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

type CommandMessage 

type CommandMessage struct {
	ConsumerId       *uint64        `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	MessageId        *MessageIdData `protobuf:"bytes,2,req,name=message_id,json=messageId" json:"message_id,omitempty"`
	XXX_unrecognized []byte         `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

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CommandPartitionedTopicMetadata) Descriptor 

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

func (*CommandPartitionedTopicMetadata) GetRequestId 

func (m *CommandPartitionedTopicMetadata) GetRequestId() uint64

func (*CommandPartitionedTopicMetadata) GetTopic 

func (m *CommandPartitionedTopicMetadata) GetTopic() string

func (*CommandPartitionedTopicMetadata) ProtoMessage 

func (*CommandPartitionedTopicMetadata) ProtoMessage()

func (*CommandPartitionedTopicMetadata) Reset 

func (m *CommandPartitionedTopicMetadata) Reset()

func (*CommandPartitionedTopicMetadata) String 

func (m *CommandPartitionedTopicMetadata) String() string

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_unrecognized []byte                                              `json:"-"`
}

func (*CommandPartitionedTopicMetadataResponse) Descriptor 

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

func (*CommandPartitionedTopicMetadataResponse) GetError 

func (m *CommandPartitionedTopicMetadataResponse) GetError() ServerError

func (*CommandPartitionedTopicMetadataResponse) GetMessage 

func (m *CommandPartitionedTopicMetadataResponse) GetMessage() string

func (*CommandPartitionedTopicMetadataResponse) GetPartitions 

func (m *CommandPartitionedTopicMetadataResponse) GetPartitions() uint32

func (*CommandPartitionedTopicMetadataResponse) GetRequestId 

func (m *CommandPartitionedTopicMetadataResponse) GetRequestId() uint64

func (*CommandPartitionedTopicMetadataResponse) GetResponse 

func (m *CommandPartitionedTopicMetadataResponse) GetResponse() CommandPartitionedTopicMetadataResponse_LookupType

func (*CommandPartitionedTopicMetadataResponse) ProtoMessage 

func (*CommandPartitionedTopicMetadataResponse) ProtoMessage()

func (*CommandPartitionedTopicMetadataResponse) Reset 

func (m *CommandPartitionedTopicMetadataResponse) Reset()

func (*CommandPartitionedTopicMetadataResponse) String 

func (m *CommandPartitionedTopicMetadataResponse) String() string

type CommandPartitionedTopicMetadataResponse_LookupType 

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

func (CommandPartitionedTopicMetadataResponse_LookupType) Enum 

func (x CommandPartitionedTopicMetadataResponse_LookupType) Enum() *CommandPartitionedTopicMetadataResponse_LookupType

func (CommandPartitionedTopicMetadataResponse_LookupType) EnumDescriptor 

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

func (CommandPartitionedTopicMetadataResponse_LookupType) String 

func (x CommandPartitionedTopicMetadataResponse_LookupType) String() string

func (*CommandPartitionedTopicMetadataResponse_LookupType) UnmarshalJSON 

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

type CommandPing 

type CommandPing struct {
	XXX_unrecognized []byte `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

type CommandPong 

type CommandPong struct {
	XXX_unrecognized []byte `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

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"`
	XXX_unrecognized []byte  `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) GetProducerId 

func (m *CommandProducer) GetProducerId() uint64

func (*CommandProducer) GetProducerName 

func (m *CommandProducer) GetProducerName() string

func (*CommandProducer) GetRequestId 

func (m *CommandProducer) GetRequestId() uint64

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

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"`
	XXX_unrecognized []byte  `json:"-"`
}

/ Response from CommandProducer

func (*CommandProducerSuccess) Descriptor 

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

func (*CommandProducerSuccess) GetProducerName 

func (m *CommandProducerSuccess) GetProducerName() string

func (*CommandProducerSuccess) GetRequestId 

func (m *CommandProducerSuccess) GetRequestId() uint64

func (*CommandProducerSuccess) ProtoMessage 

func (*CommandProducerSuccess) ProtoMessage()

func (*CommandProducerSuccess) Reset 

func (m *CommandProducerSuccess) Reset()

func (*CommandProducerSuccess) String 

func (m *CommandProducerSuccess) String() string

type CommandReachedEndOfTopic 

type CommandReachedEndOfTopic struct {
	ConsumerId       *uint64 `protobuf:"varint,1,req,name=consumer_id,json=consumerId" json:"consumer_id,omitempty"`
	XXX_unrecognized []byte  `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

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_unrecognized []byte           `json:"-"`
}

func (*CommandRedeliverUnacknowledgedMessages) Descriptor 

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

func (*CommandRedeliverUnacknowledgedMessages) GetConsumerId 

func (m *CommandRedeliverUnacknowledgedMessages) GetConsumerId() uint64

func (*CommandRedeliverUnacknowledgedMessages) GetMessageIds 

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

func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage 

func (*CommandRedeliverUnacknowledgedMessages) ProtoMessage()

func (*CommandRedeliverUnacknowledgedMessages) Reset 

func (m *CommandRedeliverUnacknowledgedMessages) Reset()

func (*CommandRedeliverUnacknowledgedMessages) String 

func (m *CommandRedeliverUnacknowledgedMessages) String() string

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_unrecognized []byte  `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

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_unrecognized []byte       `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

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_unrecognized []byte         `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

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"`
	XXX_unrecognized []byte         `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) GetPriorityLevel 

func (m *CommandSubscribe) GetPriorityLevel() int32

func (*CommandSubscribe) GetRequestId 

func (m *CommandSubscribe) GetRequestId() uint64

func (*CommandSubscribe) GetStartMessageId 

func (m *CommandSubscribe) GetStartMessageId() *MessageIdData

func (*CommandSubscribe) GetSubType 

func (m *CommandSubscribe) GetSubType() CommandSubscribe_SubType

func (*CommandSubscribe) GetSubscription 

func (m *CommandSubscribe) GetSubscription() string

func (*CommandSubscribe) GetTopic 

func (m *CommandSubscribe) GetTopic() string

func (*CommandSubscribe) ProtoMessage 

func (*CommandSubscribe) ProtoMessage()

func (*CommandSubscribe) Reset 

func (m *CommandSubscribe) Reset()

func (*CommandSubscribe) String 

func (m *CommandSubscribe) String() string

type CommandSubscribe_SubType 

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

func (CommandSubscribe_SubType) Enum 

func (x CommandSubscribe_SubType) Enum() *CommandSubscribe_SubType

func (CommandSubscribe_SubType) EnumDescriptor 

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

func (CommandSubscribe_SubType) String 

func (x CommandSubscribe_SubType) String() string

func (*CommandSubscribe_SubType) UnmarshalJSON 

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

type CommandSuccess 

type CommandSuccess struct {
	RequestId        *uint64 `protobuf:"varint,1,req,name=request_id,json=requestId" json:"request_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CommandSuccess) Descriptor 

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

func (*CommandSuccess) GetRequestId 

func (m *CommandSuccess) GetRequestId() uint64

func (*CommandSuccess) ProtoMessage 

func (*CommandSuccess) ProtoMessage()

func (*CommandSuccess) Reset 

func (m *CommandSuccess) Reset()

func (*CommandSuccess) String 

func (m *CommandSuccess) String() string

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_unrecognized []byte  `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

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 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_unrecognized []byte  `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

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_unrecognized []byte  `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

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"`
	XXX_unrecognized   []byte `json:"-"`
}

func (*MessageMetadata) Descriptor 

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

func (*MessageMetadata) GetCompression 

func (m *MessageMetadata) GetCompression() CompressionType

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

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
)

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

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"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*SingleMessageMetadata) Descriptor 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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