lib/ProtoApiEnums.h (114 lines of code) (raw):
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
// This file contains some constants with the same names of the enum constants in PulsarApi.pb.h to avoid
// including the huge PulsarApi.pb.h in *.h and *.cc files.
// Since it's safe to convert an enum constant to int, this file converts a enum from:
//
// ```c++
// // in PulsarApi.pb.h
// enum MyEnum {
// A = 0,
// B = 1
// };
// ```
//
// to
//
// ```c++
// using MyEnum = int;
// constexpr MyEnum A = 0;
// constexpr MyEnum B = 1;
// ```
#pragma once
namespace pulsar {
using CommandAck_AckType = int;
constexpr CommandAck_AckType CommandAck_AckType_Individual = 0;
constexpr CommandAck_AckType CommandAck_AckType_Cumulative = 1;
using CommandSubscribe_SubType = int;
constexpr int CommandSubscribe_SubType_Exclusive = 0;
constexpr int CommandSubscribe_SubType_Shared = 1;
constexpr int CommandSubscribe_SubType_Failover = 2;
constexpr int CommandSubscribe_SubType_Key_Shared = 3;
using CommandGetTopicsOfNamespace_Mode = int;
constexpr int CommandGetTopicsOfNamespace_Mode_PERSISTENT = 0;
constexpr int CommandGetTopicsOfNamespace_Mode_NON_PERSISTENT = 1;
constexpr int CommandGetTopicsOfNamespace_Mode_ALL = 2;
using CommandAck_ValidationError = int;
constexpr CommandAck_ValidationError CommandAck_ValidationError_UncompressedSizeCorruption = 0;
constexpr CommandAck_ValidationError CommandAck_ValidationError_DecompressionError = 1;
constexpr CommandAck_ValidationError CommandAck_ValidationError_ChecksumMismatch = 2;
constexpr CommandAck_ValidationError CommandAck_ValidationError_BatchDeSerializeError = 3;
constexpr CommandAck_ValidationError CommandAck_ValidationError_DecryptionError = 4;
using CommandSubscribe_InitialPosition = int;
constexpr CommandSubscribe_InitialPosition CommandSubscribe_InitialPosition_Latest = 0;
constexpr CommandSubscribe_InitialPosition CommandSubscribe_InitialPosition_Earliest = 1;
using ProducerAccessMode = int;
constexpr ProducerAccessMode Shared = 0;
constexpr ProducerAccessMode Exclusive = 1;
constexpr ProducerAccessMode WaitForExclusive = 2;
constexpr ProducerAccessMode ExclusiveWithFencing = 3;
using ServerError = int;
constexpr ServerError UnknownError = 0;
constexpr ServerError MetadataError = 1;
constexpr ServerError PersistenceError = 2;
constexpr ServerError AuthenticationError = 3;
constexpr ServerError AuthorizationError = 4;
constexpr ServerError ConsumerBusy = 5;
constexpr ServerError ServiceNotReady = 6;
constexpr ServerError ProducerBlockedQuotaExceededError = 7;
constexpr ServerError ProducerBlockedQuotaExceededException = 8;
constexpr ServerError ChecksumError = 9;
constexpr ServerError UnsupportedVersionError = 10;
constexpr ServerError TopicNotFound = 11;
constexpr ServerError SubscriptionNotFound = 12;
constexpr ServerError ConsumerNotFound = 13;
constexpr ServerError TooManyRequests = 14;
constexpr ServerError TopicTerminatedError = 15;
constexpr ServerError ProducerBusy = 16;
constexpr ServerError InvalidTopicName = 17;
constexpr ServerError IncompatibleSchema = 18;
constexpr ServerError ConsumerAssignError = 19;
constexpr ServerError TransactionCoordinatorNotFound = 20;
constexpr ServerError InvalidTxnStatus = 21;
constexpr ServerError NotAllowedError = 22;
constexpr ServerError TransactionConflict = 23;
constexpr ServerError TransactionNotFound = 24;
constexpr ServerError ProducerFenced = 25;
using BaseCommand_Type = int;
constexpr BaseCommand_Type BaseCommand_Type_CONNECT = 2;
constexpr BaseCommand_Type BaseCommand_Type_CONNECTED = 3;
constexpr BaseCommand_Type BaseCommand_Type_SUBSCRIBE = 4;
constexpr BaseCommand_Type BaseCommand_Type_PRODUCER = 5;
constexpr BaseCommand_Type BaseCommand_Type_SEND = 6;
constexpr BaseCommand_Type BaseCommand_Type_SEND_RECEIPT = 7;
constexpr BaseCommand_Type BaseCommand_Type_SEND_ERROR = 8;
constexpr BaseCommand_Type BaseCommand_Type_MESSAGE = 9;
constexpr BaseCommand_Type BaseCommand_Type_ACK = 10;
constexpr BaseCommand_Type BaseCommand_Type_FLOW = 11;
constexpr BaseCommand_Type BaseCommand_Type_UNSUBSCRIBE = 12;
constexpr BaseCommand_Type BaseCommand_Type_SUCCESS = 13;
constexpr BaseCommand_Type BaseCommand_Type_ERROR = 14;
constexpr BaseCommand_Type BaseCommand_Type_CLOSE_PRODUCER = 15;
constexpr BaseCommand_Type BaseCommand_Type_CLOSE_CONSUMER = 16;
constexpr BaseCommand_Type BaseCommand_Type_PRODUCER_SUCCESS = 17;
constexpr BaseCommand_Type BaseCommand_Type_PING = 18;
constexpr BaseCommand_Type BaseCommand_Type_PONG = 19;
constexpr BaseCommand_Type BaseCommand_Type_REDELIVER_UNACKNOWLEDGED_MESSAGES = 20;
constexpr BaseCommand_Type BaseCommand_Type_PARTITIONED_METADATA = 21;
constexpr BaseCommand_Type BaseCommand_Type_PARTITIONED_METADATA_RESPONSE = 22;
constexpr BaseCommand_Type BaseCommand_Type_LOOKUP = 23;
constexpr BaseCommand_Type BaseCommand_Type_LOOKUP_RESPONSE = 24;
constexpr BaseCommand_Type BaseCommand_Type_CONSUMER_STATS = 25;
constexpr BaseCommand_Type BaseCommand_Type_CONSUMER_STATS_RESPONSE = 26;
constexpr BaseCommand_Type BaseCommand_Type_REACHED_END_OF_TOPIC = 27;
constexpr BaseCommand_Type BaseCommand_Type_SEEK = 28;
constexpr BaseCommand_Type BaseCommand_Type_GET_LAST_MESSAGE_ID = 29;
constexpr BaseCommand_Type BaseCommand_Type_GET_LAST_MESSAGE_ID_RESPONSE = 30;
constexpr BaseCommand_Type BaseCommand_Type_ACTIVE_CONSUMER_CHANGE = 31;
constexpr BaseCommand_Type BaseCommand_Type_GET_TOPICS_OF_NAMESPACE = 32;
constexpr BaseCommand_Type BaseCommand_Type_GET_TOPICS_OF_NAMESPACE_RESPONSE = 33;
constexpr BaseCommand_Type BaseCommand_Type_GET_SCHEMA = 34;
constexpr BaseCommand_Type BaseCommand_Type_GET_SCHEMA_RESPONSE = 35;
constexpr BaseCommand_Type BaseCommand_Type_AUTH_CHALLENGE = 36;
constexpr BaseCommand_Type BaseCommand_Type_AUTH_RESPONSE = 37;
constexpr BaseCommand_Type BaseCommand_Type_ACK_RESPONSE = 38;
constexpr BaseCommand_Type BaseCommand_Type_GET_OR_CREATE_SCHEMA = 39;
constexpr BaseCommand_Type BaseCommand_Type_GET_OR_CREATE_SCHEMA_RESPONSE = 40;
constexpr BaseCommand_Type BaseCommand_Type_NEW_TXN = 50;
constexpr BaseCommand_Type BaseCommand_Type_NEW_TXN_RESPONSE = 51;
constexpr BaseCommand_Type BaseCommand_Type_ADD_PARTITION_TO_TXN = 52;
constexpr BaseCommand_Type BaseCommand_Type_ADD_PARTITION_TO_TXN_RESPONSE = 53;
constexpr BaseCommand_Type BaseCommand_Type_ADD_SUBSCRIPTION_TO_TXN = 54;
constexpr BaseCommand_Type BaseCommand_Type_ADD_SUBSCRIPTION_TO_TXN_RESPONSE = 55;
constexpr BaseCommand_Type BaseCommand_Type_END_TXN = 56;
constexpr BaseCommand_Type BaseCommand_Type_END_TXN_RESPONSE = 57;
constexpr BaseCommand_Type BaseCommand_Type_END_TXN_ON_PARTITION = 58;
constexpr BaseCommand_Type BaseCommand_Type_END_TXN_ON_PARTITION_RESPONSE = 59;
constexpr BaseCommand_Type BaseCommand_Type_END_TXN_ON_SUBSCRIPTION = 60;
constexpr BaseCommand_Type BaseCommand_Type_END_TXN_ON_SUBSCRIPTION_RESPONSE = 61;
constexpr BaseCommand_Type BaseCommand_Type_TC_CLIENT_CONNECT_REQUEST = 62;
constexpr BaseCommand_Type BaseCommand_Type_TC_CLIENT_CONNECT_RESPONSE = 63;
constexpr BaseCommand_Type BaseCommand_Type_WATCH_TOPIC_LIST = 64;
constexpr BaseCommand_Type BaseCommand_Type_WATCH_TOPIC_LIST_SUCCESS = 65;
constexpr BaseCommand_Type BaseCommand_Type_WATCH_TOPIC_UPDATE = 66;
constexpr BaseCommand_Type BaseCommand_Type_WATCH_TOPIC_LIST_CLOSE = 67;
} // namespace pulsar