blob: 91e973baeb169b21d7c9c69252fb66118d787fb3 [file] [log] [blame]
// 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();