Module: Pulsar::Proto

Defined in:

lib/protobuf/pulsar_api.pb.rb

Constant Summary

Schema =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.Schema").msgclass

MessageIdData =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.MessageIdData").msgclass

KeyValue =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.KeyValue").msgclass

KeyLongValue =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.KeyLongValue").msgclass

IntRange =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.IntRange").msgclass

EncryptionKeys =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.EncryptionKeys").msgclass

MessageMetadata =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.MessageMetadata").msgclass

SingleMessageMetadata =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.SingleMessageMetadata").msgclass

CommandConnect =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandConnect").msgclass

CommandConnected =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandConnected").msgclass

CommandAuthResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAuthResponse").msgclass

CommandAuthChallenge =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAuthChallenge").msgclass

AuthData =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.AuthData").msgclass

KeySharedMeta =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.KeySharedMeta").msgclass

CommandSubscribe =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandSubscribe").msgclass

CommandPartitionedTopicMetadata =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandPartitionedTopicMetadata").msgclass

CommandPartitionedTopicMetadataResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandPartitionedTopicMetadataResponse").msgclass

CommandLookupTopic =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandLookupTopic").msgclass

CommandLookupTopicResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandLookupTopicResponse").msgclass

CommandProducer =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandProducer").msgclass

CommandSend =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandSend").msgclass

CommandSendReceipt =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandSendReceipt").msgclass

CommandSendError =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandSendError").msgclass

CommandMessage =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandMessage").msgclass

CommandAck =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAck").msgclass

CommandAckResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAckResponse").msgclass

CommandActiveConsumerChange =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandActiveConsumerChange").msgclass

CommandFlow =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandFlow").msgclass

CommandUnsubscribe =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandUnsubscribe").msgclass

CommandSeek =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandSeek").msgclass

CommandReachedEndOfTopic =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandReachedEndOfTopic").msgclass

CommandCloseProducer =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandCloseProducer").msgclass

CommandCloseConsumer =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandCloseConsumer").msgclass

CommandRedeliverUnacknowledgedMessages =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandRedeliverUnacknowledgedMessages").msgclass

CommandSuccess =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandSuccess").msgclass

CommandProducerSuccess =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandProducerSuccess").msgclass

CommandError =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandError").msgclass

CommandPing =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandPing").msgclass

CommandPong =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandPong").msgclass

CommandConsumerStats =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandConsumerStats").msgclass

CommandConsumerStatsResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandConsumerStatsResponse").msgclass

CommandGetLastMessageId =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetLastMessageId").msgclass

CommandGetLastMessageIdResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetLastMessageIdResponse").msgclass

CommandGetTopicsOfNamespace =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetTopicsOfNamespace").msgclass

CommandGetTopicsOfNamespaceResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetTopicsOfNamespaceResponse").msgclass

CommandGetSchema =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetSchema").msgclass

CommandGetSchemaResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetSchemaResponse").msgclass

CommandGetOrCreateSchema =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetOrCreateSchema").msgclass

CommandGetOrCreateSchemaResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandGetOrCreateSchemaResponse").msgclass

CommandNewTxn =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandNewTxn").msgclass

CommandNewTxnResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandNewTxnResponse").msgclass

CommandAddPartitionToTxn =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAddPartitionToTxn").msgclass

CommandAddPartitionToTxnResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAddPartitionToTxnResponse").msgclass

Subscription =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.Subscription").msgclass

CommandAddSubscriptionToTxn =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAddSubscriptionToTxn").msgclass

CommandAddSubscriptionToTxnResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandAddSubscriptionToTxnResponse").msgclass

CommandEndTxn =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandEndTxn").msgclass

CommandEndTxnResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandEndTxnResponse").msgclass

CommandEndTxnOnPartition =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandEndTxnOnPartition").msgclass

CommandEndTxnOnPartitionResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandEndTxnOnPartitionResponse").msgclass

CommandEndTxnOnSubscription =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandEndTxnOnSubscription").msgclass

CommandEndTxnOnSubscriptionResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandEndTxnOnSubscriptionResponse").msgclass

BaseCommand =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.BaseCommand").msgclass

CompressionType =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CompressionType").enummodule

ServerError =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.ServerError").enummodule

AuthMethod =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.AuthMethod").enummodule

ProtocolVersion =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.ProtocolVersion").enummodule

KeySharedMode =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.KeySharedMode").enummodule

TxnAction =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.TxnAction").enummodule