Module: Pulsar::Proto

Defined in:

lib/pulsar/proto/PulsarApi_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

BrokerEntryMetadata =

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

CommandConnect =

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

FeatureFlags =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.FeatureFlags").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

CommandTopicMigrated =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandTopicMigrated").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

CommandWatchTopicList =

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

CommandWatchTopicListSuccess =

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

CommandWatchTopicUpdate =

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

CommandWatchTopicListClose =

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

SegmentInfoProto =

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

SegmentBrokerAddress =

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

ScalableTopicDAG =

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

CommandScalableTopicLookup =

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

CommandScalableTopicUpdate =

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

CommandScalableTopicClose =

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

ScalableAssignedSegment =

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

ScalableConsumerAssignment =

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

CommandScalableTopicSubscribe =

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

CommandScalableTopicSubscribeResponse =

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

CommandScalableTopicAssignmentUpdate =

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

CommandWatchScalableTopics =

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

ScalableTopicsSnapshot =

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

ScalableTopicsDiff =

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

CommandWatchScalableTopicsUpdate =

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

CommandWatchScalableTopicsClose =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandWatchScalableTopicsClose").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

CommandTcClientConnectRequest =

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

CommandTcClientConnectResponse =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.CommandTcClientConnectResponse").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

ProducerAccessMode =

::Google::Protobuf::DescriptorPool.generated_pool.lookup("pulsar.proto.ProducerAccessMode").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

SegmentState =

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

ScalableConsumerType =

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

TxnAction =

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