| // Generated by the protocol buffer compiler. DO NOT EDIT! |
| // source: PulsarApi.proto |
| |
| #ifndef PROTOBUF_PulsarApi_2eproto__INCLUDED |
| #define PROTOBUF_PulsarApi_2eproto__INCLUDED |
| |
| #include <string> |
| |
| #include <google/protobuf/stubs/common.h> |
| |
| #if GOOGLE_PROTOBUF_VERSION < 2006000 |
| #error This file was generated by a newer version of protoc which is |
| #error incompatible with your Protocol Buffer headers. Please update |
| #error your headers. |
| #endif |
| #if 2006001 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION |
| #error This file was generated by an older version of protoc which is |
| #error incompatible with your Protocol Buffer headers. Please |
| #error regenerate this file with a newer version of protoc. |
| #endif |
| |
| #include <google/protobuf/generated_message_util.h> |
| #include <google/protobuf/message_lite.h> |
| #include <google/protobuf/repeated_field.h> |
| #include <google/protobuf/extension_set.h> |
| // @@protoc_insertion_point(includes) |
| |
| namespace pulsar { |
| namespace proto { |
| |
| // Internal implementation detail -- do not call these. |
| void protobuf_AddDesc_PulsarApi_2eproto(); |
| void protobuf_AssignDesc_PulsarApi_2eproto(); |
| void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| class MessageIdData; |
| class KeyValue; |
| class MessageMetadata; |
| class SingleMessageMetadata; |
| class CommandConnect; |
| class CommandConnected; |
| class CommandSubscribe; |
| class CommandPartitionedTopicMetadata; |
| class CommandPartitionedTopicMetadataResponse; |
| class CommandLookupTopic; |
| class CommandLookupTopicResponse; |
| class CommandProducer; |
| class CommandSend; |
| class CommandSendReceipt; |
| class CommandSendError; |
| class CommandMessage; |
| class CommandAck; |
| class CommandFlow; |
| class CommandUnsubscribe; |
| class CommandCloseProducer; |
| class CommandCloseConsumer; |
| class CommandRedeliverUnacknowledgedMessages; |
| class CommandSuccess; |
| class CommandProducerSuccess; |
| class CommandError; |
| class CommandPing; |
| class CommandPong; |
| class CommandConsumerStats; |
| class CommandConsumerStatsResponse; |
| class BaseCommand; |
| |
| enum CommandSubscribe_SubType { |
| CommandSubscribe_SubType_Exclusive = 0, |
| CommandSubscribe_SubType_Shared = 1, |
| CommandSubscribe_SubType_Failover = 2 |
| }; |
| bool CommandSubscribe_SubType_IsValid(int value); |
| const CommandSubscribe_SubType CommandSubscribe_SubType_SubType_MIN = CommandSubscribe_SubType_Exclusive; |
| const CommandSubscribe_SubType CommandSubscribe_SubType_SubType_MAX = CommandSubscribe_SubType_Failover; |
| const int CommandSubscribe_SubType_SubType_ARRAYSIZE = CommandSubscribe_SubType_SubType_MAX + 1; |
| |
| enum CommandPartitionedTopicMetadataResponse_LookupType { |
| CommandPartitionedTopicMetadataResponse_LookupType_Success = 0, |
| CommandPartitionedTopicMetadataResponse_LookupType_Failed = 1 |
| }; |
| bool CommandPartitionedTopicMetadataResponse_LookupType_IsValid(int value); |
| const CommandPartitionedTopicMetadataResponse_LookupType CommandPartitionedTopicMetadataResponse_LookupType_LookupType_MIN = CommandPartitionedTopicMetadataResponse_LookupType_Success; |
| const CommandPartitionedTopicMetadataResponse_LookupType CommandPartitionedTopicMetadataResponse_LookupType_LookupType_MAX = CommandPartitionedTopicMetadataResponse_LookupType_Failed; |
| const int CommandPartitionedTopicMetadataResponse_LookupType_LookupType_ARRAYSIZE = CommandPartitionedTopicMetadataResponse_LookupType_LookupType_MAX + 1; |
| |
| enum CommandLookupTopicResponse_LookupType { |
| CommandLookupTopicResponse_LookupType_Redirect = 0, |
| CommandLookupTopicResponse_LookupType_Connect = 1, |
| CommandLookupTopicResponse_LookupType_Failed = 2 |
| }; |
| bool CommandLookupTopicResponse_LookupType_IsValid(int value); |
| const CommandLookupTopicResponse_LookupType CommandLookupTopicResponse_LookupType_LookupType_MIN = CommandLookupTopicResponse_LookupType_Redirect; |
| const CommandLookupTopicResponse_LookupType CommandLookupTopicResponse_LookupType_LookupType_MAX = CommandLookupTopicResponse_LookupType_Failed; |
| const int CommandLookupTopicResponse_LookupType_LookupType_ARRAYSIZE = CommandLookupTopicResponse_LookupType_LookupType_MAX + 1; |
| |
| enum CommandAck_AckType { |
| CommandAck_AckType_Individual = 0, |
| CommandAck_AckType_Cumulative = 1 |
| }; |
| bool CommandAck_AckType_IsValid(int value); |
| const CommandAck_AckType CommandAck_AckType_AckType_MIN = CommandAck_AckType_Individual; |
| const CommandAck_AckType CommandAck_AckType_AckType_MAX = CommandAck_AckType_Cumulative; |
| const int CommandAck_AckType_AckType_ARRAYSIZE = CommandAck_AckType_AckType_MAX + 1; |
| |
| enum CommandAck_ValidationError { |
| CommandAck_ValidationError_UncompressedSizeCorruption = 0, |
| CommandAck_ValidationError_DecompressionError = 1, |
| CommandAck_ValidationError_ChecksumMismatch = 2, |
| CommandAck_ValidationError_BatchDeSerializeError = 3 |
| }; |
| bool CommandAck_ValidationError_IsValid(int value); |
| const CommandAck_ValidationError CommandAck_ValidationError_ValidationError_MIN = CommandAck_ValidationError_UncompressedSizeCorruption; |
| const CommandAck_ValidationError CommandAck_ValidationError_ValidationError_MAX = CommandAck_ValidationError_BatchDeSerializeError; |
| const int CommandAck_ValidationError_ValidationError_ARRAYSIZE = CommandAck_ValidationError_ValidationError_MAX + 1; |
| |
| enum BaseCommand_Type { |
| BaseCommand_Type_CONNECT = 2, |
| BaseCommand_Type_CONNECTED = 3, |
| BaseCommand_Type_SUBSCRIBE = 4, |
| BaseCommand_Type_PRODUCER = 5, |
| BaseCommand_Type_SEND = 6, |
| BaseCommand_Type_SEND_RECEIPT = 7, |
| BaseCommand_Type_SEND_ERROR = 8, |
| BaseCommand_Type_MESSAGE = 9, |
| BaseCommand_Type_ACK = 10, |
| BaseCommand_Type_FLOW = 11, |
| BaseCommand_Type_UNSUBSCRIBE = 12, |
| BaseCommand_Type_SUCCESS = 13, |
| BaseCommand_Type_ERROR = 14, |
| BaseCommand_Type_CLOSE_PRODUCER = 15, |
| BaseCommand_Type_CLOSE_CONSUMER = 16, |
| BaseCommand_Type_PRODUCER_SUCCESS = 17, |
| BaseCommand_Type_PING = 18, |
| BaseCommand_Type_PONG = 19, |
| BaseCommand_Type_REDELIVER_UNACKNOWLEDGED_MESSAGES = 20, |
| BaseCommand_Type_PARTITIONED_METADATA = 21, |
| BaseCommand_Type_PARTITIONED_METADATA_RESPONSE = 22, |
| BaseCommand_Type_LOOKUP = 23, |
| BaseCommand_Type_LOOKUP_RESPONSE = 24, |
| BaseCommand_Type_CONSUMER_STATS = 25, |
| BaseCommand_Type_CONSUMER_STATS_RESPONSE = 26 |
| }; |
| bool BaseCommand_Type_IsValid(int value); |
| const BaseCommand_Type BaseCommand_Type_Type_MIN = BaseCommand_Type_CONNECT; |
| const BaseCommand_Type BaseCommand_Type_Type_MAX = BaseCommand_Type_CONSUMER_STATS_RESPONSE; |
| const int BaseCommand_Type_Type_ARRAYSIZE = BaseCommand_Type_Type_MAX + 1; |
| |
| enum CompressionType { |
| NONE = 0, |
| LZ4 = 1, |
| ZLIB = 2 |
| }; |
| bool CompressionType_IsValid(int value); |
| const CompressionType CompressionType_MIN = NONE; |
| const CompressionType CompressionType_MAX = ZLIB; |
| const int CompressionType_ARRAYSIZE = CompressionType_MAX + 1; |
| |
| enum ServerError { |
| 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 |
| }; |
| bool ServerError_IsValid(int value); |
| const ServerError ServerError_MIN = UnknownError; |
| const ServerError ServerError_MAX = ConsumerNotFound; |
| const int ServerError_ARRAYSIZE = ServerError_MAX + 1; |
| |
| enum AuthMethod { |
| AuthMethodNone = 0, |
| AuthMethodYcaV1 = 1, |
| AuthMethodAthens = 2 |
| }; |
| bool AuthMethod_IsValid(int value); |
| const AuthMethod AuthMethod_MIN = AuthMethodNone; |
| const AuthMethod AuthMethod_MAX = AuthMethodAthens; |
| const int AuthMethod_ARRAYSIZE = AuthMethod_MAX + 1; |
| |
| enum ProtocolVersion { |
| v0 = 0, |
| v1 = 1, |
| v2 = 2, |
| v3 = 3, |
| v4 = 4, |
| v5 = 5, |
| v6 = 6, |
| v7 = 7 |
| }; |
| bool ProtocolVersion_IsValid(int value); |
| const ProtocolVersion ProtocolVersion_MIN = v0; |
| const ProtocolVersion ProtocolVersion_MAX = v7; |
| const int ProtocolVersion_ARRAYSIZE = ProtocolVersion_MAX + 1; |
| |
| // =================================================================== |
| |
| class MessageIdData : public ::google::protobuf::MessageLite { |
| public: |
| MessageIdData(); |
| virtual ~MessageIdData(); |
| |
| MessageIdData(const MessageIdData& from); |
| |
| inline MessageIdData& operator=(const MessageIdData& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const MessageIdData& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const MessageIdData* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(MessageIdData* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| MessageIdData* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const MessageIdData& from); |
| void MergeFrom(const MessageIdData& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required uint64 ledgerId = 1; |
| inline bool has_ledgerid() const; |
| inline void clear_ledgerid(); |
| static const int kLedgerIdFieldNumber = 1; |
| inline ::google::protobuf::uint64 ledgerid() const; |
| inline void set_ledgerid(::google::protobuf::uint64 value); |
| |
| // required uint64 entryId = 2; |
| inline bool has_entryid() const; |
| inline void clear_entryid(); |
| static const int kEntryIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 entryid() const; |
| inline void set_entryid(::google::protobuf::uint64 value); |
| |
| // optional int32 partition = 3 [default = -1]; |
| inline bool has_partition() const; |
| inline void clear_partition(); |
| static const int kPartitionFieldNumber = 3; |
| inline ::google::protobuf::int32 partition() const; |
| inline void set_partition(::google::protobuf::int32 value); |
| |
| // optional int32 batch_index = 4 [default = -1]; |
| inline bool has_batch_index() const; |
| inline void clear_batch_index(); |
| static const int kBatchIndexFieldNumber = 4; |
| inline ::google::protobuf::int32 batch_index() const; |
| inline void set_batch_index(::google::protobuf::int32 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.MessageIdData) |
| private: |
| inline void set_has_ledgerid(); |
| inline void clear_has_ledgerid(); |
| inline void set_has_entryid(); |
| inline void clear_has_entryid(); |
| inline void set_has_partition(); |
| inline void clear_has_partition(); |
| inline void set_has_batch_index(); |
| inline void clear_has_batch_index(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 ledgerid_; |
| ::google::protobuf::uint64 entryid_; |
| ::google::protobuf::int32 partition_; |
| ::google::protobuf::int32 batch_index_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static MessageIdData* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class KeyValue : public ::google::protobuf::MessageLite { |
| public: |
| KeyValue(); |
| virtual ~KeyValue(); |
| |
| KeyValue(const KeyValue& from); |
| |
| inline KeyValue& operator=(const KeyValue& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const KeyValue& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const KeyValue* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(KeyValue* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| KeyValue* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const KeyValue& from); |
| void MergeFrom(const KeyValue& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string key = 1; |
| inline bool has_key() const; |
| inline void clear_key(); |
| static const int kKeyFieldNumber = 1; |
| inline const ::std::string& key() const; |
| inline void set_key(const ::std::string& value); |
| inline void set_key(const char* value); |
| inline void set_key(const char* value, size_t size); |
| inline ::std::string* mutable_key(); |
| inline ::std::string* release_key(); |
| inline void set_allocated_key(::std::string* key); |
| |
| // required string value = 2; |
| inline bool has_value() const; |
| inline void clear_value(); |
| static const int kValueFieldNumber = 2; |
| inline const ::std::string& value() const; |
| inline void set_value(const ::std::string& value); |
| inline void set_value(const char* value); |
| inline void set_value(const char* value, size_t size); |
| inline ::std::string* mutable_value(); |
| inline ::std::string* release_value(); |
| inline void set_allocated_value(::std::string* value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.KeyValue) |
| private: |
| inline void set_has_key(); |
| inline void clear_has_key(); |
| inline void set_has_value(); |
| inline void clear_has_value(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* key_; |
| ::std::string* value_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static KeyValue* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class MessageMetadata : public ::google::protobuf::MessageLite { |
| public: |
| MessageMetadata(); |
| virtual ~MessageMetadata(); |
| |
| MessageMetadata(const MessageMetadata& from); |
| |
| inline MessageMetadata& operator=(const MessageMetadata& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const MessageMetadata& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const MessageMetadata* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(MessageMetadata* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| MessageMetadata* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const MessageMetadata& from); |
| void MergeFrom(const MessageMetadata& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string producer_name = 1; |
| inline bool has_producer_name() const; |
| inline void clear_producer_name(); |
| static const int kProducerNameFieldNumber = 1; |
| inline const ::std::string& producer_name() const; |
| inline void set_producer_name(const ::std::string& value); |
| inline void set_producer_name(const char* value); |
| inline void set_producer_name(const char* value, size_t size); |
| inline ::std::string* mutable_producer_name(); |
| inline ::std::string* release_producer_name(); |
| inline void set_allocated_producer_name(::std::string* producer_name); |
| |
| // required uint64 sequence_id = 2; |
| inline bool has_sequence_id() const; |
| inline void clear_sequence_id(); |
| static const int kSequenceIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 sequence_id() const; |
| inline void set_sequence_id(::google::protobuf::uint64 value); |
| |
| // required uint64 publish_time = 3; |
| inline bool has_publish_time() const; |
| inline void clear_publish_time(); |
| static const int kPublishTimeFieldNumber = 3; |
| inline ::google::protobuf::uint64 publish_time() const; |
| inline void set_publish_time(::google::protobuf::uint64 value); |
| |
| // repeated .pulsar.proto.KeyValue properties = 4; |
| inline int properties_size() const; |
| inline void clear_properties(); |
| static const int kPropertiesFieldNumber = 4; |
| inline const ::pulsar::proto::KeyValue& properties(int index) const; |
| inline ::pulsar::proto::KeyValue* mutable_properties(int index); |
| inline ::pulsar::proto::KeyValue* add_properties(); |
| inline const ::google::protobuf::RepeatedPtrField< ::pulsar::proto::KeyValue >& |
| properties() const; |
| inline ::google::protobuf::RepeatedPtrField< ::pulsar::proto::KeyValue >* |
| mutable_properties(); |
| |
| // optional string replicated_from = 5; |
| inline bool has_replicated_from() const; |
| inline void clear_replicated_from(); |
| static const int kReplicatedFromFieldNumber = 5; |
| inline const ::std::string& replicated_from() const; |
| inline void set_replicated_from(const ::std::string& value); |
| inline void set_replicated_from(const char* value); |
| inline void set_replicated_from(const char* value, size_t size); |
| inline ::std::string* mutable_replicated_from(); |
| inline ::std::string* release_replicated_from(); |
| inline void set_allocated_replicated_from(::std::string* replicated_from); |
| |
| // optional string partition_key = 6; |
| inline bool has_partition_key() const; |
| inline void clear_partition_key(); |
| static const int kPartitionKeyFieldNumber = 6; |
| inline const ::std::string& partition_key() const; |
| inline void set_partition_key(const ::std::string& value); |
| inline void set_partition_key(const char* value); |
| inline void set_partition_key(const char* value, size_t size); |
| inline ::std::string* mutable_partition_key(); |
| inline ::std::string* release_partition_key(); |
| inline void set_allocated_partition_key(::std::string* partition_key); |
| |
| // repeated string replicate_to = 7; |
| inline int replicate_to_size() const; |
| inline void clear_replicate_to(); |
| static const int kReplicateToFieldNumber = 7; |
| inline const ::std::string& replicate_to(int index) const; |
| inline ::std::string* mutable_replicate_to(int index); |
| inline void set_replicate_to(int index, const ::std::string& value); |
| inline void set_replicate_to(int index, const char* value); |
| inline void set_replicate_to(int index, const char* value, size_t size); |
| inline ::std::string* add_replicate_to(); |
| inline void add_replicate_to(const ::std::string& value); |
| inline void add_replicate_to(const char* value); |
| inline void add_replicate_to(const char* value, size_t size); |
| inline const ::google::protobuf::RepeatedPtrField< ::std::string>& replicate_to() const; |
| inline ::google::protobuf::RepeatedPtrField< ::std::string>* mutable_replicate_to(); |
| |
| // optional .pulsar.proto.CompressionType compression = 8 [default = NONE]; |
| inline bool has_compression() const; |
| inline void clear_compression(); |
| static const int kCompressionFieldNumber = 8; |
| inline ::pulsar::proto::CompressionType compression() const; |
| inline void set_compression(::pulsar::proto::CompressionType value); |
| |
| // optional uint32 uncompressed_size = 9 [default = 0]; |
| inline bool has_uncompressed_size() const; |
| inline void clear_uncompressed_size(); |
| static const int kUncompressedSizeFieldNumber = 9; |
| inline ::google::protobuf::uint32 uncompressed_size() const; |
| inline void set_uncompressed_size(::google::protobuf::uint32 value); |
| |
| // optional int32 num_messages_in_batch = 11 [default = 1]; |
| inline bool has_num_messages_in_batch() const; |
| inline void clear_num_messages_in_batch(); |
| static const int kNumMessagesInBatchFieldNumber = 11; |
| inline ::google::protobuf::int32 num_messages_in_batch() const; |
| inline void set_num_messages_in_batch(::google::protobuf::int32 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.MessageMetadata) |
| private: |
| inline void set_has_producer_name(); |
| inline void clear_has_producer_name(); |
| inline void set_has_sequence_id(); |
| inline void clear_has_sequence_id(); |
| inline void set_has_publish_time(); |
| inline void clear_has_publish_time(); |
| inline void set_has_replicated_from(); |
| inline void clear_has_replicated_from(); |
| inline void set_has_partition_key(); |
| inline void clear_has_partition_key(); |
| inline void set_has_compression(); |
| inline void clear_has_compression(); |
| inline void set_has_uncompressed_size(); |
| inline void clear_has_uncompressed_size(); |
| inline void set_has_num_messages_in_batch(); |
| inline void clear_has_num_messages_in_batch(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* producer_name_; |
| ::google::protobuf::uint64 sequence_id_; |
| ::google::protobuf::uint64 publish_time_; |
| ::google::protobuf::RepeatedPtrField< ::pulsar::proto::KeyValue > properties_; |
| ::std::string* replicated_from_; |
| ::std::string* partition_key_; |
| ::google::protobuf::RepeatedPtrField< ::std::string> replicate_to_; |
| int compression_; |
| ::google::protobuf::uint32 uncompressed_size_; |
| ::google::protobuf::int32 num_messages_in_batch_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static MessageMetadata* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class SingleMessageMetadata : public ::google::protobuf::MessageLite { |
| public: |
| SingleMessageMetadata(); |
| virtual ~SingleMessageMetadata(); |
| |
| SingleMessageMetadata(const SingleMessageMetadata& from); |
| |
| inline SingleMessageMetadata& operator=(const SingleMessageMetadata& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const SingleMessageMetadata& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const SingleMessageMetadata* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(SingleMessageMetadata* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| SingleMessageMetadata* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const SingleMessageMetadata& from); |
| void MergeFrom(const SingleMessageMetadata& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // repeated .pulsar.proto.KeyValue properties = 1; |
| inline int properties_size() const; |
| inline void clear_properties(); |
| static const int kPropertiesFieldNumber = 1; |
| inline const ::pulsar::proto::KeyValue& properties(int index) const; |
| inline ::pulsar::proto::KeyValue* mutable_properties(int index); |
| inline ::pulsar::proto::KeyValue* add_properties(); |
| inline const ::google::protobuf::RepeatedPtrField< ::pulsar::proto::KeyValue >& |
| properties() const; |
| inline ::google::protobuf::RepeatedPtrField< ::pulsar::proto::KeyValue >* |
| mutable_properties(); |
| |
| // optional string partition_key = 2; |
| inline bool has_partition_key() const; |
| inline void clear_partition_key(); |
| static const int kPartitionKeyFieldNumber = 2; |
| inline const ::std::string& partition_key() const; |
| inline void set_partition_key(const ::std::string& value); |
| inline void set_partition_key(const char* value); |
| inline void set_partition_key(const char* value, size_t size); |
| inline ::std::string* mutable_partition_key(); |
| inline ::std::string* release_partition_key(); |
| inline void set_allocated_partition_key(::std::string* partition_key); |
| |
| // required int32 payload_size = 3; |
| inline bool has_payload_size() const; |
| inline void clear_payload_size(); |
| static const int kPayloadSizeFieldNumber = 3; |
| inline ::google::protobuf::int32 payload_size() const; |
| inline void set_payload_size(::google::protobuf::int32 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.SingleMessageMetadata) |
| private: |
| inline void set_has_partition_key(); |
| inline void clear_has_partition_key(); |
| inline void set_has_payload_size(); |
| inline void clear_has_payload_size(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::RepeatedPtrField< ::pulsar::proto::KeyValue > properties_; |
| ::std::string* partition_key_; |
| ::google::protobuf::int32 payload_size_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static SingleMessageMetadata* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandConnect : public ::google::protobuf::MessageLite { |
| public: |
| CommandConnect(); |
| virtual ~CommandConnect(); |
| |
| CommandConnect(const CommandConnect& from); |
| |
| inline CommandConnect& operator=(const CommandConnect& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandConnect& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandConnect* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandConnect* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandConnect* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandConnect& from); |
| void MergeFrom(const CommandConnect& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string client_version = 1; |
| inline bool has_client_version() const; |
| inline void clear_client_version(); |
| static const int kClientVersionFieldNumber = 1; |
| inline const ::std::string& client_version() const; |
| inline void set_client_version(const ::std::string& value); |
| inline void set_client_version(const char* value); |
| inline void set_client_version(const char* value, size_t size); |
| inline ::std::string* mutable_client_version(); |
| inline ::std::string* release_client_version(); |
| inline void set_allocated_client_version(::std::string* client_version); |
| |
| // optional .pulsar.proto.AuthMethod auth_method = 2; |
| inline bool has_auth_method() const; |
| inline void clear_auth_method(); |
| static const int kAuthMethodFieldNumber = 2; |
| inline ::pulsar::proto::AuthMethod auth_method() const; |
| inline void set_auth_method(::pulsar::proto::AuthMethod value); |
| |
| // optional string auth_method_name = 5; |
| inline bool has_auth_method_name() const; |
| inline void clear_auth_method_name(); |
| static const int kAuthMethodNameFieldNumber = 5; |
| inline const ::std::string& auth_method_name() const; |
| inline void set_auth_method_name(const ::std::string& value); |
| inline void set_auth_method_name(const char* value); |
| inline void set_auth_method_name(const char* value, size_t size); |
| inline ::std::string* mutable_auth_method_name(); |
| inline ::std::string* release_auth_method_name(); |
| inline void set_allocated_auth_method_name(::std::string* auth_method_name); |
| |
| // optional bytes auth_data = 3; |
| inline bool has_auth_data() const; |
| inline void clear_auth_data(); |
| static const int kAuthDataFieldNumber = 3; |
| inline const ::std::string& auth_data() const; |
| inline void set_auth_data(const ::std::string& value); |
| inline void set_auth_data(const char* value); |
| inline void set_auth_data(const void* value, size_t size); |
| inline ::std::string* mutable_auth_data(); |
| inline ::std::string* release_auth_data(); |
| inline void set_allocated_auth_data(::std::string* auth_data); |
| |
| // optional int32 protocol_version = 4 [default = 0]; |
| inline bool has_protocol_version() const; |
| inline void clear_protocol_version(); |
| static const int kProtocolVersionFieldNumber = 4; |
| inline ::google::protobuf::int32 protocol_version() const; |
| inline void set_protocol_version(::google::protobuf::int32 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandConnect) |
| private: |
| inline void set_has_client_version(); |
| inline void clear_has_client_version(); |
| inline void set_has_auth_method(); |
| inline void clear_has_auth_method(); |
| inline void set_has_auth_method_name(); |
| inline void clear_has_auth_method_name(); |
| inline void set_has_auth_data(); |
| inline void clear_has_auth_data(); |
| inline void set_has_protocol_version(); |
| inline void clear_has_protocol_version(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* client_version_; |
| ::std::string* auth_method_name_; |
| int auth_method_; |
| ::google::protobuf::int32 protocol_version_; |
| ::std::string* auth_data_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandConnect* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandConnected : public ::google::protobuf::MessageLite { |
| public: |
| CommandConnected(); |
| virtual ~CommandConnected(); |
| |
| CommandConnected(const CommandConnected& from); |
| |
| inline CommandConnected& operator=(const CommandConnected& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandConnected& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandConnected* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandConnected* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandConnected* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandConnected& from); |
| void MergeFrom(const CommandConnected& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string server_version = 1; |
| inline bool has_server_version() const; |
| inline void clear_server_version(); |
| static const int kServerVersionFieldNumber = 1; |
| inline const ::std::string& server_version() const; |
| inline void set_server_version(const ::std::string& value); |
| inline void set_server_version(const char* value); |
| inline void set_server_version(const char* value, size_t size); |
| inline ::std::string* mutable_server_version(); |
| inline ::std::string* release_server_version(); |
| inline void set_allocated_server_version(::std::string* server_version); |
| |
| // optional int32 protocol_version = 2 [default = 0]; |
| inline bool has_protocol_version() const; |
| inline void clear_protocol_version(); |
| static const int kProtocolVersionFieldNumber = 2; |
| inline ::google::protobuf::int32 protocol_version() const; |
| inline void set_protocol_version(::google::protobuf::int32 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandConnected) |
| private: |
| inline void set_has_server_version(); |
| inline void clear_has_server_version(); |
| inline void set_has_protocol_version(); |
| inline void clear_has_protocol_version(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* server_version_; |
| ::google::protobuf::int32 protocol_version_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandConnected* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandSubscribe : public ::google::protobuf::MessageLite { |
| public: |
| CommandSubscribe(); |
| virtual ~CommandSubscribe(); |
| |
| CommandSubscribe(const CommandSubscribe& from); |
| |
| inline CommandSubscribe& operator=(const CommandSubscribe& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandSubscribe& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandSubscribe* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandSubscribe* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandSubscribe* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandSubscribe& from); |
| void MergeFrom(const CommandSubscribe& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| typedef CommandSubscribe_SubType SubType; |
| static const SubType Exclusive = CommandSubscribe_SubType_Exclusive; |
| static const SubType Shared = CommandSubscribe_SubType_Shared; |
| static const SubType Failover = CommandSubscribe_SubType_Failover; |
| static inline bool SubType_IsValid(int value) { |
| return CommandSubscribe_SubType_IsValid(value); |
| } |
| static const SubType SubType_MIN = |
| CommandSubscribe_SubType_SubType_MIN; |
| static const SubType SubType_MAX = |
| CommandSubscribe_SubType_SubType_MAX; |
| static const int SubType_ARRAYSIZE = |
| CommandSubscribe_SubType_SubType_ARRAYSIZE; |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string topic = 1; |
| inline bool has_topic() const; |
| inline void clear_topic(); |
| static const int kTopicFieldNumber = 1; |
| inline const ::std::string& topic() const; |
| inline void set_topic(const ::std::string& value); |
| inline void set_topic(const char* value); |
| inline void set_topic(const char* value, size_t size); |
| inline ::std::string* mutable_topic(); |
| inline ::std::string* release_topic(); |
| inline void set_allocated_topic(::std::string* topic); |
| |
| // required string subscription = 2; |
| inline bool has_subscription() const; |
| inline void clear_subscription(); |
| static const int kSubscriptionFieldNumber = 2; |
| inline const ::std::string& subscription() const; |
| inline void set_subscription(const ::std::string& value); |
| inline void set_subscription(const char* value); |
| inline void set_subscription(const char* value, size_t size); |
| inline ::std::string* mutable_subscription(); |
| inline ::std::string* release_subscription(); |
| inline void set_allocated_subscription(::std::string* subscription); |
| |
| // required .pulsar.proto.CommandSubscribe.SubType subType = 3; |
| inline bool has_subtype() const; |
| inline void clear_subtype(); |
| static const int kSubTypeFieldNumber = 3; |
| inline ::pulsar::proto::CommandSubscribe_SubType subtype() const; |
| inline void set_subtype(::pulsar::proto::CommandSubscribe_SubType value); |
| |
| // required uint64 consumer_id = 4; |
| inline bool has_consumer_id() const; |
| inline void clear_consumer_id(); |
| static const int kConsumerIdFieldNumber = 4; |
| inline ::google::protobuf::uint64 consumer_id() const; |
| inline void set_consumer_id(::google::protobuf::uint64 value); |
| |
| // required uint64 request_id = 5; |
| inline bool has_request_id() const; |
| inline void clear_request_id(); |
| static const int kRequestIdFieldNumber = 5; |
| inline ::google::protobuf::uint64 request_id() const; |
| inline void set_request_id(::google::protobuf::uint64 value); |
| |
| // optional string consumer_name = 6; |
| inline bool has_consumer_name() const; |
| inline void clear_consumer_name(); |
| static const int kConsumerNameFieldNumber = 6; |
| inline const ::std::string& consumer_name() const; |
| inline void set_consumer_name(const ::std::string& value); |
| inline void set_consumer_name(const char* value); |
| inline void set_consumer_name(const char* value, size_t size); |
| inline ::std::string* mutable_consumer_name(); |
| inline ::std::string* release_consumer_name(); |
| inline void set_allocated_consumer_name(::std::string* consumer_name); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandSubscribe) |
| private: |
| inline void set_has_topic(); |
| inline void clear_has_topic(); |
| inline void set_has_subscription(); |
| inline void clear_has_subscription(); |
| inline void set_has_subtype(); |
| inline void clear_has_subtype(); |
| inline void set_has_consumer_id(); |
| inline void clear_has_consumer_id(); |
| inline void set_has_request_id(); |
| inline void clear_has_request_id(); |
| inline void set_has_consumer_name(); |
| inline void clear_has_consumer_name(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* topic_; |
| ::std::string* subscription_; |
| ::google::protobuf::uint64 consumer_id_; |
| ::google::protobuf::uint64 request_id_; |
| ::std::string* consumer_name_; |
| int subtype_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandSubscribe* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandPartitionedTopicMetadata : public ::google::protobuf::MessageLite { |
| public: |
| CommandPartitionedTopicMetadata(); |
| virtual ~CommandPartitionedTopicMetadata(); |
| |
| CommandPartitionedTopicMetadata(const CommandPartitionedTopicMetadata& from); |
| |
| inline CommandPartitionedTopicMetadata& operator=(const CommandPartitionedTopicMetadata& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandPartitionedTopicMetadata& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandPartitionedTopicMetadata* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandPartitionedTopicMetadata* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandPartitionedTopicMetadata* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandPartitionedTopicMetadata& from); |
| void MergeFrom(const CommandPartitionedTopicMetadata& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string topic = 1; |
| inline bool has_topic() const; |
| inline void clear_topic(); |
| static const int kTopicFieldNumber = 1; |
| inline const ::std::string& topic() const; |
| inline void set_topic(const ::std::string& value); |
| inline void set_topic(const char* value); |
| inline void set_topic(const char* value, size_t size); |
| inline ::std::string* mutable_topic(); |
| inline ::std::string* release_topic(); |
| inline void set_allocated_topic(::std::string* topic); |
| |
| // required uint64 request_id = 2; |
| inline bool has_request_id() const; |
| inline void clear_request_id(); |
| static const int kRequestIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 request_id() const; |
| inline void set_request_id(::google::protobuf::uint64 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandPartitionedTopicMetadata) |
| private: |
| inline void set_has_topic(); |
| inline void clear_has_topic(); |
| inline void set_has_request_id(); |
| inline void clear_has_request_id(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* topic_; |
| ::google::protobuf::uint64 request_id_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandPartitionedTopicMetadata* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandPartitionedTopicMetadataResponse : public ::google::protobuf::MessageLite { |
| public: |
| CommandPartitionedTopicMetadataResponse(); |
| virtual ~CommandPartitionedTopicMetadataResponse(); |
| |
| CommandPartitionedTopicMetadataResponse(const CommandPartitionedTopicMetadataResponse& from); |
| |
| inline CommandPartitionedTopicMetadataResponse& operator=(const CommandPartitionedTopicMetadataResponse& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandPartitionedTopicMetadataResponse& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandPartitionedTopicMetadataResponse* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandPartitionedTopicMetadataResponse* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandPartitionedTopicMetadataResponse* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandPartitionedTopicMetadataResponse& from); |
| void MergeFrom(const CommandPartitionedTopicMetadataResponse& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| typedef CommandPartitionedTopicMetadataResponse_LookupType LookupType; |
| static const LookupType Success = CommandPartitionedTopicMetadataResponse_LookupType_Success; |
| static const LookupType Failed = CommandPartitionedTopicMetadataResponse_LookupType_Failed; |
| static inline bool LookupType_IsValid(int value) { |
| return CommandPartitionedTopicMetadataResponse_LookupType_IsValid(value); |
| } |
| static const LookupType LookupType_MIN = |
| CommandPartitionedTopicMetadataResponse_LookupType_LookupType_MIN; |
| static const LookupType LookupType_MAX = |
| CommandPartitionedTopicMetadataResponse_LookupType_LookupType_MAX; |
| static const int LookupType_ARRAYSIZE = |
| CommandPartitionedTopicMetadataResponse_LookupType_LookupType_ARRAYSIZE; |
| |
| // accessors ------------------------------------------------------- |
| |
| // optional uint32 partitions = 1; |
| inline bool has_partitions() const; |
| inline void clear_partitions(); |
| static const int kPartitionsFieldNumber = 1; |
| inline ::google::protobuf::uint32 partitions() const; |
| inline void set_partitions(::google::protobuf::uint32 value); |
| |
| // required uint64 request_id = 2; |
| inline bool has_request_id() const; |
| inline void clear_request_id(); |
| static const int kRequestIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 request_id() const; |
| inline void set_request_id(::google::protobuf::uint64 value); |
| |
| // optional .pulsar.proto.CommandPartitionedTopicMetadataResponse.LookupType response = 3; |
| inline bool has_response() const; |
| inline void clear_response(); |
| static const int kResponseFieldNumber = 3; |
| inline ::pulsar::proto::CommandPartitionedTopicMetadataResponse_LookupType response() const; |
| inline void set_response(::pulsar::proto::CommandPartitionedTopicMetadataResponse_LookupType value); |
| |
| // optional .pulsar.proto.ServerError error = 4; |
| inline bool has_error() const; |
| inline void clear_error(); |
| static const int kErrorFieldNumber = 4; |
| inline ::pulsar::proto::ServerError error() const; |
| inline void set_error(::pulsar::proto::ServerError value); |
| |
| // optional string message = 5; |
| inline bool has_message() const; |
| inline void clear_message(); |
| static const int kMessageFieldNumber = 5; |
| inline const ::std::string& message() const; |
| inline void set_message(const ::std::string& value); |
| inline void set_message(const char* value); |
| inline void set_message(const char* value, size_t size); |
| inline ::std::string* mutable_message(); |
| inline ::std::string* release_message(); |
| inline void set_allocated_message(::std::string* message); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandPartitionedTopicMetadataResponse) |
| private: |
| inline void set_has_partitions(); |
| inline void clear_has_partitions(); |
| inline void set_has_request_id(); |
| inline void clear_has_request_id(); |
| inline void set_has_response(); |
| inline void clear_has_response(); |
| inline void set_has_error(); |
| inline void clear_has_error(); |
| inline void set_has_message(); |
| inline void clear_has_message(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 request_id_; |
| ::google::protobuf::uint32 partitions_; |
| int response_; |
| ::std::string* message_; |
| int error_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandPartitionedTopicMetadataResponse* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandLookupTopic : public ::google::protobuf::MessageLite { |
| public: |
| CommandLookupTopic(); |
| virtual ~CommandLookupTopic(); |
| |
| CommandLookupTopic(const CommandLookupTopic& from); |
| |
| inline CommandLookupTopic& operator=(const CommandLookupTopic& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandLookupTopic& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandLookupTopic* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandLookupTopic* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandLookupTopic* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandLookupTopic& from); |
| void MergeFrom(const CommandLookupTopic& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string topic = 1; |
| inline bool has_topic() const; |
| inline void clear_topic(); |
| static const int kTopicFieldNumber = 1; |
| inline const ::std::string& topic() const; |
| inline void set_topic(const ::std::string& value); |
| inline void set_topic(const char* value); |
| inline void set_topic(const char* value, size_t size); |
| inline ::std::string* mutable_topic(); |
| inline ::std::string* release_topic(); |
| inline void set_allocated_topic(::std::string* topic); |
| |
| // required uint64 request_id = 2; |
| inline bool has_request_id() const; |
| inline void clear_request_id(); |
| static const int kRequestIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 request_id() const; |
| inline void set_request_id(::google::protobuf::uint64 value); |
| |
| // optional bool authoritative = 3 [default = false]; |
| inline bool has_authoritative() const; |
| inline void clear_authoritative(); |
| static const int kAuthoritativeFieldNumber = 3; |
| inline bool authoritative() const; |
| inline void set_authoritative(bool value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandLookupTopic) |
| private: |
| inline void set_has_topic(); |
| inline void clear_has_topic(); |
| inline void set_has_request_id(); |
| inline void clear_has_request_id(); |
| inline void set_has_authoritative(); |
| inline void clear_has_authoritative(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* topic_; |
| ::google::protobuf::uint64 request_id_; |
| bool authoritative_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandLookupTopic* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandLookupTopicResponse : public ::google::protobuf::MessageLite { |
| public: |
| CommandLookupTopicResponse(); |
| virtual ~CommandLookupTopicResponse(); |
| |
| CommandLookupTopicResponse(const CommandLookupTopicResponse& from); |
| |
| inline CommandLookupTopicResponse& operator=(const CommandLookupTopicResponse& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandLookupTopicResponse& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandLookupTopicResponse* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandLookupTopicResponse* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandLookupTopicResponse* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandLookupTopicResponse& from); |
| void MergeFrom(const CommandLookupTopicResponse& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| typedef CommandLookupTopicResponse_LookupType LookupType; |
| static const LookupType Redirect = CommandLookupTopicResponse_LookupType_Redirect; |
| static const LookupType Connect = CommandLookupTopicResponse_LookupType_Connect; |
| static const LookupType Failed = CommandLookupTopicResponse_LookupType_Failed; |
| static inline bool LookupType_IsValid(int value) { |
| return CommandLookupTopicResponse_LookupType_IsValid(value); |
| } |
| static const LookupType LookupType_MIN = |
| CommandLookupTopicResponse_LookupType_LookupType_MIN; |
| static const LookupType LookupType_MAX = |
| CommandLookupTopicResponse_LookupType_LookupType_MAX; |
| static const int LookupType_ARRAYSIZE = |
| CommandLookupTopicResponse_LookupType_LookupType_ARRAYSIZE; |
| |
| // accessors ------------------------------------------------------- |
| |
| // optional string brokerServiceUrl = 1; |
| inline bool has_brokerserviceurl() const; |
| inline void clear_brokerserviceurl(); |
| static const int kBrokerServiceUrlFieldNumber = 1; |
| inline const ::std::string& brokerserviceurl() const; |
| inline void set_brokerserviceurl(const ::std::string& value); |
| inline void set_brokerserviceurl(const char* value); |
| inline void set_brokerserviceurl(const char* value, size_t size); |
| inline ::std::string* mutable_brokerserviceurl(); |
| inline ::std::string* release_brokerserviceurl(); |
| inline void set_allocated_brokerserviceurl(::std::string* brokerserviceurl); |
| |
| // optional string brokerServiceUrlTls = 2; |
| inline bool has_brokerserviceurltls() const; |
| inline void clear_brokerserviceurltls(); |
| static const int kBrokerServiceUrlTlsFieldNumber = 2; |
| inline const ::std::string& brokerserviceurltls() const; |
| inline void set_brokerserviceurltls(const ::std::string& value); |
| inline void set_brokerserviceurltls(const char* value); |
| inline void set_brokerserviceurltls(const char* value, size_t size); |
| inline ::std::string* mutable_brokerserviceurltls(); |
| inline ::std::string* release_brokerserviceurltls(); |
| inline void set_allocated_brokerserviceurltls(::std::string* brokerserviceurltls); |
| |
| // optional .pulsar.proto.CommandLookupTopicResponse.LookupType response = 3; |
| inline bool has_response() const; |
| inline void clear_response(); |
| static const int kResponseFieldNumber = 3; |
| inline ::pulsar::proto::CommandLookupTopicResponse_LookupType response() const; |
| inline void set_response(::pulsar::proto::CommandLookupTopicResponse_LookupType value); |
| |
| // required uint64 request_id = 4; |
| inline bool has_request_id() const; |
| inline void clear_request_id(); |
| static const int kRequestIdFieldNumber = 4; |
| inline ::google::protobuf::uint64 request_id() const; |
| inline void set_request_id(::google::protobuf::uint64 value); |
| |
| // optional bool authoritative = 5 [default = false]; |
| inline bool has_authoritative() const; |
| inline void clear_authoritative(); |
| static const int kAuthoritativeFieldNumber = 5; |
| inline bool authoritative() const; |
| inline void set_authoritative(bool value); |
| |
| // optional .pulsar.proto.ServerError error = 6; |
| inline bool has_error() const; |
| inline void clear_error(); |
| static const int kErrorFieldNumber = 6; |
| inline ::pulsar::proto::ServerError error() const; |
| inline void set_error(::pulsar::proto::ServerError value); |
| |
| // optional string message = 7; |
| inline bool has_message() const; |
| inline void clear_message(); |
| static const int kMessageFieldNumber = 7; |
| inline const ::std::string& message() const; |
| inline void set_message(const ::std::string& value); |
| inline void set_message(const char* value); |
| inline void set_message(const char* value, size_t size); |
| inline ::std::string* mutable_message(); |
| inline ::std::string* release_message(); |
| inline void set_allocated_message(::std::string* message); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandLookupTopicResponse) |
| private: |
| inline void set_has_brokerserviceurl(); |
| inline void clear_has_brokerserviceurl(); |
| inline void set_has_brokerserviceurltls(); |
| inline void clear_has_brokerserviceurltls(); |
| inline void set_has_response(); |
| inline void clear_has_response(); |
| inline void set_has_request_id(); |
| inline void clear_has_request_id(); |
| inline void set_has_authoritative(); |
| inline void clear_has_authoritative(); |
| inline void set_has_error(); |
| inline void clear_has_error(); |
| inline void set_has_message(); |
| inline void clear_has_message(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* brokerserviceurl_; |
| ::std::string* brokerserviceurltls_; |
| ::google::protobuf::uint64 request_id_; |
| int response_; |
| bool authoritative_; |
| ::std::string* message_; |
| int error_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandLookupTopicResponse* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandProducer : public ::google::protobuf::MessageLite { |
| public: |
| CommandProducer(); |
| virtual ~CommandProducer(); |
| |
| CommandProducer(const CommandProducer& from); |
| |
| inline CommandProducer& operator=(const CommandProducer& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandProducer& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandProducer* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandProducer* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandProducer* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandProducer& from); |
| void MergeFrom(const CommandProducer& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required string topic = 1; |
| inline bool has_topic() const; |
| inline void clear_topic(); |
| static const int kTopicFieldNumber = 1; |
| inline const ::std::string& topic() const; |
| inline void set_topic(const ::std::string& value); |
| inline void set_topic(const char* value); |
| inline void set_topic(const char* value, size_t size); |
| inline ::std::string* mutable_topic(); |
| inline ::std::string* release_topic(); |
| inline void set_allocated_topic(::std::string* topic); |
| |
| // required uint64 producer_id = 2; |
| inline bool has_producer_id() const; |
| inline void clear_producer_id(); |
| static const int kProducerIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 producer_id() const; |
| inline void set_producer_id(::google::protobuf::uint64 value); |
| |
| // required uint64 request_id = 3; |
| inline bool has_request_id() const; |
| inline void clear_request_id(); |
| static const int kRequestIdFieldNumber = 3; |
| inline ::google::protobuf::uint64 request_id() const; |
| inline void set_request_id(::google::protobuf::uint64 value); |
| |
| // optional string producer_name = 4; |
| inline bool has_producer_name() const; |
| inline void clear_producer_name(); |
| static const int kProducerNameFieldNumber = 4; |
| inline const ::std::string& producer_name() const; |
| inline void set_producer_name(const ::std::string& value); |
| inline void set_producer_name(const char* value); |
| inline void set_producer_name(const char* value, size_t size); |
| inline ::std::string* mutable_producer_name(); |
| inline ::std::string* release_producer_name(); |
| inline void set_allocated_producer_name(::std::string* producer_name); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandProducer) |
| private: |
| inline void set_has_topic(); |
| inline void clear_has_topic(); |
| inline void set_has_producer_id(); |
| inline void clear_has_producer_id(); |
| inline void set_has_request_id(); |
| inline void clear_has_request_id(); |
| inline void set_has_producer_name(); |
| inline void clear_has_producer_name(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::std::string* topic_; |
| ::google::protobuf::uint64 producer_id_; |
| ::google::protobuf::uint64 request_id_; |
| ::std::string* producer_name_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandProducer* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandSend : public ::google::protobuf::MessageLite { |
| public: |
| CommandSend(); |
| virtual ~CommandSend(); |
| |
| CommandSend(const CommandSend& from); |
| |
| inline CommandSend& operator=(const CommandSend& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandSend& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandSend* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandSend* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandSend* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandSend& from); |
| void MergeFrom(const CommandSend& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required uint64 producer_id = 1; |
| inline bool has_producer_id() const; |
| inline void clear_producer_id(); |
| static const int kProducerIdFieldNumber = 1; |
| inline ::google::protobuf::uint64 producer_id() const; |
| inline void set_producer_id(::google::protobuf::uint64 value); |
| |
| // required uint64 sequence_id = 2; |
| inline bool has_sequence_id() const; |
| inline void clear_sequence_id(); |
| static const int kSequenceIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 sequence_id() const; |
| inline void set_sequence_id(::google::protobuf::uint64 value); |
| |
| // optional int32 num_messages = 3 [default = 1]; |
| inline bool has_num_messages() const; |
| inline void clear_num_messages(); |
| static const int kNumMessagesFieldNumber = 3; |
| inline ::google::protobuf::int32 num_messages() const; |
| inline void set_num_messages(::google::protobuf::int32 value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandSend) |
| private: |
| inline void set_has_producer_id(); |
| inline void clear_has_producer_id(); |
| inline void set_has_sequence_id(); |
| inline void clear_has_sequence_id(); |
| inline void set_has_num_messages(); |
| inline void clear_has_num_messages(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 producer_id_; |
| ::google::protobuf::uint64 sequence_id_; |
| ::google::protobuf::int32 num_messages_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandSend* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandSendReceipt : public ::google::protobuf::MessageLite { |
| public: |
| CommandSendReceipt(); |
| virtual ~CommandSendReceipt(); |
| |
| CommandSendReceipt(const CommandSendReceipt& from); |
| |
| inline CommandSendReceipt& operator=(const CommandSendReceipt& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandSendReceipt& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandSendReceipt* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandSendReceipt* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandSendReceipt* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandSendReceipt& from); |
| void MergeFrom(const CommandSendReceipt& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required uint64 producer_id = 1; |
| inline bool has_producer_id() const; |
| inline void clear_producer_id(); |
| static const int kProducerIdFieldNumber = 1; |
| inline ::google::protobuf::uint64 producer_id() const; |
| inline void set_producer_id(::google::protobuf::uint64 value); |
| |
| // required uint64 sequence_id = 2; |
| inline bool has_sequence_id() const; |
| inline void clear_sequence_id(); |
| static const int kSequenceIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 sequence_id() const; |
| inline void set_sequence_id(::google::protobuf::uint64 value); |
| |
| // optional .pulsar.proto.MessageIdData message_id = 3; |
| inline bool has_message_id() const; |
| inline void clear_message_id(); |
| static const int kMessageIdFieldNumber = 3; |
| inline const ::pulsar::proto::MessageIdData& message_id() const; |
| inline ::pulsar::proto::MessageIdData* mutable_message_id(); |
| inline ::pulsar::proto::MessageIdData* release_message_id(); |
| inline void set_allocated_message_id(::pulsar::proto::MessageIdData* message_id); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandSendReceipt) |
| private: |
| inline void set_has_producer_id(); |
| inline void clear_has_producer_id(); |
| inline void set_has_sequence_id(); |
| inline void clear_has_sequence_id(); |
| inline void set_has_message_id(); |
| inline void clear_has_message_id(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 producer_id_; |
| ::google::protobuf::uint64 sequence_id_; |
| ::pulsar::proto::MessageIdData* message_id_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandSendReceipt* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandSendError : public ::google::protobuf::MessageLite { |
| public: |
| CommandSendError(); |
| virtual ~CommandSendError(); |
| |
| CommandSendError(const CommandSendError& from); |
| |
| inline CommandSendError& operator=(const CommandSendError& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandSendError& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandSendError* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandSendError* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandSendError* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandSendError& from); |
| void MergeFrom(const CommandSendError& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required uint64 producer_id = 1; |
| inline bool has_producer_id() const; |
| inline void clear_producer_id(); |
| static const int kProducerIdFieldNumber = 1; |
| inline ::google::protobuf::uint64 producer_id() const; |
| inline void set_producer_id(::google::protobuf::uint64 value); |
| |
| // required uint64 sequence_id = 2; |
| inline bool has_sequence_id() const; |
| inline void clear_sequence_id(); |
| static const int kSequenceIdFieldNumber = 2; |
| inline ::google::protobuf::uint64 sequence_id() const; |
| inline void set_sequence_id(::google::protobuf::uint64 value); |
| |
| // required .pulsar.proto.ServerError error = 3; |
| inline bool has_error() const; |
| inline void clear_error(); |
| static const int kErrorFieldNumber = 3; |
| inline ::pulsar::proto::ServerError error() const; |
| inline void set_error(::pulsar::proto::ServerError value); |
| |
| // required string message = 4; |
| inline bool has_message() const; |
| inline void clear_message(); |
| static const int kMessageFieldNumber = 4; |
| inline const ::std::string& message() const; |
| inline void set_message(const ::std::string& value); |
| inline void set_message(const char* value); |
| inline void set_message(const char* value, size_t size); |
| inline ::std::string* mutable_message(); |
| inline ::std::string* release_message(); |
| inline void set_allocated_message(::std::string* message); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandSendError) |
| private: |
| inline void set_has_producer_id(); |
| inline void clear_has_producer_id(); |
| inline void set_has_sequence_id(); |
| inline void clear_has_sequence_id(); |
| inline void set_has_error(); |
| inline void clear_has_error(); |
| inline void set_has_message(); |
| inline void clear_has_message(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 producer_id_; |
| ::google::protobuf::uint64 sequence_id_; |
| ::std::string* message_; |
| int error_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandSendError* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandMessage : public ::google::protobuf::MessageLite { |
| public: |
| CommandMessage(); |
| virtual ~CommandMessage(); |
| |
| CommandMessage(const CommandMessage& from); |
| |
| inline CommandMessage& operator=(const CommandMessage& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandMessage& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandMessage* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandMessage* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandMessage* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandMessage& from); |
| void MergeFrom(const CommandMessage& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| // accessors ------------------------------------------------------- |
| |
| // required uint64 consumer_id = 1; |
| inline bool has_consumer_id() const; |
| inline void clear_consumer_id(); |
| static const int kConsumerIdFieldNumber = 1; |
| inline ::google::protobuf::uint64 consumer_id() const; |
| inline void set_consumer_id(::google::protobuf::uint64 value); |
| |
| // required .pulsar.proto.MessageIdData message_id = 2; |
| inline bool has_message_id() const; |
| inline void clear_message_id(); |
| static const int kMessageIdFieldNumber = 2; |
| inline const ::pulsar::proto::MessageIdData& message_id() const; |
| inline ::pulsar::proto::MessageIdData* mutable_message_id(); |
| inline ::pulsar::proto::MessageIdData* release_message_id(); |
| inline void set_allocated_message_id(::pulsar::proto::MessageIdData* message_id); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandMessage) |
| private: |
| inline void set_has_consumer_id(); |
| inline void clear_has_consumer_id(); |
| inline void set_has_message_id(); |
| inline void clear_has_message_id(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 consumer_id_; |
| ::pulsar::proto::MessageIdData* message_id_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandMessage* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandAck : public ::google::protobuf::MessageLite { |
| public: |
| CommandAck(); |
| virtual ~CommandAck(); |
| |
| CommandAck(const CommandAck& from); |
| |
| inline CommandAck& operator=(const CommandAck& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandAck& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandAck* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandAck* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandAck* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandAck& from); |
| void MergeFrom(const CommandAck& from); |
| void Clear(); |
| bool IsInitialized() const; |
| |
| int ByteSize() const; |
| bool MergePartialFromCodedStream( |
| ::google::protobuf::io::CodedInputStream* input); |
| void SerializeWithCachedSizes( |
| ::google::protobuf::io::CodedOutputStream* output) const; |
| void DiscardUnknownFields(); |
| int GetCachedSize() const { return _cached_size_; } |
| private: |
| void SharedCtor(); |
| void SharedDtor(); |
| void SetCachedSize(int size) const; |
| public: |
| ::std::string GetTypeName() const; |
| |
| // nested types ---------------------------------------------------- |
| |
| typedef CommandAck_AckType AckType; |
| static const AckType Individual = CommandAck_AckType_Individual; |
| static const AckType Cumulative = CommandAck_AckType_Cumulative; |
| static inline bool AckType_IsValid(int value) { |
| return CommandAck_AckType_IsValid(value); |
| } |
| static const AckType AckType_MIN = |
| CommandAck_AckType_AckType_MIN; |
| static const AckType AckType_MAX = |
| CommandAck_AckType_AckType_MAX; |
| static const int AckType_ARRAYSIZE = |
| CommandAck_AckType_AckType_ARRAYSIZE; |
| |
| typedef CommandAck_ValidationError ValidationError; |
| static const ValidationError UncompressedSizeCorruption = CommandAck_ValidationError_UncompressedSizeCorruption; |
| static const ValidationError DecompressionError = CommandAck_ValidationError_DecompressionError; |
| static const ValidationError ChecksumMismatch = CommandAck_ValidationError_ChecksumMismatch; |
| static const ValidationError BatchDeSerializeError = CommandAck_ValidationError_BatchDeSerializeError; |
| static inline bool ValidationError_IsValid(int value) { |
| return CommandAck_ValidationError_IsValid(value); |
| } |
| static const ValidationError ValidationError_MIN = |
| CommandAck_ValidationError_ValidationError_MIN; |
| static const ValidationError ValidationError_MAX = |
| CommandAck_ValidationError_ValidationError_MAX; |
| static const int ValidationError_ARRAYSIZE = |
| CommandAck_ValidationError_ValidationError_ARRAYSIZE; |
| |
| // accessors ------------------------------------------------------- |
| |
| // required uint64 consumer_id = 1; |
| inline bool has_consumer_id() const; |
| inline void clear_consumer_id(); |
| static const int kConsumerIdFieldNumber = 1; |
| inline ::google::protobuf::uint64 consumer_id() const; |
| inline void set_consumer_id(::google::protobuf::uint64 value); |
| |
| // required .pulsar.proto.CommandAck.AckType ack_type = 2; |
| inline bool has_ack_type() const; |
| inline void clear_ack_type(); |
| static const int kAckTypeFieldNumber = 2; |
| inline ::pulsar::proto::CommandAck_AckType ack_type() const; |
| inline void set_ack_type(::pulsar::proto::CommandAck_AckType value); |
| |
| // required .pulsar.proto.MessageIdData message_id = 3; |
| inline bool has_message_id() const; |
| inline void clear_message_id(); |
| static const int kMessageIdFieldNumber = 3; |
| inline const ::pulsar::proto::MessageIdData& message_id() const; |
| inline ::pulsar::proto::MessageIdData* mutable_message_id(); |
| inline ::pulsar::proto::MessageIdData* release_message_id(); |
| inline void set_allocated_message_id(::pulsar::proto::MessageIdData* message_id); |
| |
| // optional .pulsar.proto.CommandAck.ValidationError validation_error = 4; |
| inline bool has_validation_error() const; |
| inline void clear_validation_error(); |
| static const int kValidationErrorFieldNumber = 4; |
| inline ::pulsar::proto::CommandAck_ValidationError validation_error() const; |
| inline void set_validation_error(::pulsar::proto::CommandAck_ValidationError value); |
| |
| // @@protoc_insertion_point(class_scope:pulsar.proto.CommandAck) |
| private: |
| inline void set_has_consumer_id(); |
| inline void clear_has_consumer_id(); |
| inline void set_has_ack_type(); |
| inline void clear_has_ack_type(); |
| inline void set_has_message_id(); |
| inline void clear_has_message_id(); |
| inline void set_has_validation_error(); |
| inline void clear_has_validation_error(); |
| |
| ::std::string _unknown_fields_; |
| |
| ::google::protobuf::uint32 _has_bits_[1]; |
| mutable int _cached_size_; |
| ::google::protobuf::uint64 consumer_id_; |
| ::pulsar::proto::MessageIdData* message_id_; |
| int ack_type_; |
| int validation_error_; |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| friend void protobuf_AddDesc_PulsarApi_2eproto_impl(); |
| #else |
| friend void protobuf_AddDesc_PulsarApi_2eproto(); |
| #endif |
| friend void protobuf_AssignDesc_PulsarApi_2eproto(); |
| friend void protobuf_ShutdownFile_PulsarApi_2eproto(); |
| |
| void InitAsDefaultInstance(); |
| static CommandAck* default_instance_; |
| }; |
| // ------------------------------------------------------------------- |
| |
| class CommandFlow : public ::google::protobuf::MessageLite { |
| public: |
| CommandFlow(); |
| virtual ~CommandFlow(); |
| |
| CommandFlow(const CommandFlow& from); |
| |
| inline CommandFlow& operator=(const CommandFlow& from) { |
| CopyFrom(from); |
| return *this; |
| } |
| |
| inline const ::std::string& unknown_fields() const { |
| return _unknown_fields_; |
| } |
| |
| inline ::std::string* mutable_unknown_fields() { |
| return &_unknown_fields_; |
| } |
| |
| static const CommandFlow& default_instance(); |
| |
| #ifdef GOOGLE_PROTOBUF_NO_STATIC_INITIALIZER |
| // Returns the internal default instance pointer. This function can |
| // return NULL thus should not be used by the user. This is intended |
| // for Protobuf internal code. Please use default_instance() declared |
| // above instead. |
| static inline const CommandFlow* internal_default_instance() { |
| return default_instance_; |
| } |
| #endif |
| |
| void Swap(CommandFlow* other); |
| |
| // implements Message ---------------------------------------------- |
| |
| CommandFlow* New() const; |
| void CheckTypeAndMergeFrom(const ::google::protobuf::MessageLite& from); |
| void CopyFrom(const CommandFlow& from); |
| void MergeFrom(const CommandFlow& from); |
| void Clear(); |
|
