YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// Generated by the protocol buffer compiler.  DO NOT EDIT!

// source: yb/cdc/cdc_service.proto

#ifndef PROTOBUF_yb_2fcdc_2fcdc_5fservice_2eproto__INCLUDED

#define PROTOBUF_yb_2fcdc_2fcdc_5fservice_2eproto__INCLUDED

#include <string>

#include <google/protobuf/stubs/common.h>

#if GOOGLE_PROTOBUF_VERSION < 3005000

#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 3005001 < 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/io/coded_stream.h>

#include <google/protobuf/arena.h>

#include <google/protobuf/arenastring.h>

#include <google/protobuf/generated_message_table_driven.h>

#include <google/protobuf/generated_message_util.h>

#include <google/protobuf/metadata.h>

#include <google/protobuf/message.h>

#include <google/protobuf/repeated_field.h>  // IWYU pragma: export

#include <google/protobuf/extension_set.h>  // IWYU pragma: export

#include <google/protobuf/generated_enum_reflection.h>

#include <google/protobuf/unknown_field_set.h>

#include "yb/common/common.pb.h"

#include "yb/common/common_net.pb.h"

#include "yb/common/value.pb.h"

#include "yb/common/wire_protocol.pb.h"

#include "yb/rpc/service.pb.h"

#include "yb/tablet/operations.pb.h"

#include "yb/tserver/tserver.pb.h"

#include "yb/util/opid.pb.h"

// @@protoc_insertion_point(includes)

namespace protobuf_yb_2fcdc_2fcdc_5fservice_2eproto {

// Internal implementation detail -- do not use these members.

struct TableStruct {

  static const ::google::protobuf::internal::ParseTableField entries[];

  static const ::google::protobuf::internal::AuxillaryParseTableField aux[];

  static const ::google::protobuf::internal::ParseTable schema[35];

  static const ::google::protobuf::internal::FieldMetadata field_metadata[];

  static const ::google::protobuf::internal::SerializationTable serialization_table[];

  static const ::google::protobuf::uint32 offsets[];

};

void AddDescriptors();

void InitDefaultsCDCErrorPBImpl();

void InitDefaultsCDCErrorPB();

void InitDefaultsCreateCDCStreamRequestPBImpl();

void InitDefaultsCreateCDCStreamRequestPB();

void InitDefaultsCreateCDCStreamResponsePBImpl();

void InitDefaultsCreateCDCStreamResponsePB();

void InitDefaultsDeleteCDCStreamRequestPBImpl();

void InitDefaultsDeleteCDCStreamRequestPB();

void InitDefaultsDeleteCDCStreamResponsePBImpl();

void InitDefaultsDeleteCDCStreamResponsePB();

void InitDefaultsListTabletsRequestPBImpl();

void InitDefaultsListTabletsRequestPB();

void InitDefaultsListTabletsResponsePBImpl();

void InitDefaultsListTabletsResponsePB();

void InitDefaultsCDCTabletPB_ReplicaPBImpl();

void InitDefaultsCDCTabletPB_ReplicaPB();

void InitDefaultsCDCTabletPBImpl();

void InitDefaultsCDCTabletPB();

void InitDefaultsCDCSDKCheckpointPBImpl();

void InitDefaultsCDCSDKCheckpointPB();

void InitDefaultsCDCCheckpointPBImpl();

void InitDefaultsCDCCheckpointPB();

void InitDefaultsGetChangesRequestPBImpl();

void InitDefaultsGetChangesRequestPB();

void InitDefaultsKeyValuePairPBImpl();

void InitDefaultsKeyValuePairPB();

void InitDefaultsCDCRecordPBImpl();

void InitDefaultsCDCRecordPB();

void InitDefaultsCDCSDKColumnInfoPBImpl();

void InitDefaultsCDCSDKColumnInfoPB();

void InitDefaultsCDCSDKTablePropertiesPBImpl();

void InitDefaultsCDCSDKTablePropertiesPB();

void InitDefaultsCDCSDKSchemaPBImpl();

void InitDefaultsCDCSDKSchemaPB();

void InitDefaultsCDCSDKOpIdPBImpl();

void InitDefaultsCDCSDKOpIdPB();

void InitDefaultsTypeInfoImpl();

void InitDefaultsTypeInfo();

void InitDefaultsRowMessageImpl();

void InitDefaultsRowMessage();

void InitDefaultsCDCSDKProtoRecordPBImpl();

void InitDefaultsCDCSDKProtoRecordPB();

void InitDefaultsGetChangesResponsePBImpl();

void InitDefaultsGetChangesResponsePB();

void InitDefaultsGetCheckpointRequestPBImpl();

void InitDefaultsGetCheckpointRequestPB();

void InitDefaultsGetCheckpointResponsePBImpl();

void InitDefaultsGetCheckpointResponsePB();

void InitDefaultsUpdateCdcReplicatedIndexRequestPBImpl();

void InitDefaultsUpdateCdcReplicatedIndexRequestPB();

void InitDefaultsUpdateCdcReplicatedIndexResponsePBImpl();

void InitDefaultsUpdateCdcReplicatedIndexResponsePB();

void InitDefaultsBootstrapProducerRequestPBImpl();

void InitDefaultsBootstrapProducerRequestPB();

void InitDefaultsBootstrapProducerResponsePBImpl();

void InitDefaultsBootstrapProducerResponsePB();

void InitDefaultsGetLatestEntryOpIdRequestPBImpl();

void InitDefaultsGetLatestEntryOpIdRequestPB();

void InitDefaultsGetLatestEntryOpIdResponsePBImpl();

void InitDefaultsGetLatestEntryOpIdResponsePB();

void InitDefaultsTableInfoImpl();

void InitDefaultsTableInfo();

void InitDefaultsGetCDCDBStreamInfoRequestPBImpl();

void InitDefaultsGetCDCDBStreamInfoRequestPB();

void InitDefaultsGetCDCDBStreamInfoResponsePBImpl();

void InitDefaultsGetCDCDBStreamInfoResponsePB();

void InitDefaultsSetCDCCheckpointRequestPBImpl();

void InitDefaultsSetCDCCheckpointRequestPB();

void InitDefaultsSetCDCCheckpointResponsePBImpl();

void InitDefaultsSetCDCCheckpointResponsePB();

inline void InitDefaults() {

  InitDefaultsCDCErrorPB();

  InitDefaultsCreateCDCStreamRequestPB();

  InitDefaultsCreateCDCStreamResponsePB();

  InitDefaultsDeleteCDCStreamRequestPB();

  InitDefaultsDeleteCDCStreamResponsePB();

  InitDefaultsListTabletsRequestPB();

  InitDefaultsListTabletsResponsePB();

  InitDefaultsCDCTabletPB_ReplicaPB();

  InitDefaultsCDCTabletPB();

  InitDefaultsCDCSDKCheckpointPB();

  InitDefaultsCDCCheckpointPB();

  InitDefaultsGetChangesRequestPB();

  InitDefaultsKeyValuePairPB();

  InitDefaultsCDCRecordPB();

  InitDefaultsCDCSDKColumnInfoPB();

  InitDefaultsCDCSDKTablePropertiesPB();

  InitDefaultsCDCSDKSchemaPB();

  InitDefaultsCDCSDKOpIdPB();

  InitDefaultsTypeInfo();

  InitDefaultsRowMessage();

  InitDefaultsCDCSDKProtoRecordPB();

  InitDefaultsGetChangesResponsePB();

  InitDefaultsGetCheckpointRequestPB();

  InitDefaultsGetCheckpointResponsePB();

  InitDefaultsUpdateCdcReplicatedIndexRequestPB();

  InitDefaultsUpdateCdcReplicatedIndexResponsePB();

  InitDefaultsBootstrapProducerRequestPB();

  InitDefaultsBootstrapProducerResponsePB();

  InitDefaultsGetLatestEntryOpIdRequestPB();

  InitDefaultsGetLatestEntryOpIdResponsePB();

  InitDefaultsTableInfo();

  InitDefaultsGetCDCDBStreamInfoRequestPB();

  InitDefaultsGetCDCDBStreamInfoResponsePB();

  InitDefaultsSetCDCCheckpointRequestPB();

  InitDefaultsSetCDCCheckpointResponsePB();

}

}  // namespace protobuf_yb_2fcdc_2fcdc_5fservice_2eproto

namespace yb {

namespace cdc {

class BootstrapProducerRequestPB;

class BootstrapProducerRequestPBDefaultTypeInternal;

extern BootstrapProducerRequestPBDefaultTypeInternal _BootstrapProducerRequestPB_default_instance_;

class BootstrapProducerResponsePB;

class BootstrapProducerResponsePBDefaultTypeInternal;

extern BootstrapProducerResponsePBDefaultTypeInternal _BootstrapProducerResponsePB_default_instance_;

class CDCCheckpointPB;

class CDCCheckpointPBDefaultTypeInternal;

extern CDCCheckpointPBDefaultTypeInternal _CDCCheckpointPB_default_instance_;

class CDCErrorPB;

class CDCErrorPBDefaultTypeInternal;

extern CDCErrorPBDefaultTypeInternal _CDCErrorPB_default_instance_;

class CDCRecordPB;

class CDCRecordPBDefaultTypeInternal;

extern CDCRecordPBDefaultTypeInternal _CDCRecordPB_default_instance_;

class CDCSDKCheckpointPB;

class CDCSDKCheckpointPBDefaultTypeInternal;

extern CDCSDKCheckpointPBDefaultTypeInternal _CDCSDKCheckpointPB_default_instance_;

class CDCSDKColumnInfoPB;

class CDCSDKColumnInfoPBDefaultTypeInternal;

extern CDCSDKColumnInfoPBDefaultTypeInternal _CDCSDKColumnInfoPB_default_instance_;

class CDCSDKOpIdPB;

class CDCSDKOpIdPBDefaultTypeInternal;

extern CDCSDKOpIdPBDefaultTypeInternal _CDCSDKOpIdPB_default_instance_;

class CDCSDKProtoRecordPB;

class CDCSDKProtoRecordPBDefaultTypeInternal;

extern CDCSDKProtoRecordPBDefaultTypeInternal _CDCSDKProtoRecordPB_default_instance_;

class CDCSDKSchemaPB;

class CDCSDKSchemaPBDefaultTypeInternal;

extern CDCSDKSchemaPBDefaultTypeInternal _CDCSDKSchemaPB_default_instance_;

class CDCSDKTablePropertiesPB;

class CDCSDKTablePropertiesPBDefaultTypeInternal;

extern CDCSDKTablePropertiesPBDefaultTypeInternal _CDCSDKTablePropertiesPB_default_instance_;

class CDCTabletPB;

class CDCTabletPBDefaultTypeInternal;

extern CDCTabletPBDefaultTypeInternal _CDCTabletPB_default_instance_;

class CDCTabletPB_ReplicaPB;

class CDCTabletPB_ReplicaPBDefaultTypeInternal;

extern CDCTabletPB_ReplicaPBDefaultTypeInternal _CDCTabletPB_ReplicaPB_default_instance_;

class CreateCDCStreamRequestPB;

class CreateCDCStreamRequestPBDefaultTypeInternal;

extern CreateCDCStreamRequestPBDefaultTypeInternal _CreateCDCStreamRequestPB_default_instance_;

class CreateCDCStreamResponsePB;

class CreateCDCStreamResponsePBDefaultTypeInternal;

extern CreateCDCStreamResponsePBDefaultTypeInternal _CreateCDCStreamResponsePB_default_instance_;

class DeleteCDCStreamRequestPB;

class DeleteCDCStreamRequestPBDefaultTypeInternal;

extern DeleteCDCStreamRequestPBDefaultTypeInternal _DeleteCDCStreamRequestPB_default_instance_;

class DeleteCDCStreamResponsePB;

class DeleteCDCStreamResponsePBDefaultTypeInternal;

extern DeleteCDCStreamResponsePBDefaultTypeInternal _DeleteCDCStreamResponsePB_default_instance_;

class GetCDCDBStreamInfoRequestPB;

class GetCDCDBStreamInfoRequestPBDefaultTypeInternal;

extern GetCDCDBStreamInfoRequestPBDefaultTypeInternal _GetCDCDBStreamInfoRequestPB_default_instance_;

class GetCDCDBStreamInfoResponsePB;

class GetCDCDBStreamInfoResponsePBDefaultTypeInternal;

extern GetCDCDBStreamInfoResponsePBDefaultTypeInternal _GetCDCDBStreamInfoResponsePB_default_instance_;

class GetChangesRequestPB;

class GetChangesRequestPBDefaultTypeInternal;

extern GetChangesRequestPBDefaultTypeInternal _GetChangesRequestPB_default_instance_;

class GetChangesResponsePB;

class GetChangesResponsePBDefaultTypeInternal;

extern GetChangesResponsePBDefaultTypeInternal _GetChangesResponsePB_default_instance_;

class GetCheckpointRequestPB;

class GetCheckpointRequestPBDefaultTypeInternal;

extern GetCheckpointRequestPBDefaultTypeInternal _GetCheckpointRequestPB_default_instance_;

class GetCheckpointResponsePB;

class GetCheckpointResponsePBDefaultTypeInternal;

extern GetCheckpointResponsePBDefaultTypeInternal _GetCheckpointResponsePB_default_instance_;

class GetLatestEntryOpIdRequestPB;

class GetLatestEntryOpIdRequestPBDefaultTypeInternal;

extern GetLatestEntryOpIdRequestPBDefaultTypeInternal _GetLatestEntryOpIdRequestPB_default_instance_;

class GetLatestEntryOpIdResponsePB;

class GetLatestEntryOpIdResponsePBDefaultTypeInternal;

extern GetLatestEntryOpIdResponsePBDefaultTypeInternal _GetLatestEntryOpIdResponsePB_default_instance_;

class KeyValuePairPB;

class KeyValuePairPBDefaultTypeInternal;

extern KeyValuePairPBDefaultTypeInternal _KeyValuePairPB_default_instance_;

class ListTabletsRequestPB;

class ListTabletsRequestPBDefaultTypeInternal;

extern ListTabletsRequestPBDefaultTypeInternal _ListTabletsRequestPB_default_instance_;

class ListTabletsResponsePB;

class ListTabletsResponsePBDefaultTypeInternal;

extern ListTabletsResponsePBDefaultTypeInternal _ListTabletsResponsePB_default_instance_;

class RowMessage;

class RowMessageDefaultTypeInternal;

extern RowMessageDefaultTypeInternal _RowMessage_default_instance_;

class SetCDCCheckpointRequestPB;

class SetCDCCheckpointRequestPBDefaultTypeInternal;

extern SetCDCCheckpointRequestPBDefaultTypeInternal _SetCDCCheckpointRequestPB_default_instance_;

class SetCDCCheckpointResponsePB;

class SetCDCCheckpointResponsePBDefaultTypeInternal;

extern SetCDCCheckpointResponsePBDefaultTypeInternal _SetCDCCheckpointResponsePB_default_instance_;

class TableInfo;

class TableInfoDefaultTypeInternal;

extern TableInfoDefaultTypeInternal _TableInfo_default_instance_;

class TypeInfo;

class TypeInfoDefaultTypeInternal;

extern TypeInfoDefaultTypeInternal _TypeInfo_default_instance_;

class UpdateCdcReplicatedIndexRequestPB;

class UpdateCdcReplicatedIndexRequestPBDefaultTypeInternal;

extern UpdateCdcReplicatedIndexRequestPBDefaultTypeInternal _UpdateCdcReplicatedIndexRequestPB_default_instance_;

class UpdateCdcReplicatedIndexResponsePB;

class UpdateCdcReplicatedIndexResponsePBDefaultTypeInternal;

extern UpdateCdcReplicatedIndexResponsePBDefaultTypeInternal _UpdateCdcReplicatedIndexResponsePB_default_instance_;

}  // namespace cdc

}  // namespace yb

namespace yb {

namespace cdc {

enum CDCErrorPB_Code {

  CDCErrorPB_Code_UNKNOWN_ERROR = 1,

  CDCErrorPB_Code_TABLET_NOT_FOUND = 2,

  CDCErrorPB_Code_TABLE_NOT_FOUND = 3,

  CDCErrorPB_Code_SUBSCRIBER_NOT_FOUND = 4,

  CDCErrorPB_Code_CHECKPOINT_TOO_OLD = 5,

  CDCErrorPB_Code_TABLET_NOT_RUNNING = 6,

  CDCErrorPB_Code_NOT_LEADER = 7,

  CDCErrorPB_Code_LEADER_NOT_READY = 11,

  CDCErrorPB_Code_NOT_RUNNING = 8,

  CDCErrorPB_Code_INTERNAL_ERROR = 9,

  CDCErrorPB_Code_INVALID_REQUEST = 10

};

bool CDCErrorPB_Code_IsValid(int value);

const CDCErrorPB_Code CDCErrorPB_Code_Code_MIN = CDCErrorPB_Code_UNKNOWN_ERROR;

const CDCErrorPB_Code CDCErrorPB_Code_Code_MAX = CDCErrorPB_Code_LEADER_NOT_READY;

const int CDCErrorPB_Code_Code_ARRAYSIZE = CDCErrorPB_Code_Code_MAX + 1;

const ::google::protobuf::EnumDescriptor* CDCErrorPB_Code_descriptor();

inline const ::std::string& CDCErrorPB_Code_Name(CDCErrorPB_Code value) {

  return ::google::protobuf::internal::NameOfEnum(

    CDCErrorPB_Code_descriptor(), value);

}

inline bool CDCErrorPB_Code_Parse(

    const ::std::string& name, CDCErrorPB_Code* value) {

  return ::google::protobuf::internal::ParseNamedEnum<CDCErrorPB_Code>(

    CDCErrorPB_Code_descriptor(), name, value);

}

enum CDCRecordPB_OperationType {

  CDCRecordPB_OperationType_WRITE = 1,

  CDCRecordPB_OperationType_DELETE = 2,

  CDCRecordPB_OperationType_APPLY = 3,

  CDCRecordPB_OperationType_SPLIT_OP = 4

};

bool CDCRecordPB_OperationType_IsValid(int value);

const CDCRecordPB_OperationType CDCRecordPB_OperationType_OperationType_MIN = CDCRecordPB_OperationType_WRITE;

const CDCRecordPB_OperationType CDCRecordPB_OperationType_OperationType_MAX = CDCRecordPB_OperationType_SPLIT_OP;

const int CDCRecordPB_OperationType_OperationType_ARRAYSIZE = CDCRecordPB_OperationType_OperationType_MAX + 1;

const ::google::protobuf::EnumDescriptor* CDCRecordPB_OperationType_descriptor();

inline const ::std::string& CDCRecordPB_OperationType_Name(CDCRecordPB_OperationType value) {

  return ::google::protobuf::internal::NameOfEnum(

    CDCRecordPB_OperationType_descriptor(), value);

}

inline bool CDCRecordPB_OperationType_Parse(

    const ::std::string& name, CDCRecordPB_OperationType* value) {

  return ::google::protobuf::internal::ParseNamedEnum<CDCRecordPB_OperationType>(

    CDCRecordPB_OperationType_descriptor(), name, value);

}

enum RowMessage_Op {

  RowMessage_Op_UNKNOWN = -1,

  RowMessage_Op_INSERT = 0,

  RowMessage_Op_UPDATE = 1,

  RowMessage_Op_DELETE = 2,

  RowMessage_Op_BEGIN = 3,

  RowMessage_Op_COMMIT = 4,

  RowMessage_Op_DDL = 5,

  RowMessage_Op_TRUNCATE = 6,

  RowMessage_Op_READ = 7

};

bool RowMessage_Op_IsValid(int value);

const RowMessage_Op RowMessage_Op_Op_MIN = RowMessage_Op_UNKNOWN;

const RowMessage_Op RowMessage_Op_Op_MAX = RowMessage_Op_READ;

const int RowMessage_Op_Op_ARRAYSIZE = RowMessage_Op_Op_MAX + 1;

const ::google::protobuf::EnumDescriptor* RowMessage_Op_descriptor();

inline const ::std::string& RowMessage_Op_Name(RowMessage_Op value) {

  return ::google::protobuf::internal::NameOfEnum(

    RowMessage_Op_descriptor(), value);

}

inline bool RowMessage_Op_Parse(

    const ::std::string& name, RowMessage_Op* value) {

  return ::google::protobuf::internal::ParseNamedEnum<RowMessage_Op>(

    RowMessage_Op_descriptor(), name, value);

}

enum CDCRecordType {

  CHANGE = 1,

  AFTER = 2,

  ALL = 3

};

bool CDCRecordType_IsValid(int value);

const CDCRecordType CDCRecordType_MIN = CHANGE;

const CDCRecordType CDCRecordType_MAX = ALL;

const int CDCRecordType_ARRAYSIZE = CDCRecordType_MAX + 1;

const ::google::protobuf::EnumDescriptor* CDCRecordType_descriptor();

inline const ::std::string& CDCRecordType_Name(CDCRecordType value) {

  return ::google::protobuf::internal::NameOfEnum(

    CDCRecordType_descriptor(), value);

}

inline bool CDCRecordType_Parse(

    const ::std::string& name, CDCRecordType* value) {

  return ::google::protobuf::internal::ParseNamedEnum<CDCRecordType>(

    CDCRecordType_descriptor(), name, value);

}

enum CDCRecordFormat {

  JSON = 1,

  WAL = 2,

  PROTO = 3

};

bool CDCRecordFormat_IsValid(int value);

const CDCRecordFormat CDCRecordFormat_MIN = JSON;

const CDCRecordFormat CDCRecordFormat_MAX = PROTO;

const int CDCRecordFormat_ARRAYSIZE = CDCRecordFormat_MAX + 1;

const ::google::protobuf::EnumDescriptor* CDCRecordFormat_descriptor();

inline const ::std::string& CDCRecordFormat_Name(CDCRecordFormat value) {

  return ::google::protobuf::internal::NameOfEnum(

    CDCRecordFormat_descriptor(), value);

}

inline bool CDCRecordFormat_Parse(

    const ::std::string& name, CDCRecordFormat* value) {

  return ::google::protobuf::internal::ParseNamedEnum<CDCRecordFormat>(

    CDCRecordFormat_descriptor(), name, value);

}

enum CDCRequestSource {

  XCLUSTER = 1,

  CDCSDK = 2

};

bool CDCRequestSource_IsValid(int value);

const CDCRequestSource CDCRequestSource_MIN = XCLUSTER;

const CDCRequestSource CDCRequestSource_MAX = CDCSDK;

const int CDCRequestSource_ARRAYSIZE = CDCRequestSource_MAX + 1;

const ::google::protobuf::EnumDescriptor* CDCRequestSource_descriptor();

inline const ::std::string& CDCRequestSource_Name(CDCRequestSource value) {

  return ::google::protobuf::internal::NameOfEnum(

    CDCRequestSource_descriptor(), value);

}

inline bool CDCRequestSource_Parse(

    const ::std::string& name, CDCRequestSource* value) {

  return ::google::protobuf::internal::ParseNamedEnum<CDCRequestSource>(

    CDCRequestSource_descriptor(), name, value);

}

enum CDCCheckpointType {

  IMPLICIT = 1,

  EXPLICIT = 2

};

bool CDCCheckpointType_IsValid(int value);

const CDCCheckpointType CDCCheckpointType_MIN = IMPLICIT;

const CDCCheckpointType CDCCheckpointType_MAX = EXPLICIT;

const int CDCCheckpointType_ARRAYSIZE = CDCCheckpointType_MAX + 1;

const ::google::protobuf::EnumDescriptor* CDCCheckpointType_descriptor();

inline const ::std::string& CDCCheckpointType_Name(CDCCheckpointType value) {

  return ::google::protobuf::internal::NameOfEnum(

    CDCCheckpointType_descriptor(), value);

}

inline bool CDCCheckpointType_Parse(

    const ::std::string& name, CDCCheckpointType* value) {

  return ::google::protobuf::internal::ParseNamedEnum<CDCCheckpointType>(

    CDCCheckpointType_descriptor(), name, value);

}

// ===================================================================

class CDCErrorPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.CDCErrorPB) */ {

 public:

  CDCErrorPB();

  virtual ~CDCErrorPB();

  CDCErrorPB(const CDCErrorPB& from);

  inline CDCErrorPB& operator=(const CDCErrorPB& from) {

    CopyFrom(from);

    return *this;

  }

  #if LANG_CXX11

  CDCErrorPB(CDCErrorPB&& from) noexcept

    : CDCErrorPB() {

    *this = ::std::move(from);

  }

  inline CDCErrorPB& operator=(CDCErrorPB&& from) noexcept {

    if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {

      if (this != &from) InternalSwap(&from);

    } else {

      CopyFrom(from);

    }

    return *this;

  }

  #endif

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {

    return _internal_metadata_.unknown_fields();

  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {

    return _internal_metadata_.mutable_unknown_fields();

  }

  static const ::google::protobuf::Descriptor* descriptor();

  static const CDCErrorPB& default_instance();

  static void InitAsDefaultInstance();  // FOR INTERNAL USE ONLY

  static inline const CDCErrorPB* internal_default_instance() {

    return reinterpret_cast<const CDCErrorPB*>(

               &_CDCErrorPB_default_instance_);

  }

  static PROTOBUF_CONSTEXPR int const kIndexInFileMessages =

    0;

  void Swap(CDCErrorPB* other);

  friend void swap(CDCErrorPB& a, CDCErrorPB& b) {

    a.Swap(&b);

  }

  // implements Message ----------------------------------------------

  inline CDCErrorPB* New() const PROTOBUF_FINAL { return New(NULL); }

  CDCErrorPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL;

  void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void CopyFrom(const CDCErrorPB& from);

  void MergeFrom(const CDCErrorPB& from);

  void Clear() PROTOBUF_FINAL;

  bool IsInitialized() const PROTOBUF_FINAL;

  size_t ByteSizeLong() const PROTOBUF_FINAL;

  bool MergePartialFromCodedStream(

      ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL;

  void SerializeWithCachedSizes(

      ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL;

  ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(

      bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL;

  int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; }

  private:

  void SharedCtor();

  void SharedDtor();

  void SetCachedSize(int size) const PROTOBUF_FINAL;

  void InternalSwap(CDCErrorPB* other);

  private:

  inline ::google::protobuf::Arena* GetArenaNoVirtual() const {

    return NULL;

  }

  inline void* MaybeArenaPtr() const {

    return NULL;

  }

  public:

  ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL;

  // nested types ----------------------------------------------------

  typedef CDCErrorPB_Code Code;

  static const Code UNKNOWN_ERROR =

    CDCErrorPB_Code_UNKNOWN_ERROR;

  static const Code TABLET_NOT_FOUND =

    CDCErrorPB_Code_TABLET_NOT_FOUND;

  static const Code TABLE_NOT_FOUND =

    CDCErrorPB_Code_TABLE_NOT_FOUND;

  static const Code SUBSCRIBER_NOT_FOUND =

    CDCErrorPB_Code_SUBSCRIBER_NOT_FOUND;

  static const Code CHECKPOINT_TOO_OLD =

    CDCErrorPB_Code_CHECKPOINT_TOO_OLD;

  static const Code TABLET_NOT_RUNNING =

    CDCErrorPB_Code_TABLET_NOT_RUNNING;

  static const Code NOT_LEADER =

    CDCErrorPB_Code_NOT_LEADER;

  static const Code LEADER_NOT_READY =

    CDCErrorPB_Code_LEADER_NOT_READY;

  static const Code NOT_RUNNING =

    CDCErrorPB_Code_NOT_RUNNING;

  static const Code INTERNAL_ERROR =

    CDCErrorPB_Code_INTERNAL_ERROR;

  static const Code INVALID_REQUEST =

    CDCErrorPB_Code_INVALID_REQUEST;

  static inline bool Code_IsValid(int value) {

    return CDCErrorPB_Code_IsValid(value);

  }

  static const Code Code_MIN =

    CDCErrorPB_Code_Code_MIN;

  static const Code Code_MAX =

    CDCErrorPB_Code_Code_MAX;

  static const int Code_ARRAYSIZE =

    CDCErrorPB_Code_Code_ARRAYSIZE;

  static inline const ::google::protobuf::EnumDescriptor*

  Code_descriptor() {

    return CDCErrorPB_Code_descriptor();

  }

  static inline const ::std::string& Code_Name(Code value) {

    return CDCErrorPB_Code_Name(value);

  }

  static inline bool Code_Parse(const ::std::string& name,

      Code* value) {

    return CDCErrorPB_Code_Parse(name, value);

  }

  // accessors -------------------------------------------------------

  // optional .yb.AppStatusPB status = 2;

  bool has_status() const;

  void clear_status();

  static const int kStatusFieldNumber = 2;

  const ::yb::AppStatusPB& status() const;

  ::yb::AppStatusPB* release_status();

  ::yb::AppStatusPB* mutable_status();

  void set_allocated_status(::yb::AppStatusPB* status);

  // optional .yb.cdc.CDCErrorPB.Code code = 1 [default = UNKNOWN_ERROR];

  bool has_code() const;

  void clear_code();

  static const int kCodeFieldNumber = 1;

  ::yb::cdc::CDCErrorPB_Code code() const;

  void set_code(::yb::cdc::CDCErrorPB_Code value);

  // @@protoc_insertion_point(class_scope:yb.cdc.CDCErrorPB)

 private:

  void set_has_code();

  void clear_has_code();

  void set_has_status();

  void clear_has_status();

  ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;

  ::google::protobuf::internal::HasBits<1> _has_bits_;

  mutable int _cached_size_;

  ::yb::AppStatusPB* status_;

  int code_;

  friend struct ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::TableStruct;

  friend void ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::InitDefaultsCDCErrorPBImpl();

};

// -------------------------------------------------------------------

class CreateCDCStreamRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.CreateCDCStreamRequestPB) */ {

 public:

  CreateCDCStreamRequestPB();

  virtual ~CreateCDCStreamRequestPB();

  CreateCDCStreamRequestPB(const CreateCDCStreamRequestPB& from);

  inline CreateCDCStreamRequestPB& operator=(const CreateCDCStreamRequestPB& from) {

    CopyFrom(from);

    return *this;

  }

  #if LANG_CXX11

  CreateCDCStreamRequestPB(CreateCDCStreamRequestPB&& from) noexcept

    : CreateCDCStreamRequestPB() {

    *this = ::std::move(from);

  }

  inline CreateCDCStreamRequestPB& operator=(CreateCDCStreamRequestPB&& from) noexcept {

    if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {

      if (this != &from) InternalSwap(&from);

    } else {

      CopyFrom(from);

    }

    return *this;

  }

  #endif

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {

    return _internal_metadata_.unknown_fields();

  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {

    return _internal_metadata_.mutable_unknown_fields();

  }

  static const ::google::protobuf::Descriptor* descriptor();

  static const CreateCDCStreamRequestPB& default_instance();

  static void InitAsDefaultInstance();  // FOR INTERNAL USE ONLY

  static inline const CreateCDCStreamRequestPB* internal_default_instance() {

    return reinterpret_cast<const CreateCDCStreamRequestPB*>(

               &_CreateCDCStreamRequestPB_default_instance_);

  }

  static PROTOBUF_CONSTEXPR int const kIndexInFileMessages =

    1;

  void Swap(CreateCDCStreamRequestPB* other);

  friend void swap(CreateCDCStreamRequestPB& a, CreateCDCStreamRequestPB& b) {

    a.Swap(&b);

  }

  // implements Message ----------------------------------------------

  inline CreateCDCStreamRequestPB* New() const PROTOBUF_FINAL { return New(NULL); }

  CreateCDCStreamRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL;

  void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void CopyFrom(const CreateCDCStreamRequestPB& from);

  void MergeFrom(const CreateCDCStreamRequestPB& from);

  void Clear() PROTOBUF_FINAL;

  bool IsInitialized() const PROTOBUF_FINAL;

  size_t ByteSizeLong() const PROTOBUF_FINAL;

  bool MergePartialFromCodedStream(

      ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL;

  void SerializeWithCachedSizes(

      ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL;

  ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(

      bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL;

  int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; }

  private:

  void SharedCtor();

  void SharedDtor();

  void SetCachedSize(int size) const PROTOBUF_FINAL;

  void InternalSwap(CreateCDCStreamRequestPB* other);

  private:

  inline ::google::protobuf::Arena* GetArenaNoVirtual() const {

    return NULL;

  }

  inline void* MaybeArenaPtr() const {

    return NULL;

  }

  public:

  ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional string table_id = 1;

  bool has_table_id() const;

  void clear_table_id();

  static const int kTableIdFieldNumber = 1;

  const ::std::string& table_id() const;

  void set_table_id(const ::std::string& value);

  #if LANG_CXX11

  void set_table_id(::std::string&& value);

  #endif

  void set_table_id(const char* value);

  void set_table_id(const char* value, size_t size);

  ::std::string* mutable_table_id();

  ::std::string* release_table_id();

  void set_allocated_table_id(::std::string* table_id);

  // optional string namespace_name = 4;

  bool has_namespace_name() const;

  void clear_namespace_name();

  static const int kNamespaceNameFieldNumber = 4;

  const ::std::string& namespace_name() const;

  void set_namespace_name(const ::std::string& value);

  #if LANG_CXX11

  void set_namespace_name(::std::string&& value);

  #endif

  void set_namespace_name(const char* value);

  void set_namespace_name(const char* value, size_t size);

  ::std::string* mutable_namespace_name();

  ::std::string* release_namespace_name();

  void set_allocated_namespace_name(::std::string* namespace_name);

  // optional .yb.cdc.CDCRecordType record_type = 2 [default = CHANGE];

  bool has_record_type() const;

  void clear_record_type();

  static const int kRecordTypeFieldNumber = 2;

  ::yb::cdc::CDCRecordType record_type() const;

  void set_record_type(::yb::cdc::CDCRecordType value);

  // optional .yb.cdc.CDCRecordFormat record_format = 3 [default = JSON];

  bool has_record_format() const;

  void clear_record_format();

  static const int kRecordFormatFieldNumber = 3;

  ::yb::cdc::CDCRecordFormat record_format() const;

  void set_record_format(::yb::cdc::CDCRecordFormat value);

  // optional .yb.cdc.CDCRequestSource source_type = 5 [default = XCLUSTER];

  bool has_source_type() const;

  void clear_source_type();

  static const int kSourceTypeFieldNumber = 5;

  ::yb::cdc::CDCRequestSource source_type() const;

  void set_source_type(::yb::cdc::CDCRequestSource value);

  // optional .yb.cdc.CDCCheckpointType checkpoint_type = 6 [default = IMPLICIT];

  bool has_checkpoint_type() const;

  void clear_checkpoint_type();

  static const int kCheckpointTypeFieldNumber = 6;

  ::yb::cdc::CDCCheckpointType checkpoint_type() const;

  void set_checkpoint_type(::yb::cdc::CDCCheckpointType value);

  // @@protoc_insertion_point(class_scope:yb.cdc.CreateCDCStreamRequestPB)

 private:

  void set_has_table_id();

  void clear_has_table_id();

  void set_has_record_type();

  void clear_has_record_type();

  void set_has_record_format();

  void clear_has_record_format();

  void set_has_namespace_name();

  void clear_has_namespace_name();

  void set_has_source_type();

  void clear_has_source_type();

  void set_has_checkpoint_type();

  void clear_has_checkpoint_type();

  ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;

  ::google::protobuf::internal::HasBits<1> _has_bits_;

  mutable int _cached_size_;

  ::google::protobuf::internal::ArenaStringPtr table_id_;

  ::google::protobuf::internal::ArenaStringPtr namespace_name_;

  int record_type_;

  int record_format_;

  int source_type_;

  int checkpoint_type_;

  friend struct ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::TableStruct;

  friend void ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::InitDefaultsCreateCDCStreamRequestPBImpl();

};

// -------------------------------------------------------------------

class CreateCDCStreamResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.CreateCDCStreamResponsePB) */ {

 public:

  CreateCDCStreamResponsePB();

  virtual ~CreateCDCStreamResponsePB();

  CreateCDCStreamResponsePB(const CreateCDCStreamResponsePB& from);

  inline CreateCDCStreamResponsePB& operator=(const CreateCDCStreamResponsePB& from) {

    CopyFrom(from);

    return *this;

  }

  #if LANG_CXX11

  CreateCDCStreamResponsePB(CreateCDCStreamResponsePB&& from) noexcept

    : CreateCDCStreamResponsePB() {

    *this = ::std::move(from);

  }

  inline CreateCDCStreamResponsePB& operator=(CreateCDCStreamResponsePB&& from) noexcept {

    if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {

      if (this != &from) InternalSwap(&from);

    } else {

      CopyFrom(from);

    }

    return *this;

  }

  #endif

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {

    return _internal_metadata_.unknown_fields();

  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {

    return _internal_metadata_.mutable_unknown_fields();

  }

  static const ::google::protobuf::Descriptor* descriptor();

  static const CreateCDCStreamResponsePB& default_instance();

  static void InitAsDefaultInstance();  // FOR INTERNAL USE ONLY

  static inline const CreateCDCStreamResponsePB* internal_default_instance() {

    return reinterpret_cast<const CreateCDCStreamResponsePB*>(

               &_CreateCDCStreamResponsePB_default_instance_);

  }

  static PROTOBUF_CONSTEXPR int const kIndexInFileMessages =

    2;

  void Swap(CreateCDCStreamResponsePB* other);

  friend void swap(CreateCDCStreamResponsePB& a, CreateCDCStreamResponsePB& b) {

    a.Swap(&b);

  }

  // implements Message ----------------------------------------------

  inline CreateCDCStreamResponsePB* New() const PROTOBUF_FINAL { return New(NULL); }

  CreateCDCStreamResponsePB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL;

  void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void CopyFrom(const CreateCDCStreamResponsePB& from);

  void MergeFrom(const CreateCDCStreamResponsePB& from);

  void Clear() PROTOBUF_FINAL;

  bool IsInitialized() const PROTOBUF_FINAL;

  size_t ByteSizeLong() const PROTOBUF_FINAL;

  bool MergePartialFromCodedStream(

      ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL;

  void SerializeWithCachedSizes(

      ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL;

  ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(

      bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL;

  int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; }

  private:

  void SharedCtor();

  void SharedDtor();

  void SetCachedSize(int size) const PROTOBUF_FINAL;

  void InternalSwap(CreateCDCStreamResponsePB* other);

  private:

  inline ::google::protobuf::Arena* GetArenaNoVirtual() const {

    return NULL;

  }

  inline void* MaybeArenaPtr() const {

    return NULL;

  }

  public:

  ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional bytes stream_id = 2;

  bool has_stream_id() const;

  void clear_stream_id();

  static const int kStreamIdFieldNumber = 2;

  const ::std::string& stream_id() const;

  void set_stream_id(const ::std::string& value);

  #if LANG_CXX11

  void set_stream_id(::std::string&& value);

  #endif

  void set_stream_id(const char* value);

  void set_stream_id(const void* value, size_t size);

  ::std::string* mutable_stream_id();

  ::std::string* release_stream_id();

  void set_allocated_stream_id(::std::string* stream_id);

  // optional bytes db_stream_id = 3;

  bool has_db_stream_id() const;

  void clear_db_stream_id();

  static const int kDbStreamIdFieldNumber = 3;

  const ::std::string& db_stream_id() const;

  void set_db_stream_id(const ::std::string& value);

  #if LANG_CXX11

  void set_db_stream_id(::std::string&& value);

  #endif

  void set_db_stream_id(const char* value);

  void set_db_stream_id(const void* value, size_t size);

  ::std::string* mutable_db_stream_id();

  ::std::string* release_db_stream_id();

  void set_allocated_db_stream_id(::std::string* db_stream_id);

  // optional .yb.cdc.CDCErrorPB error = 1;

  bool has_error() const;

  void clear_error();

  static const int kErrorFieldNumber = 1;

  const ::yb::cdc::CDCErrorPB& error() const;

  ::yb::cdc::CDCErrorPB* release_error();

  ::yb::cdc::CDCErrorPB* mutable_error();

  void set_allocated_error(::yb::cdc::CDCErrorPB* error);

  // @@protoc_insertion_point(class_scope:yb.cdc.CreateCDCStreamResponsePB)

 private:

  void set_has_error();

  void clear_has_error();

  void set_has_stream_id();

  void clear_has_stream_id();

  void set_has_db_stream_id();

  void clear_has_db_stream_id();

  ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;

  ::google::protobuf::internal::HasBits<1> _has_bits_;

  mutable int _cached_size_;

  ::google::protobuf::internal::ArenaStringPtr stream_id_;

  ::google::protobuf::internal::ArenaStringPtr db_stream_id_;

  ::yb::cdc::CDCErrorPB* error_;

  friend struct ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::TableStruct;

  friend void ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::InitDefaultsCreateCDCStreamResponsePBImpl();

};

// -------------------------------------------------------------------

class DeleteCDCStreamRequestPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.DeleteCDCStreamRequestPB) */ {

 public:

  DeleteCDCStreamRequestPB();

  virtual ~DeleteCDCStreamRequestPB();

  DeleteCDCStreamRequestPB(const DeleteCDCStreamRequestPB& from);

  inline DeleteCDCStreamRequestPB& operator=(const DeleteCDCStreamRequestPB& from) {

    CopyFrom(from);

    return *this;

  }

  #if LANG_CXX11

  DeleteCDCStreamRequestPB(DeleteCDCStreamRequestPB&& from) noexcept

    : DeleteCDCStreamRequestPB() {

    *this = ::std::move(from);

  }

  inline DeleteCDCStreamRequestPB& operator=(DeleteCDCStreamRequestPB&& from) noexcept {

    if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {

      if (this != &from) InternalSwap(&from);

    } else {

      CopyFrom(from);

    }

    return *this;

  }

  #endif

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {

    return _internal_metadata_.unknown_fields();

  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {

    return _internal_metadata_.mutable_unknown_fields();

  }

  static const ::google::protobuf::Descriptor* descriptor();

  static const DeleteCDCStreamRequestPB& default_instance();

  static void InitAsDefaultInstance();  // FOR INTERNAL USE ONLY

  static inline const DeleteCDCStreamRequestPB* internal_default_instance() {

    return reinterpret_cast<const DeleteCDCStreamRequestPB*>(

               &_DeleteCDCStreamRequestPB_default_instance_);

  }

  static PROTOBUF_CONSTEXPR int const kIndexInFileMessages =

    3;

  void Swap(DeleteCDCStreamRequestPB* other);

  friend void swap(DeleteCDCStreamRequestPB& a, DeleteCDCStreamRequestPB& b) {

    a.Swap(&b);

  }

  // implements Message ----------------------------------------------

  inline DeleteCDCStreamRequestPB* New() const PROTOBUF_FINAL { return New(NULL); }

  DeleteCDCStreamRequestPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL;

  void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL;

  void CopyFrom(const DeleteCDCStreamRequestPB& from);

  void MergeFrom(const DeleteCDCStreamRequestPB& from);

  void Clear() PROTOBUF_FINAL;

  bool IsInitialized() const PROTOBUF_FINAL;

  size_t ByteSizeLong() const PROTOBUF_FINAL;

  bool MergePartialFromCodedStream(

      ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL;

  void SerializeWithCachedSizes(

      ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL;

  ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray(

      bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL;

  int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; }

  private:

  void SharedCtor();

  void SharedDtor();

  void SetCachedSize(int size) const PROTOBUF_FINAL;

  void InternalSwap(DeleteCDCStreamRequestPB* other);

  private:

  inline ::google::protobuf::Arena* GetArenaNoVirtual() const {

    return NULL;

  }

  inline void* MaybeArenaPtr() const {

    return NULL;

  }

  public:

  ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // repeated bytes stream_id = 1;

  int stream_id_size() const;

  void clear_stream_id();

  static const int kStreamIdFieldNumber = 1;

  const ::std::string& stream_id(int index) const;

  ::std::string* mutable_stream_id(int index);

  void set_stream_id(int index, const ::std::string& value);

  #if LANG_CXX11

  void set_stream_id(int index, ::std::string&& value);

  #endif

  void set_stream_id(int index, const char* value);

  void set_stream_id(int index, const void* value, size_t size);

  ::std::string* add_stream_id();

  void add_stream_id(const ::std::string& value);

  #if LANG_CXX11

  void add_stream_id(::std::string&& value);

  #endif

  void add_stream_id(const char* value);

  void add_stream_id(const void* value, size_t size);

  const ::google::protobuf::RepeatedPtrField< ::std::string>& stream_id() const;

  ::google::protobuf::RepeatedPtrField< ::std::string>* mutable_stream_id();

  // optional bool ignore_errors = 2 [default = false];

  bool has_ignore_errors() const;

  void clear_ignore_errors();

  static const int kIgnoreErrorsFieldNumber = 2;

  bool ignore_errors() const;

  void set_ignore_errors(bool value);

  // optional bool force_delete = 3 [default = false];

  bool has_force_delete() const;

  void clear_force_delete();

  static const int kForceDeleteFieldNumber = 3;

  bool force_delete() const;

  void set_force_delete(bool value);

  // @@protoc_insertion_point(class_scope:yb.cdc.DeleteCDCStreamRequestPB)

 private:

  void set_has_ignore_errors();

  void clear_has_ignore_errors();

  void set_has_force_delete();

  void clear_has_force_delete();

  ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_;

  ::google::protobuf::internal::HasBits<1> _has_bits_;

  mutable int _cached_size_;

  ::google::protobuf::RepeatedPtrField< ::std::string> stream_id_;

  bool ignore_errors_;

  bool force_delete_;

  friend struct ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::TableStruct;

  friend void ::protobuf_yb_2fcdc_2fcdc_5fservice_2eproto::InitDefaultsDeleteCDCStreamRequestPBImpl();

};

// -------------------------------------------------------------------

class DeleteCDCStreamResponsePB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.DeleteCDCStreamResponsePB) */ {

 public:

  DeleteCDCStreamResponsePB();

  virtual ~DeleteCDCStreamResponsePB();

  DeleteCDCStreamResponsePB(const DeleteCDCStreamResponsePB& from);

  inline DeleteCDCStreamResponsePB& operator=(const DeleteCDCStreamResponsePB& from) {

    CopyFrom(from);

    return *this;

  }

  #if LANG_CXX11

  DeleteCDCStreamResponsePB(DeleteCDCStreamResponsePB&& from) noexcept

    : DeleteCDCStreamResponsePB() {

    *this = ::std::move(from);

  }