Module pulsar::message::proto

Modules

base_command
command_ack
command_lookup_topic_response
command_partitioned_topic_metadata_response
command_subscribe
get_topics
schema

Structs

BaseCommand
CommandAck
CommandActiveConsumerChange	changes on active consumer
CommandCloseConsumer
CommandCloseProducer
CommandConnect
CommandConnected
CommandConsumerStats
CommandConsumerStatsResponse
CommandError
CommandFlow
CommandGetLastMessageId
CommandGetLastMessageIdResponse
CommandGetSchema
CommandGetSchemaResponse
CommandGetTopicsOfNamespace
CommandGetTopicsOfNamespaceResponse
CommandLookupTopic
CommandLookupTopicResponse
CommandMessage
CommandPartitionedTopicMetadata
CommandPartitionedTopicMetadataResponse
CommandPing	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.
CommandPong
CommandProducer
CommandProducerSuccess
CommandReachedEndOfTopic	Message sent by broker to client when a topic has been forcefully terminated and there are no more messages left to consume
CommandRedeliverUnacknowledgedMessages
CommandSeek	Reset an existing consumer to a particular message id
CommandSend
CommandSendError
CommandSendReceipt
CommandSubscribe
CommandSuccess
CommandUnsubscribe
EncryptionKeys
KeyLongValue
KeyValue
MessageIdData
MessageMetadata
Schema
SingleMessageMetadata

Enums

AuthMethod
CompressionType
ProtocolVersion	Each protocol version identify new features that are incrementally added to the protocol
ServerError