Documentation for pulsar-client-ruby (0.1.0)

Alphabetic Index

File Listing

README

Namespace Listing A-Z

Top Level Namespace

A

AckType (Pulsar::Proto::CommandAck)
AuthData (Pulsar::Proto)
AuthMethod (Pulsar::Proto)

B

BaseCommand (Pulsar::Proto)
BrokerEntryMetadata (Pulsar::Proto)

C

Client (Pulsar)
CommandAck (Pulsar::Proto)
CommandAckResponse (Pulsar::Proto)
CommandActiveConsumerChange (Pulsar::Proto)
CommandAddPartitionToTxn (Pulsar::Proto)
CommandAddPartitionToTxnResponse (Pulsar::Proto)
CommandAddSubscriptionToTxn (Pulsar::Proto)
CommandAddSubscriptionToTxnResponse (Pulsar::Proto)
CommandAuthChallenge (Pulsar::Proto)
CommandAuthResponse (Pulsar::Proto)
CommandCloseConsumer (Pulsar::Proto)
CommandCloseProducer (Pulsar::Proto)
CommandConnect (Pulsar::Proto)
CommandConnected (Pulsar::Proto)
CommandConsumerStats (Pulsar::Proto)
CommandConsumerStatsResponse (Pulsar::Proto)
CommandEndTxn (Pulsar::Proto)
CommandEndTxnOnPartition (Pulsar::Proto)
CommandEndTxnOnPartitionResponse (Pulsar::Proto)
CommandEndTxnOnSubscription (Pulsar::Proto)
CommandEndTxnOnSubscriptionResponse (Pulsar::Proto)
CommandEndTxnResponse (Pulsar::Proto)
CommandError (Pulsar::Proto)
CommandFlow (Pulsar::Proto)
CommandGetLastMessageId (Pulsar::Proto)
CommandGetLastMessageIdResponse (Pulsar::Proto)
CommandGetOrCreateSchema (Pulsar::Proto)
CommandGetOrCreateSchemaResponse (Pulsar::Proto)
CommandGetSchema (Pulsar::Proto)
CommandGetSchemaResponse (Pulsar::Proto)
CommandGetTopicsOfNamespace (Pulsar::Proto)
CommandGetTopicsOfNamespaceResponse (Pulsar::Proto)
CommandLookupTopic (Pulsar::Proto)
CommandLookupTopicResponse (Pulsar::Proto)
CommandMessage (Pulsar::Proto)
CommandNewTxn (Pulsar::Proto)
CommandNewTxnResponse (Pulsar::Proto)
CommandPartitionedTopicMetadata (Pulsar::Proto)
CommandPartitionedTopicMetadataResponse (Pulsar::Proto)
CommandPing (Pulsar::Proto)
CommandPong (Pulsar::Proto)
CommandProducer (Pulsar::Proto)
CommandProducerSuccess (Pulsar::Proto)
CommandReachedEndOfTopic (Pulsar::Proto)
CommandRedeliverUnacknowledgedMessages (Pulsar::Proto)
CommandSeek (Pulsar::Proto)
CommandSend (Pulsar::Proto)
CommandSendError (Pulsar::Proto)
CommandSendReceipt (Pulsar::Proto)
CommandSubscribe (Pulsar::Proto)
CommandSuccess (Pulsar::Proto)
CommandTcClientConnectRequest (Pulsar::Proto)
CommandTcClientConnectResponse (Pulsar::Proto)
CommandUnsubscribe (Pulsar::Proto)
CommandWatchTopicList (Pulsar::Proto)
CommandWatchTopicListClose (Pulsar::Proto)
CommandWatchTopicListSuccess (Pulsar::Proto)
CommandWatchTopicUpdate (Pulsar::Proto)
CompressionType (Pulsar::Proto)

E

EncryptionKeys (Pulsar::Proto)
Error (Pulsar::Client)

F

FeatureFlags (Pulsar::Proto)

I

InitialPosition (Pulsar::Proto::CommandSubscribe)
IntRange (Pulsar::Proto)

K

KeyLongValue (Pulsar::Proto)
KeySharedMeta (Pulsar::Proto)
KeySharedMode (Pulsar::Proto)
KeyValue (Pulsar::Proto)

L

LookupType (Pulsar::Proto::CommandPartitionedTopicMetadataResponse)
LookupType (Pulsar::Proto::CommandLookupTopicResponse)

M

MessageIdData (Pulsar::Proto)
MessageMetadata (Pulsar::Proto)
Mode (Pulsar::Proto::CommandGetTopicsOfNamespace)

P

ProducerAccessMode (Pulsar::Proto)
Proto (Pulsar)
ProtocolVersion (Pulsar::Proto)
Pulsar

S

Schema (Pulsar::Proto)
ServerError (Pulsar::Proto)
SingleMessageMetadata (Pulsar::Proto)
SubType (Pulsar::Proto::CommandSubscribe)
Subscription (Pulsar::Proto)

T

TxnAction (Pulsar::Proto)
Type (Pulsar::Proto::Schema)
Type (Pulsar::Proto::BaseCommand)

V

ValidationError (Pulsar::Proto::CommandAck)