/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/cdc/cdc_consumer.pb.h
Line | Count | Source (jump to first uncovered line) |
1 | | // Generated by the protocol buffer compiler. DO NOT EDIT! |
2 | | // source: yb/cdc/cdc_consumer.proto |
3 | | |
4 | | #ifndef PROTOBUF_yb_2fcdc_2fcdc_5fconsumer_2eproto__INCLUDED |
5 | | #define PROTOBUF_yb_2fcdc_2fcdc_5fconsumer_2eproto__INCLUDED |
6 | | |
7 | | #include <string> |
8 | | |
9 | | #include <google/protobuf/stubs/common.h> |
10 | | |
11 | | #if GOOGLE_PROTOBUF_VERSION < 3005000 |
12 | | #error This file was generated by a newer version of protoc which is |
13 | | #error incompatible with your Protocol Buffer headers. Please update |
14 | | #error your headers. |
15 | | #endif |
16 | | #if 3005001 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION |
17 | | #error This file was generated by an older version of protoc which is |
18 | | #error incompatible with your Protocol Buffer headers. Please |
19 | | #error regenerate this file with a newer version of protoc. |
20 | | #endif |
21 | | |
22 | | #include <google/protobuf/io/coded_stream.h> |
23 | | #include <google/protobuf/arena.h> |
24 | | #include <google/protobuf/arenastring.h> |
25 | | #include <google/protobuf/generated_message_table_driven.h> |
26 | | #include <google/protobuf/generated_message_util.h> |
27 | | #include <google/protobuf/metadata.h> |
28 | | #include <google/protobuf/message.h> |
29 | | #include <google/protobuf/repeated_field.h> // IWYU pragma: export |
30 | | #include <google/protobuf/extension_set.h> // IWYU pragma: export |
31 | | #include <google/protobuf/map.h> // IWYU pragma: export |
32 | | #include <google/protobuf/map_entry.h> |
33 | | #include <google/protobuf/map_field_inl.h> |
34 | | #include <google/protobuf/unknown_field_set.h> |
35 | | #include "yb/common/common_net.pb.h" |
36 | | // @@protoc_insertion_point(includes) |
37 | | |
38 | | namespace protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto { |
39 | | // Internal implementation detail -- do not use these members. |
40 | | struct TableStruct { |
41 | | static const ::google::protobuf::internal::ParseTableField entries[]; |
42 | | static const ::google::protobuf::internal::AuxillaryParseTableField aux[]; |
43 | | static const ::google::protobuf::internal::ParseTable schema[7]; |
44 | | static const ::google::protobuf::internal::FieldMetadata field_metadata[]; |
45 | | static const ::google::protobuf::internal::SerializationTable serialization_table[]; |
46 | | static const ::google::protobuf::uint32 offsets[]; |
47 | | }; |
48 | | void AddDescriptors(); |
49 | | void InitDefaultsProducerTabletListPBImpl(); |
50 | | void InitDefaultsProducerTabletListPB(); |
51 | | void InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUseImpl(); |
52 | | void InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse(); |
53 | | void InitDefaultsStreamEntryPBImpl(); |
54 | | void InitDefaultsStreamEntryPB(); |
55 | | void InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUseImpl(); |
56 | | void InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUse(); |
57 | | void InitDefaultsProducerEntryPBImpl(); |
58 | | void InitDefaultsProducerEntryPB(); |
59 | | void InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUseImpl(); |
60 | | void InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUse(); |
61 | | void InitDefaultsConsumerRegistryPBImpl(); |
62 | | void InitDefaultsConsumerRegistryPB(); |
63 | 15.8k | inline void InitDefaults() { |
64 | 15.8k | InitDefaultsProducerTabletListPB(); |
65 | 15.8k | InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse(); |
66 | 15.8k | InitDefaultsStreamEntryPB(); |
67 | 15.8k | InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUse(); |
68 | 15.8k | InitDefaultsProducerEntryPB(); |
69 | 15.8k | InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUse(); |
70 | 15.8k | InitDefaultsConsumerRegistryPB(); |
71 | 15.8k | } |
72 | | } // namespace protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto |
73 | | namespace yb { |
74 | | namespace cdc { |
75 | | class ConsumerRegistryPB; |
76 | | class ConsumerRegistryPBDefaultTypeInternal; |
77 | | extern ConsumerRegistryPBDefaultTypeInternal _ConsumerRegistryPB_default_instance_; |
78 | | class ConsumerRegistryPB_ProducerMapEntry_DoNotUse; |
79 | | class ConsumerRegistryPB_ProducerMapEntry_DoNotUseDefaultTypeInternal; |
80 | | extern ConsumerRegistryPB_ProducerMapEntry_DoNotUseDefaultTypeInternal _ConsumerRegistryPB_ProducerMapEntry_DoNotUse_default_instance_; |
81 | | class ProducerEntryPB; |
82 | | class ProducerEntryPBDefaultTypeInternal; |
83 | | extern ProducerEntryPBDefaultTypeInternal _ProducerEntryPB_default_instance_; |
84 | | class ProducerEntryPB_StreamMapEntry_DoNotUse; |
85 | | class ProducerEntryPB_StreamMapEntry_DoNotUseDefaultTypeInternal; |
86 | | extern ProducerEntryPB_StreamMapEntry_DoNotUseDefaultTypeInternal _ProducerEntryPB_StreamMapEntry_DoNotUse_default_instance_; |
87 | | class ProducerTabletListPB; |
88 | | class ProducerTabletListPBDefaultTypeInternal; |
89 | | extern ProducerTabletListPBDefaultTypeInternal _ProducerTabletListPB_default_instance_; |
90 | | class StreamEntryPB; |
91 | | class StreamEntryPBDefaultTypeInternal; |
92 | | extern StreamEntryPBDefaultTypeInternal _StreamEntryPB_default_instance_; |
93 | | class StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse; |
94 | | class StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUseDefaultTypeInternal; |
95 | | extern StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUseDefaultTypeInternal _StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse_default_instance_; |
96 | | } // namespace cdc |
97 | | } // namespace yb |
98 | | namespace yb { |
99 | | namespace cdc { |
100 | | |
101 | | // =================================================================== |
102 | | |
103 | | class ProducerTabletListPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.ProducerTabletListPB) */ { |
104 | | public: |
105 | | ProducerTabletListPB(); |
106 | | virtual ~ProducerTabletListPB(); |
107 | | |
108 | | ProducerTabletListPB(const ProducerTabletListPB& from); |
109 | | |
110 | 0 | inline ProducerTabletListPB& operator=(const ProducerTabletListPB& from) { |
111 | 0 | CopyFrom(from); |
112 | 0 | return *this; |
113 | 0 | } |
114 | | #if LANG_CXX11 |
115 | | ProducerTabletListPB(ProducerTabletListPB&& from) noexcept |
116 | 0 | : ProducerTabletListPB() { |
117 | 0 | *this = ::std::move(from); |
118 | 0 | } |
119 | | |
120 | 0 | inline ProducerTabletListPB& operator=(ProducerTabletListPB&& from) noexcept { |
121 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
122 | 0 | if (this != &from) InternalSwap(&from); |
123 | 0 | } else { |
124 | 0 | CopyFrom(from); |
125 | 0 | } |
126 | 0 | return *this; |
127 | 0 | } |
128 | | #endif |
129 | | static const ::google::protobuf::Descriptor* descriptor(); |
130 | | static const ProducerTabletListPB& default_instance(); |
131 | | |
132 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
133 | 31.6k | static inline const ProducerTabletListPB* internal_default_instance() { |
134 | 31.6k | return reinterpret_cast<const ProducerTabletListPB*>( |
135 | 31.6k | &_ProducerTabletListPB_default_instance_); |
136 | 31.6k | } |
137 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
138 | | 0; |
139 | | |
140 | | void Swap(ProducerTabletListPB* other); |
141 | 0 | friend void swap(ProducerTabletListPB& a, ProducerTabletListPB& b) { |
142 | 0 | a.Swap(&b); |
143 | 0 | } |
144 | | |
145 | | // implements Message ---------------------------------------------- |
146 | | |
147 | 0 | inline ProducerTabletListPB* New() const PROTOBUF_FINAL { return New(NULL); } |
148 | | |
149 | | ProducerTabletListPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
150 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
151 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
152 | | void CopyFrom(const ProducerTabletListPB& from); |
153 | | void MergeFrom(const ProducerTabletListPB& from); |
154 | | void Clear() PROTOBUF_FINAL; |
155 | | bool IsInitialized() const PROTOBUF_FINAL; |
156 | | |
157 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
158 | | bool MergePartialFromCodedStream( |
159 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
160 | | void SerializeWithCachedSizes( |
161 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
162 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
163 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
164 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
165 | | private: |
166 | | void SharedCtor(); |
167 | | void SharedDtor(); |
168 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
169 | | void InternalSwap(ProducerTabletListPB* other); |
170 | | private: |
171 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
172 | 0 | return NULL; |
173 | 0 | } |
174 | 0 | inline void* MaybeArenaPtr() const { |
175 | 0 | return NULL; |
176 | 0 | } |
177 | | public: |
178 | | |
179 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
180 | | |
181 | | // nested types ---------------------------------------------------- |
182 | | |
183 | | // accessors ------------------------------------------------------- |
184 | | |
185 | | // repeated string tablets = 1; |
186 | | int tablets_size() const; |
187 | | void clear_tablets(); |
188 | | static const int kTabletsFieldNumber = 1; |
189 | | const ::std::string& tablets(int index) const; |
190 | | ::std::string* mutable_tablets(int index); |
191 | | void set_tablets(int index, const ::std::string& value); |
192 | | #if LANG_CXX11 |
193 | | void set_tablets(int index, ::std::string&& value); |
194 | | #endif |
195 | | void set_tablets(int index, const char* value); |
196 | | void set_tablets(int index, const char* value, size_t size); |
197 | | ::std::string* add_tablets(); |
198 | | void add_tablets(const ::std::string& value); |
199 | | #if LANG_CXX11 |
200 | | void add_tablets(::std::string&& value); |
201 | | #endif |
202 | | void add_tablets(const char* value); |
203 | | void add_tablets(const char* value, size_t size); |
204 | | const ::google::protobuf::RepeatedPtrField< ::std::string>& tablets() const; |
205 | | ::google::protobuf::RepeatedPtrField< ::std::string>* mutable_tablets(); |
206 | | |
207 | | // @@protoc_insertion_point(class_scope:yb.cdc.ProducerTabletListPB) |
208 | | private: |
209 | | |
210 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
211 | | ::google::protobuf::RepeatedPtrField< ::std::string> tablets_; |
212 | | mutable int _cached_size_; |
213 | | friend struct ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::TableStruct; |
214 | | friend void ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerTabletListPBImpl(); |
215 | | }; |
216 | | // ------------------------------------------------------------------- |
217 | | |
218 | | class StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse : public ::google::protobuf::internal::MapEntry<StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, |
219 | | ::std::string, ::yb::cdc::ProducerTabletListPB, |
220 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
221 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
222 | | 0 > { |
223 | | public: |
224 | | typedef ::google::protobuf::internal::MapEntry<StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, |
225 | | ::std::string, ::yb::cdc::ProducerTabletListPB, |
226 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
227 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
228 | | 0 > SuperType; |
229 | | StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse(); |
230 | | StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse(::google::protobuf::Arena* arena); |
231 | | void MergeFrom(const StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse& other); |
232 | 15.8k | static const StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse*>(&_StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse_default_instance_); } |
233 | | void MergeFrom(const ::google::protobuf::Message& other) PROTOBUF_FINAL; |
234 | | ::google::protobuf::Metadata GetMetadata() const; |
235 | | }; |
236 | | |
237 | | // ------------------------------------------------------------------- |
238 | | |
239 | | class StreamEntryPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.StreamEntryPB) */ { |
240 | | public: |
241 | | StreamEntryPB(); |
242 | | virtual ~StreamEntryPB(); |
243 | | |
244 | | StreamEntryPB(const StreamEntryPB& from); |
245 | | |
246 | 0 | inline StreamEntryPB& operator=(const StreamEntryPB& from) { |
247 | 0 | CopyFrom(from); |
248 | 0 | return *this; |
249 | 0 | } |
250 | | #if LANG_CXX11 |
251 | | StreamEntryPB(StreamEntryPB&& from) noexcept |
252 | 0 | : StreamEntryPB() { |
253 | 0 | *this = ::std::move(from); |
254 | 0 | } |
255 | | |
256 | 0 | inline StreamEntryPB& operator=(StreamEntryPB&& from) noexcept { |
257 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
258 | 0 | if (this != &from) InternalSwap(&from); |
259 | 0 | } else { |
260 | 0 | CopyFrom(from); |
261 | 0 | } |
262 | 0 | return *this; |
263 | 0 | } |
264 | | #endif |
265 | | static const ::google::protobuf::Descriptor* descriptor(); |
266 | | static const StreamEntryPB& default_instance(); |
267 | | |
268 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
269 | 31.6k | static inline const StreamEntryPB* internal_default_instance() { |
270 | 31.6k | return reinterpret_cast<const StreamEntryPB*>( |
271 | 31.6k | &_StreamEntryPB_default_instance_); |
272 | 31.6k | } |
273 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
274 | | 2; |
275 | | |
276 | | void Swap(StreamEntryPB* other); |
277 | 0 | friend void swap(StreamEntryPB& a, StreamEntryPB& b) { |
278 | 0 | a.Swap(&b); |
279 | 0 | } |
280 | | |
281 | | // implements Message ---------------------------------------------- |
282 | | |
283 | 0 | inline StreamEntryPB* New() const PROTOBUF_FINAL { return New(NULL); } |
284 | | |
285 | | StreamEntryPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
286 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
287 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
288 | | void CopyFrom(const StreamEntryPB& from); |
289 | | void MergeFrom(const StreamEntryPB& from); |
290 | | void Clear() PROTOBUF_FINAL; |
291 | | bool IsInitialized() const PROTOBUF_FINAL; |
292 | | |
293 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
294 | | bool MergePartialFromCodedStream( |
295 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
296 | | void SerializeWithCachedSizes( |
297 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
298 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
299 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
300 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
301 | | private: |
302 | | void SharedCtor(); |
303 | | void SharedDtor(); |
304 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
305 | | void InternalSwap(StreamEntryPB* other); |
306 | | private: |
307 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
308 | 0 | return NULL; |
309 | 0 | } |
310 | 0 | inline void* MaybeArenaPtr() const { |
311 | 0 | return NULL; |
312 | 0 | } |
313 | | public: |
314 | | |
315 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
316 | | |
317 | | // nested types ---------------------------------------------------- |
318 | | |
319 | | |
320 | | // accessors ------------------------------------------------------- |
321 | | |
322 | | // map<string, .yb.cdc.ProducerTabletListPB> consumer_producer_tablet_map = 1; |
323 | | int consumer_producer_tablet_map_size() const; |
324 | | void clear_consumer_producer_tablet_map(); |
325 | | static const int kConsumerProducerTabletMapFieldNumber = 1; |
326 | | const ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >& |
327 | | consumer_producer_tablet_map() const; |
328 | | ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >* |
329 | | mutable_consumer_producer_tablet_map(); |
330 | | |
331 | | // string consumer_table_id = 2; |
332 | | void clear_consumer_table_id(); |
333 | | static const int kConsumerTableIdFieldNumber = 2; |
334 | | const ::std::string& consumer_table_id() const; |
335 | | void set_consumer_table_id(const ::std::string& value); |
336 | | #if LANG_CXX11 |
337 | | void set_consumer_table_id(::std::string&& value); |
338 | | #endif |
339 | | void set_consumer_table_id(const char* value); |
340 | | void set_consumer_table_id(const char* value, size_t size); |
341 | | ::std::string* mutable_consumer_table_id(); |
342 | | ::std::string* release_consumer_table_id(); |
343 | | void set_allocated_consumer_table_id(::std::string* consumer_table_id); |
344 | | |
345 | | // string producer_table_id = 3; |
346 | | void clear_producer_table_id(); |
347 | | static const int kProducerTableIdFieldNumber = 3; |
348 | | const ::std::string& producer_table_id() const; |
349 | | void set_producer_table_id(const ::std::string& value); |
350 | | #if LANG_CXX11 |
351 | | void set_producer_table_id(::std::string&& value); |
352 | | #endif |
353 | | void set_producer_table_id(const char* value); |
354 | | void set_producer_table_id(const char* value, size_t size); |
355 | | ::std::string* mutable_producer_table_id(); |
356 | | ::std::string* release_producer_table_id(); |
357 | | void set_allocated_producer_table_id(::std::string* producer_table_id); |
358 | | |
359 | | // bool same_num_producer_consumer_tablets = 4; |
360 | | void clear_same_num_producer_consumer_tablets(); |
361 | | static const int kSameNumProducerConsumerTabletsFieldNumber = 4; |
362 | | bool same_num_producer_consumer_tablets() const; |
363 | | void set_same_num_producer_consumer_tablets(bool value); |
364 | | |
365 | | // @@protoc_insertion_point(class_scope:yb.cdc.StreamEntryPB) |
366 | | private: |
367 | | |
368 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
369 | | ::google::protobuf::internal::MapField< |
370 | | StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, |
371 | | ::std::string, ::yb::cdc::ProducerTabletListPB, |
372 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
373 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
374 | | 0 > consumer_producer_tablet_map_; |
375 | | ::google::protobuf::internal::ArenaStringPtr consumer_table_id_; |
376 | | ::google::protobuf::internal::ArenaStringPtr producer_table_id_; |
377 | | bool same_num_producer_consumer_tablets_; |
378 | | mutable int _cached_size_; |
379 | | friend struct ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::TableStruct; |
380 | | friend void ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsStreamEntryPBImpl(); |
381 | | }; |
382 | | // ------------------------------------------------------------------- |
383 | | |
384 | | class ProducerEntryPB_StreamMapEntry_DoNotUse : public ::google::protobuf::internal::MapEntry<ProducerEntryPB_StreamMapEntry_DoNotUse, |
385 | | ::std::string, ::yb::cdc::StreamEntryPB, |
386 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
387 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
388 | | 0 > { |
389 | | public: |
390 | | typedef ::google::protobuf::internal::MapEntry<ProducerEntryPB_StreamMapEntry_DoNotUse, |
391 | | ::std::string, ::yb::cdc::StreamEntryPB, |
392 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
393 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
394 | | 0 > SuperType; |
395 | | ProducerEntryPB_StreamMapEntry_DoNotUse(); |
396 | | ProducerEntryPB_StreamMapEntry_DoNotUse(::google::protobuf::Arena* arena); |
397 | | void MergeFrom(const ProducerEntryPB_StreamMapEntry_DoNotUse& other); |
398 | 15.8k | static const ProducerEntryPB_StreamMapEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const ProducerEntryPB_StreamMapEntry_DoNotUse*>(&_ProducerEntryPB_StreamMapEntry_DoNotUse_default_instance_); } |
399 | | void MergeFrom(const ::google::protobuf::Message& other) PROTOBUF_FINAL; |
400 | | ::google::protobuf::Metadata GetMetadata() const; |
401 | | }; |
402 | | |
403 | | // ------------------------------------------------------------------- |
404 | | |
405 | | class ProducerEntryPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.ProducerEntryPB) */ { |
406 | | public: |
407 | | ProducerEntryPB(); |
408 | | virtual ~ProducerEntryPB(); |
409 | | |
410 | | ProducerEntryPB(const ProducerEntryPB& from); |
411 | | |
412 | 0 | inline ProducerEntryPB& operator=(const ProducerEntryPB& from) { |
413 | 0 | CopyFrom(from); |
414 | 0 | return *this; |
415 | 0 | } |
416 | | #if LANG_CXX11 |
417 | | ProducerEntryPB(ProducerEntryPB&& from) noexcept |
418 | 0 | : ProducerEntryPB() { |
419 | 0 | *this = ::std::move(from); |
420 | 0 | } |
421 | | |
422 | 0 | inline ProducerEntryPB& operator=(ProducerEntryPB&& from) noexcept { |
423 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
424 | 0 | if (this != &from) InternalSwap(&from); |
425 | 0 | } else { |
426 | 0 | CopyFrom(from); |
427 | 0 | } |
428 | 0 | return *this; |
429 | 0 | } |
430 | | #endif |
431 | | static const ::google::protobuf::Descriptor* descriptor(); |
432 | | static const ProducerEntryPB& default_instance(); |
433 | | |
434 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
435 | 31.6k | static inline const ProducerEntryPB* internal_default_instance() { |
436 | 31.6k | return reinterpret_cast<const ProducerEntryPB*>( |
437 | 31.6k | &_ProducerEntryPB_default_instance_); |
438 | 31.6k | } |
439 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
440 | | 4; |
441 | | |
442 | | void Swap(ProducerEntryPB* other); |
443 | 0 | friend void swap(ProducerEntryPB& a, ProducerEntryPB& b) { |
444 | 0 | a.Swap(&b); |
445 | 0 | } |
446 | | |
447 | | // implements Message ---------------------------------------------- |
448 | | |
449 | 0 | inline ProducerEntryPB* New() const PROTOBUF_FINAL { return New(NULL); } |
450 | | |
451 | | ProducerEntryPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
452 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
453 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
454 | | void CopyFrom(const ProducerEntryPB& from); |
455 | | void MergeFrom(const ProducerEntryPB& from); |
456 | | void Clear() PROTOBUF_FINAL; |
457 | | bool IsInitialized() const PROTOBUF_FINAL; |
458 | | |
459 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
460 | | bool MergePartialFromCodedStream( |
461 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
462 | | void SerializeWithCachedSizes( |
463 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
464 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
465 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
466 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
467 | | private: |
468 | | void SharedCtor(); |
469 | | void SharedDtor(); |
470 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
471 | | void InternalSwap(ProducerEntryPB* other); |
472 | | private: |
473 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
474 | 0 | return NULL; |
475 | 0 | } |
476 | 0 | inline void* MaybeArenaPtr() const { |
477 | 0 | return NULL; |
478 | 0 | } |
479 | | public: |
480 | | |
481 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
482 | | |
483 | | // nested types ---------------------------------------------------- |
484 | | |
485 | | |
486 | | // accessors ------------------------------------------------------- |
487 | | |
488 | | // map<string, .yb.cdc.StreamEntryPB> stream_map = 1; |
489 | | int stream_map_size() const; |
490 | | void clear_stream_map(); |
491 | | static const int kStreamMapFieldNumber = 1; |
492 | | const ::google::protobuf::Map< ::std::string, ::yb::cdc::StreamEntryPB >& |
493 | | stream_map() const; |
494 | | ::google::protobuf::Map< ::std::string, ::yb::cdc::StreamEntryPB >* |
495 | | mutable_stream_map(); |
496 | | |
497 | | // repeated .yb.HostPortPB master_addrs = 2; |
498 | | int master_addrs_size() const; |
499 | | void clear_master_addrs(); |
500 | | static const int kMasterAddrsFieldNumber = 2; |
501 | | const ::yb::HostPortPB& master_addrs(int index) const; |
502 | | ::yb::HostPortPB* mutable_master_addrs(int index); |
503 | | ::yb::HostPortPB* add_master_addrs(); |
504 | | ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >* |
505 | | mutable_master_addrs(); |
506 | | const ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >& |
507 | | master_addrs() const; |
508 | | |
509 | | // repeated .yb.HostPortPB tserver_addrs = 3; |
510 | | int tserver_addrs_size() const; |
511 | | void clear_tserver_addrs(); |
512 | | static const int kTserverAddrsFieldNumber = 3; |
513 | | const ::yb::HostPortPB& tserver_addrs(int index) const; |
514 | | ::yb::HostPortPB* mutable_tserver_addrs(int index); |
515 | | ::yb::HostPortPB* add_tserver_addrs(); |
516 | | ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >* |
517 | | mutable_tserver_addrs(); |
518 | | const ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >& |
519 | | tserver_addrs() const; |
520 | | |
521 | | // bool disable_stream = 4; |
522 | | void clear_disable_stream(); |
523 | | static const int kDisableStreamFieldNumber = 4; |
524 | | bool disable_stream() const; |
525 | | void set_disable_stream(bool value); |
526 | | |
527 | | // @@protoc_insertion_point(class_scope:yb.cdc.ProducerEntryPB) |
528 | | private: |
529 | | |
530 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
531 | | ::google::protobuf::internal::MapField< |
532 | | ProducerEntryPB_StreamMapEntry_DoNotUse, |
533 | | ::std::string, ::yb::cdc::StreamEntryPB, |
534 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
535 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
536 | | 0 > stream_map_; |
537 | | ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB > master_addrs_; |
538 | | ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB > tserver_addrs_; |
539 | | bool disable_stream_; |
540 | | mutable int _cached_size_; |
541 | | friend struct ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::TableStruct; |
542 | | friend void ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerEntryPBImpl(); |
543 | | }; |
544 | | // ------------------------------------------------------------------- |
545 | | |
546 | | class ConsumerRegistryPB_ProducerMapEntry_DoNotUse : public ::google::protobuf::internal::MapEntry<ConsumerRegistryPB_ProducerMapEntry_DoNotUse, |
547 | | ::std::string, ::yb::cdc::ProducerEntryPB, |
548 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
549 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
550 | | 0 > { |
551 | | public: |
552 | | typedef ::google::protobuf::internal::MapEntry<ConsumerRegistryPB_ProducerMapEntry_DoNotUse, |
553 | | ::std::string, ::yb::cdc::ProducerEntryPB, |
554 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
555 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
556 | | 0 > SuperType; |
557 | | ConsumerRegistryPB_ProducerMapEntry_DoNotUse(); |
558 | | ConsumerRegistryPB_ProducerMapEntry_DoNotUse(::google::protobuf::Arena* arena); |
559 | | void MergeFrom(const ConsumerRegistryPB_ProducerMapEntry_DoNotUse& other); |
560 | 15.8k | static const ConsumerRegistryPB_ProducerMapEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const ConsumerRegistryPB_ProducerMapEntry_DoNotUse*>(&_ConsumerRegistryPB_ProducerMapEntry_DoNotUse_default_instance_); } |
561 | | void MergeFrom(const ::google::protobuf::Message& other) PROTOBUF_FINAL; |
562 | | ::google::protobuf::Metadata GetMetadata() const; |
563 | | }; |
564 | | |
565 | | // ------------------------------------------------------------------- |
566 | | |
567 | | class ConsumerRegistryPB : public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:yb.cdc.ConsumerRegistryPB) */ { |
568 | | public: |
569 | | ConsumerRegistryPB(); |
570 | | virtual ~ConsumerRegistryPB(); |
571 | | |
572 | | ConsumerRegistryPB(const ConsumerRegistryPB& from); |
573 | | |
574 | 0 | inline ConsumerRegistryPB& operator=(const ConsumerRegistryPB& from) { |
575 | 0 | CopyFrom(from); |
576 | 0 | return *this; |
577 | 0 | } |
578 | | #if LANG_CXX11 |
579 | | ConsumerRegistryPB(ConsumerRegistryPB&& from) noexcept |
580 | 0 | : ConsumerRegistryPB() { |
581 | 0 | *this = ::std::move(from); |
582 | 0 | } |
583 | | |
584 | 0 | inline ConsumerRegistryPB& operator=(ConsumerRegistryPB&& from) noexcept { |
585 | 0 | if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) { |
586 | 0 | if (this != &from) InternalSwap(&from); |
587 | 0 | } else { |
588 | 0 | CopyFrom(from); |
589 | 0 | } |
590 | 0 | return *this; |
591 | 0 | } |
592 | | #endif |
593 | | static const ::google::protobuf::Descriptor* descriptor(); |
594 | | static const ConsumerRegistryPB& default_instance(); |
595 | | |
596 | | static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY |
597 | 47.5k | static inline const ConsumerRegistryPB* internal_default_instance() { |
598 | 47.5k | return reinterpret_cast<const ConsumerRegistryPB*>( |
599 | 47.5k | &_ConsumerRegistryPB_default_instance_); |
600 | 47.5k | } |
601 | | static PROTOBUF_CONSTEXPR int const kIndexInFileMessages = |
602 | | 6; |
603 | | |
604 | | void Swap(ConsumerRegistryPB* other); |
605 | 0 | friend void swap(ConsumerRegistryPB& a, ConsumerRegistryPB& b) { |
606 | 0 | a.Swap(&b); |
607 | 0 | } |
608 | | |
609 | | // implements Message ---------------------------------------------- |
610 | | |
611 | 0 | inline ConsumerRegistryPB* New() const PROTOBUF_FINAL { return New(NULL); } |
612 | | |
613 | | ConsumerRegistryPB* New(::google::protobuf::Arena* arena) const PROTOBUF_FINAL; |
614 | | void CopyFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
615 | | void MergeFrom(const ::google::protobuf::Message& from) PROTOBUF_FINAL; |
616 | | void CopyFrom(const ConsumerRegistryPB& from); |
617 | | void MergeFrom(const ConsumerRegistryPB& from); |
618 | | void Clear() PROTOBUF_FINAL; |
619 | | bool IsInitialized() const PROTOBUF_FINAL; |
620 | | |
621 | | size_t ByteSizeLong() const PROTOBUF_FINAL; |
622 | | bool MergePartialFromCodedStream( |
623 | | ::google::protobuf::io::CodedInputStream* input) PROTOBUF_FINAL; |
624 | | void SerializeWithCachedSizes( |
625 | | ::google::protobuf::io::CodedOutputStream* output) const PROTOBUF_FINAL; |
626 | | ::google::protobuf::uint8* InternalSerializeWithCachedSizesToArray( |
627 | | bool deterministic, ::google::protobuf::uint8* target) const PROTOBUF_FINAL; |
628 | 0 | int GetCachedSize() const PROTOBUF_FINAL { return _cached_size_; } |
629 | | private: |
630 | | void SharedCtor(); |
631 | | void SharedDtor(); |
632 | | void SetCachedSize(int size) const PROTOBUF_FINAL; |
633 | | void InternalSwap(ConsumerRegistryPB* other); |
634 | | private: |
635 | 0 | inline ::google::protobuf::Arena* GetArenaNoVirtual() const { |
636 | 0 | return NULL; |
637 | 0 | } |
638 | 0 | inline void* MaybeArenaPtr() const { |
639 | 0 | return NULL; |
640 | 0 | } |
641 | | public: |
642 | | |
643 | | ::google::protobuf::Metadata GetMetadata() const PROTOBUF_FINAL; |
644 | | |
645 | | // nested types ---------------------------------------------------- |
646 | | |
647 | | |
648 | | // accessors ------------------------------------------------------- |
649 | | |
650 | | // map<string, .yb.cdc.ProducerEntryPB> producer_map = 1; |
651 | | int producer_map_size() const; |
652 | | void clear_producer_map(); |
653 | | static const int kProducerMapFieldNumber = 1; |
654 | | const ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerEntryPB >& |
655 | | producer_map() const; |
656 | | ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerEntryPB >* |
657 | | mutable_producer_map(); |
658 | | |
659 | | // @@protoc_insertion_point(class_scope:yb.cdc.ConsumerRegistryPB) |
660 | | private: |
661 | | |
662 | | ::google::protobuf::internal::InternalMetadataWithArena _internal_metadata_; |
663 | | ::google::protobuf::internal::MapField< |
664 | | ConsumerRegistryPB_ProducerMapEntry_DoNotUse, |
665 | | ::std::string, ::yb::cdc::ProducerEntryPB, |
666 | | ::google::protobuf::internal::WireFormatLite::TYPE_STRING, |
667 | | ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE, |
668 | | 0 > producer_map_; |
669 | | mutable int _cached_size_; |
670 | | friend struct ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::TableStruct; |
671 | | friend void ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsConsumerRegistryPBImpl(); |
672 | | }; |
673 | | // =================================================================== |
674 | | |
675 | | |
676 | | // =================================================================== |
677 | | |
678 | | #ifdef __GNUC__ |
679 | | #pragma GCC diagnostic push |
680 | | #pragma GCC diagnostic ignored "-Wstrict-aliasing" |
681 | | #endif // __GNUC__ |
682 | | // ProducerTabletListPB |
683 | | |
684 | | // repeated string tablets = 1; |
685 | 0 | inline int ProducerTabletListPB::tablets_size() const { |
686 | 0 | return tablets_.size(); |
687 | 0 | } |
688 | 0 | inline void ProducerTabletListPB::clear_tablets() { |
689 | 0 | tablets_.Clear(); |
690 | 0 | } |
691 | 0 | inline const ::std::string& ProducerTabletListPB::tablets(int index) const { |
692 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.ProducerTabletListPB.tablets) |
693 | 0 | return tablets_.Get(index); |
694 | 0 | } |
695 | 0 | inline ::std::string* ProducerTabletListPB::mutable_tablets(int index) { |
696 | 0 | // @@protoc_insertion_point(field_mutable:yb.cdc.ProducerTabletListPB.tablets) |
697 | 0 | return tablets_.Mutable(index); |
698 | 0 | } |
699 | 0 | inline void ProducerTabletListPB::set_tablets(int index, const ::std::string& value) { |
700 | 0 | // @@protoc_insertion_point(field_set:yb.cdc.ProducerTabletListPB.tablets) |
701 | 0 | tablets_.Mutable(index)->assign(value); |
702 | 0 | } |
703 | | #if LANG_CXX11 |
704 | 0 | inline void ProducerTabletListPB::set_tablets(int index, ::std::string&& value) { |
705 | 0 | // @@protoc_insertion_point(field_set:yb.cdc.ProducerTabletListPB.tablets) |
706 | 0 | tablets_.Mutable(index)->assign(std::move(value)); |
707 | 0 | } |
708 | | #endif |
709 | 0 | inline void ProducerTabletListPB::set_tablets(int index, const char* value) { |
710 | 0 | GOOGLE_DCHECK(value != NULL); |
711 | 0 | tablets_.Mutable(index)->assign(value); |
712 | 0 | // @@protoc_insertion_point(field_set_char:yb.cdc.ProducerTabletListPB.tablets) |
713 | 0 | } |
714 | 0 | inline void ProducerTabletListPB::set_tablets(int index, const char* value, size_t size) { |
715 | 0 | tablets_.Mutable(index)->assign( |
716 | 0 | reinterpret_cast<const char*>(value), size); |
717 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.cdc.ProducerTabletListPB.tablets) |
718 | 0 | } |
719 | 0 | inline ::std::string* ProducerTabletListPB::add_tablets() { |
720 | 0 | // @@protoc_insertion_point(field_add_mutable:yb.cdc.ProducerTabletListPB.tablets) |
721 | 0 | return tablets_.Add(); |
722 | 0 | } |
723 | 0 | inline void ProducerTabletListPB::add_tablets(const ::std::string& value) { |
724 | 0 | tablets_.Add()->assign(value); |
725 | 0 | // @@protoc_insertion_point(field_add:yb.cdc.ProducerTabletListPB.tablets) |
726 | 0 | } |
727 | | #if LANG_CXX11 |
728 | 0 | inline void ProducerTabletListPB::add_tablets(::std::string&& value) { |
729 | 0 | tablets_.Add(std::move(value)); |
730 | 0 | // @@protoc_insertion_point(field_add:yb.cdc.ProducerTabletListPB.tablets) |
731 | 0 | } |
732 | | #endif |
733 | 0 | inline void ProducerTabletListPB::add_tablets(const char* value) { |
734 | 0 | GOOGLE_DCHECK(value != NULL); |
735 | 0 | tablets_.Add()->assign(value); |
736 | 0 | // @@protoc_insertion_point(field_add_char:yb.cdc.ProducerTabletListPB.tablets) |
737 | 0 | } |
738 | 0 | inline void ProducerTabletListPB::add_tablets(const char* value, size_t size) { |
739 | 0 | tablets_.Add()->assign(reinterpret_cast<const char*>(value), size); |
740 | 0 | // @@protoc_insertion_point(field_add_pointer:yb.cdc.ProducerTabletListPB.tablets) |
741 | 0 | } |
742 | | inline const ::google::protobuf::RepeatedPtrField< ::std::string>& |
743 | 0 | ProducerTabletListPB::tablets() const { |
744 | 0 | // @@protoc_insertion_point(field_list:yb.cdc.ProducerTabletListPB.tablets) |
745 | 0 | return tablets_; |
746 | 0 | } |
747 | | inline ::google::protobuf::RepeatedPtrField< ::std::string>* |
748 | 0 | ProducerTabletListPB::mutable_tablets() { |
749 | 0 | // @@protoc_insertion_point(field_mutable_list:yb.cdc.ProducerTabletListPB.tablets) |
750 | 0 | return &tablets_; |
751 | 0 | } |
752 | | |
753 | | // ------------------------------------------------------------------- |
754 | | |
755 | | // ------------------------------------------------------------------- |
756 | | |
757 | | // StreamEntryPB |
758 | | |
759 | | // map<string, .yb.cdc.ProducerTabletListPB> consumer_producer_tablet_map = 1; |
760 | 0 | inline int StreamEntryPB::consumer_producer_tablet_map_size() const { |
761 | 0 | return consumer_producer_tablet_map_.size(); |
762 | 0 | } |
763 | 0 | inline void StreamEntryPB::clear_consumer_producer_tablet_map() { |
764 | 0 | consumer_producer_tablet_map_.Clear(); |
765 | 0 | } |
766 | | inline const ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >& |
767 | 0 | StreamEntryPB::consumer_producer_tablet_map() const { |
768 | 0 | // @@protoc_insertion_point(field_map:yb.cdc.StreamEntryPB.consumer_producer_tablet_map) |
769 | 0 | return consumer_producer_tablet_map_.GetMap(); |
770 | 0 | } |
771 | | inline ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >* |
772 | 0 | StreamEntryPB::mutable_consumer_producer_tablet_map() { |
773 | 0 | // @@protoc_insertion_point(field_mutable_map:yb.cdc.StreamEntryPB.consumer_producer_tablet_map) |
774 | 0 | return consumer_producer_tablet_map_.MutableMap(); |
775 | 0 | } |
776 | | |
777 | | // string consumer_table_id = 2; |
778 | 0 | inline void StreamEntryPB::clear_consumer_table_id() { |
779 | 0 | consumer_table_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
780 | 0 | } |
781 | 0 | inline const ::std::string& StreamEntryPB::consumer_table_id() const { |
782 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.StreamEntryPB.consumer_table_id) |
783 | 0 | return consumer_table_id_.GetNoArena(); |
784 | 0 | } |
785 | 0 | inline void StreamEntryPB::set_consumer_table_id(const ::std::string& value) { |
786 | 0 | |
787 | 0 | consumer_table_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
788 | 0 | // @@protoc_insertion_point(field_set:yb.cdc.StreamEntryPB.consumer_table_id) |
789 | 0 | } |
790 | | #if LANG_CXX11 |
791 | 0 | inline void StreamEntryPB::set_consumer_table_id(::std::string&& value) { |
792 | 0 | |
793 | 0 | consumer_table_id_.SetNoArena( |
794 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
795 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.cdc.StreamEntryPB.consumer_table_id) |
796 | 0 | } |
797 | | #endif |
798 | 0 | inline void StreamEntryPB::set_consumer_table_id(const char* value) { |
799 | 0 | GOOGLE_DCHECK(value != NULL); |
800 | 0 | |
801 | 0 | consumer_table_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
802 | 0 | // @@protoc_insertion_point(field_set_char:yb.cdc.StreamEntryPB.consumer_table_id) |
803 | 0 | } |
804 | 0 | inline void StreamEntryPB::set_consumer_table_id(const char* value, size_t size) { |
805 | 0 | |
806 | 0 | consumer_table_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
807 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
808 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.cdc.StreamEntryPB.consumer_table_id) |
809 | 0 | } |
810 | 0 | inline ::std::string* StreamEntryPB::mutable_consumer_table_id() { |
811 | 0 | |
812 | 0 | // @@protoc_insertion_point(field_mutable:yb.cdc.StreamEntryPB.consumer_table_id) |
813 | 0 | return consumer_table_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
814 | 0 | } |
815 | 0 | inline ::std::string* StreamEntryPB::release_consumer_table_id() { |
816 | 0 | // @@protoc_insertion_point(field_release:yb.cdc.StreamEntryPB.consumer_table_id) |
817 | 0 | |
818 | 0 | return consumer_table_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
819 | 0 | } |
820 | 0 | inline void StreamEntryPB::set_allocated_consumer_table_id(::std::string* consumer_table_id) { |
821 | 0 | if (consumer_table_id != NULL) { |
822 | 0 | |
823 | 0 | } else { |
824 | 0 | |
825 | 0 | } |
826 | 0 | consumer_table_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), consumer_table_id); |
827 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.cdc.StreamEntryPB.consumer_table_id) |
828 | 0 | } |
829 | | |
830 | | // string producer_table_id = 3; |
831 | 0 | inline void StreamEntryPB::clear_producer_table_id() { |
832 | 0 | producer_table_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
833 | 0 | } |
834 | 0 | inline const ::std::string& StreamEntryPB::producer_table_id() const { |
835 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.StreamEntryPB.producer_table_id) |
836 | 0 | return producer_table_id_.GetNoArena(); |
837 | 0 | } |
838 | 0 | inline void StreamEntryPB::set_producer_table_id(const ::std::string& value) { |
839 | 0 | |
840 | 0 | producer_table_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value); |
841 | 0 | // @@protoc_insertion_point(field_set:yb.cdc.StreamEntryPB.producer_table_id) |
842 | 0 | } |
843 | | #if LANG_CXX11 |
844 | 0 | inline void StreamEntryPB::set_producer_table_id(::std::string&& value) { |
845 | 0 | |
846 | 0 | producer_table_id_.SetNoArena( |
847 | 0 | &::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::move(value)); |
848 | 0 | // @@protoc_insertion_point(field_set_rvalue:yb.cdc.StreamEntryPB.producer_table_id) |
849 | 0 | } |
850 | | #endif |
851 | 0 | inline void StreamEntryPB::set_producer_table_id(const char* value) { |
852 | 0 | GOOGLE_DCHECK(value != NULL); |
853 | 0 | |
854 | 0 | producer_table_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value)); |
855 | 0 | // @@protoc_insertion_point(field_set_char:yb.cdc.StreamEntryPB.producer_table_id) |
856 | 0 | } |
857 | 0 | inline void StreamEntryPB::set_producer_table_id(const char* value, size_t size) { |
858 | 0 | |
859 | 0 | producer_table_id_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), |
860 | 0 | ::std::string(reinterpret_cast<const char*>(value), size)); |
861 | 0 | // @@protoc_insertion_point(field_set_pointer:yb.cdc.StreamEntryPB.producer_table_id) |
862 | 0 | } |
863 | 0 | inline ::std::string* StreamEntryPB::mutable_producer_table_id() { |
864 | 0 | |
865 | 0 | // @@protoc_insertion_point(field_mutable:yb.cdc.StreamEntryPB.producer_table_id) |
866 | 0 | return producer_table_id_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
867 | 0 | } |
868 | 0 | inline ::std::string* StreamEntryPB::release_producer_table_id() { |
869 | 0 | // @@protoc_insertion_point(field_release:yb.cdc.StreamEntryPB.producer_table_id) |
870 | 0 | |
871 | 0 | return producer_table_id_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
872 | 0 | } |
873 | 0 | inline void StreamEntryPB::set_allocated_producer_table_id(::std::string* producer_table_id) { |
874 | 0 | if (producer_table_id != NULL) { |
875 | 0 | |
876 | 0 | } else { |
877 | 0 | |
878 | 0 | } |
879 | 0 | producer_table_id_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), producer_table_id); |
880 | 0 | // @@protoc_insertion_point(field_set_allocated:yb.cdc.StreamEntryPB.producer_table_id) |
881 | 0 | } |
882 | | |
883 | | // bool same_num_producer_consumer_tablets = 4; |
884 | 0 | inline void StreamEntryPB::clear_same_num_producer_consumer_tablets() { |
885 | 0 | same_num_producer_consumer_tablets_ = false; |
886 | 0 | } |
887 | 0 | inline bool StreamEntryPB::same_num_producer_consumer_tablets() const { |
888 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.StreamEntryPB.same_num_producer_consumer_tablets) |
889 | 0 | return same_num_producer_consumer_tablets_; |
890 | 0 | } |
891 | 0 | inline void StreamEntryPB::set_same_num_producer_consumer_tablets(bool value) { |
892 | 0 | |
893 | 0 | same_num_producer_consumer_tablets_ = value; |
894 | 0 | // @@protoc_insertion_point(field_set:yb.cdc.StreamEntryPB.same_num_producer_consumer_tablets) |
895 | 0 | } |
896 | | |
897 | | // ------------------------------------------------------------------- |
898 | | |
899 | | // ------------------------------------------------------------------- |
900 | | |
901 | | // ProducerEntryPB |
902 | | |
903 | | // map<string, .yb.cdc.StreamEntryPB> stream_map = 1; |
904 | 0 | inline int ProducerEntryPB::stream_map_size() const { |
905 | 0 | return stream_map_.size(); |
906 | 0 | } |
907 | 0 | inline void ProducerEntryPB::clear_stream_map() { |
908 | 0 | stream_map_.Clear(); |
909 | 0 | } |
910 | | inline const ::google::protobuf::Map< ::std::string, ::yb::cdc::StreamEntryPB >& |
911 | 0 | ProducerEntryPB::stream_map() const { |
912 | 0 | // @@protoc_insertion_point(field_map:yb.cdc.ProducerEntryPB.stream_map) |
913 | 0 | return stream_map_.GetMap(); |
914 | 0 | } |
915 | | inline ::google::protobuf::Map< ::std::string, ::yb::cdc::StreamEntryPB >* |
916 | 0 | ProducerEntryPB::mutable_stream_map() { |
917 | 0 | // @@protoc_insertion_point(field_mutable_map:yb.cdc.ProducerEntryPB.stream_map) |
918 | 0 | return stream_map_.MutableMap(); |
919 | 0 | } |
920 | | |
921 | | // repeated .yb.HostPortPB master_addrs = 2; |
922 | 0 | inline int ProducerEntryPB::master_addrs_size() const { |
923 | 0 | return master_addrs_.size(); |
924 | 0 | } |
925 | 0 | inline const ::yb::HostPortPB& ProducerEntryPB::master_addrs(int index) const { |
926 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.ProducerEntryPB.master_addrs) |
927 | 0 | return master_addrs_.Get(index); |
928 | 0 | } |
929 | 0 | inline ::yb::HostPortPB* ProducerEntryPB::mutable_master_addrs(int index) { |
930 | 0 | // @@protoc_insertion_point(field_mutable:yb.cdc.ProducerEntryPB.master_addrs) |
931 | 0 | return master_addrs_.Mutable(index); |
932 | 0 | } |
933 | 0 | inline ::yb::HostPortPB* ProducerEntryPB::add_master_addrs() { |
934 | 0 | // @@protoc_insertion_point(field_add:yb.cdc.ProducerEntryPB.master_addrs) |
935 | 0 | return master_addrs_.Add(); |
936 | 0 | } |
937 | | inline ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >* |
938 | 0 | ProducerEntryPB::mutable_master_addrs() { |
939 | 0 | // @@protoc_insertion_point(field_mutable_list:yb.cdc.ProducerEntryPB.master_addrs) |
940 | 0 | return &master_addrs_; |
941 | 0 | } |
942 | | inline const ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >& |
943 | 0 | ProducerEntryPB::master_addrs() const { |
944 | 0 | // @@protoc_insertion_point(field_list:yb.cdc.ProducerEntryPB.master_addrs) |
945 | 0 | return master_addrs_; |
946 | 0 | } |
947 | | |
948 | | // repeated .yb.HostPortPB tserver_addrs = 3; |
949 | 0 | inline int ProducerEntryPB::tserver_addrs_size() const { |
950 | 0 | return tserver_addrs_.size(); |
951 | 0 | } |
952 | 0 | inline const ::yb::HostPortPB& ProducerEntryPB::tserver_addrs(int index) const { |
953 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.ProducerEntryPB.tserver_addrs) |
954 | 0 | return tserver_addrs_.Get(index); |
955 | 0 | } |
956 | 0 | inline ::yb::HostPortPB* ProducerEntryPB::mutable_tserver_addrs(int index) { |
957 | 0 | // @@protoc_insertion_point(field_mutable:yb.cdc.ProducerEntryPB.tserver_addrs) |
958 | 0 | return tserver_addrs_.Mutable(index); |
959 | 0 | } |
960 | 0 | inline ::yb::HostPortPB* ProducerEntryPB::add_tserver_addrs() { |
961 | 0 | // @@protoc_insertion_point(field_add:yb.cdc.ProducerEntryPB.tserver_addrs) |
962 | 0 | return tserver_addrs_.Add(); |
963 | 0 | } |
964 | | inline ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >* |
965 | 0 | ProducerEntryPB::mutable_tserver_addrs() { |
966 | 0 | // @@protoc_insertion_point(field_mutable_list:yb.cdc.ProducerEntryPB.tserver_addrs) |
967 | 0 | return &tserver_addrs_; |
968 | 0 | } |
969 | | inline const ::google::protobuf::RepeatedPtrField< ::yb::HostPortPB >& |
970 | 0 | ProducerEntryPB::tserver_addrs() const { |
971 | 0 | // @@protoc_insertion_point(field_list:yb.cdc.ProducerEntryPB.tserver_addrs) |
972 | 0 | return tserver_addrs_; |
973 | 0 | } |
974 | | |
975 | | // bool disable_stream = 4; |
976 | 0 | inline void ProducerEntryPB::clear_disable_stream() { |
977 | 0 | disable_stream_ = false; |
978 | 0 | } |
979 | 0 | inline bool ProducerEntryPB::disable_stream() const { |
980 | 0 | // @@protoc_insertion_point(field_get:yb.cdc.ProducerEntryPB.disable_stream) |
981 | 0 | return disable_stream_; |
982 | 0 | } |
983 | 0 | inline void ProducerEntryPB::set_disable_stream(bool value) { |
984 | 0 | |
985 | 0 | disable_stream_ = value; |
986 | 0 | // @@protoc_insertion_point(field_set:yb.cdc.ProducerEntryPB.disable_stream) |
987 | 0 | } |
988 | | |
989 | | // ------------------------------------------------------------------- |
990 | | |
991 | | // ------------------------------------------------------------------- |
992 | | |
993 | | // ConsumerRegistryPB |
994 | | |
995 | | // map<string, .yb.cdc.ProducerEntryPB> producer_map = 1; |
996 | 0 | inline int ConsumerRegistryPB::producer_map_size() const { |
997 | 0 | return producer_map_.size(); |
998 | 0 | } |
999 | 0 | inline void ConsumerRegistryPB::clear_producer_map() { |
1000 | 0 | producer_map_.Clear(); |
1001 | 0 | } |
1002 | | inline const ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerEntryPB >& |
1003 | 0 | ConsumerRegistryPB::producer_map() const { |
1004 | 0 | // @@protoc_insertion_point(field_map:yb.cdc.ConsumerRegistryPB.producer_map) |
1005 | 0 | return producer_map_.GetMap(); |
1006 | 0 | } |
1007 | | inline ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerEntryPB >* |
1008 | 0 | ConsumerRegistryPB::mutable_producer_map() { |
1009 | 0 | // @@protoc_insertion_point(field_mutable_map:yb.cdc.ConsumerRegistryPB.producer_map) |
1010 | 0 | return producer_map_.MutableMap(); |
1011 | 0 | } |
1012 | | |
1013 | | #ifdef __GNUC__ |
1014 | | #pragma GCC diagnostic pop |
1015 | | #endif // __GNUC__ |
1016 | | // ------------------------------------------------------------------- |
1017 | | |
1018 | | // ------------------------------------------------------------------- |
1019 | | |
1020 | | // ------------------------------------------------------------------- |
1021 | | |
1022 | | // ------------------------------------------------------------------- |
1023 | | |
1024 | | // ------------------------------------------------------------------- |
1025 | | |
1026 | | // ------------------------------------------------------------------- |
1027 | | |
1028 | | |
1029 | | // @@protoc_insertion_point(namespace_scope) |
1030 | | |
1031 | | } // namespace cdc |
1032 | | } // namespace yb |
1033 | | |
1034 | | // @@protoc_insertion_point(global_scope) |
1035 | | |
1036 | | #endif // PROTOBUF_yb_2fcdc_2fcdc_5fconsumer_2eproto__INCLUDED |