1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: tensorflow/core/protobuf/service_config.proto
3
4#ifndef GOOGLE_PROTOBUF_INCLUDED_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto
5#define GOOGLE_PROTOBUF_INCLUDED_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto
6
7#include <limits>
8#include <string>
9
10#include <google/protobuf/port_def.inc>
11#if PROTOBUF_VERSION < 3009000
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 3009002 < 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/port_undef.inc>
23#include <google/protobuf/io/coded_stream.h>
24#include <google/protobuf/arena.h>
25#include <google/protobuf/arenastring.h>
26#include <google/protobuf/generated_message_table_driven.h>
27#include <google/protobuf/generated_message_util.h>
28#include <google/protobuf/inlined_string_field.h>
29#include <google/protobuf/metadata.h>
30#include <google/protobuf/generated_message_reflection.h>
31#include <google/protobuf/message.h>
32#include <google/protobuf/repeated_field.h> // IWYU pragma: export
33#include <google/protobuf/extension_set.h> // IWYU pragma: export
34#include <google/protobuf/unknown_field_set.h>
35#include "tensorflow/core/protobuf/data_service.pb.h"
36// @@protoc_insertion_point(includes)
37#include <google/protobuf/port_def.inc>
38#define PROTOBUF_INTERNAL_EXPORT_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto
39PROTOBUF_NAMESPACE_OPEN
40namespace internal {
41class AnyMetadata;
42} // namespace internal
43PROTOBUF_NAMESPACE_CLOSE
44
45// Internal implementation detail -- do not use these members.
46struct TableStruct_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto {
47 static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[]
48 PROTOBUF_SECTION_VARIABLE(protodesc_cold);
49 static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[]
50 PROTOBUF_SECTION_VARIABLE(protodesc_cold);
51 static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[2]
52 PROTOBUF_SECTION_VARIABLE(protodesc_cold);
53 static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[];
54 static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[];
55 static const ::PROTOBUF_NAMESPACE_ID::uint32 offsets[];
56};
57extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto;
58namespace tensorflow {
59namespace data {
60namespace experimental {
61class DispatcherConfig;
62class DispatcherConfigDefaultTypeInternal;
63extern DispatcherConfigDefaultTypeInternal _DispatcherConfig_default_instance_;
64class WorkerConfig;
65class WorkerConfigDefaultTypeInternal;
66extern WorkerConfigDefaultTypeInternal _WorkerConfig_default_instance_;
67} // namespace experimental
68} // namespace data
69} // namespace tensorflow
70PROTOBUF_NAMESPACE_OPEN
71template<> ::tensorflow::data::experimental::DispatcherConfig* Arena::CreateMaybeMessage<::tensorflow::data::experimental::DispatcherConfig>(Arena*);
72template<> ::tensorflow::data::experimental::WorkerConfig* Arena::CreateMaybeMessage<::tensorflow::data::experimental::WorkerConfig>(Arena*);
73PROTOBUF_NAMESPACE_CLOSE
74namespace tensorflow {
75namespace data {
76namespace experimental {
77
78// ===================================================================
79
80class DispatcherConfig :
81 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tensorflow.data.experimental.DispatcherConfig) */ {
82 public:
83 DispatcherConfig();
84 virtual ~DispatcherConfig();
85
86 DispatcherConfig(const DispatcherConfig& from);
87 DispatcherConfig(DispatcherConfig&& from) noexcept
88 : DispatcherConfig() {
89 *this = ::std::move(from);
90 }
91
92 inline DispatcherConfig& operator=(const DispatcherConfig& from) {
93 CopyFrom(from);
94 return *this;
95 }
96 inline DispatcherConfig& operator=(DispatcherConfig&& from) noexcept {
97 if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
98 if (this != &from) InternalSwap(&from);
99 } else {
100 CopyFrom(from);
101 }
102 return *this;
103 }
104
105 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
106 return GetDescriptor();
107 }
108 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
109 return GetMetadataStatic().descriptor;
110 }
111 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
112 return GetMetadataStatic().reflection;
113 }
114 static const DispatcherConfig& default_instance();
115
116 static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
117 static inline const DispatcherConfig* internal_default_instance() {
118 return reinterpret_cast<const DispatcherConfig*>(
119 &_DispatcherConfig_default_instance_);
120 }
121 static constexpr int kIndexInFileMessages =
122 0;
123
124 friend void swap(DispatcherConfig& a, DispatcherConfig& b) {
125 a.Swap(&b);
126 }
127 inline void Swap(DispatcherConfig* other) {
128 if (other == this) return;
129 InternalSwap(other);
130 }
131
132 // implements Message ----------------------------------------------
133
134 inline DispatcherConfig* New() const final {
135 return CreateMaybeMessage<DispatcherConfig>(nullptr);
136 }
137
138 DispatcherConfig* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
139 return CreateMaybeMessage<DispatcherConfig>(arena);
140 }
141 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
142 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
143 void CopyFrom(const DispatcherConfig& from);
144 void MergeFrom(const DispatcherConfig& from);
145 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
146 bool IsInitialized() const final;
147
148 size_t ByteSizeLong() const final;
149 #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
150 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
151 #else
152 bool MergePartialFromCodedStream(
153 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
154 #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
155 void SerializeWithCachedSizes(
156 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
157 ::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
158 ::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
159 int GetCachedSize() const final { return _cached_size_.Get(); }
160
161 private:
162 inline void SharedCtor();
163 inline void SharedDtor();
164 void SetCachedSize(int size) const final;
165 void InternalSwap(DispatcherConfig* other);
166 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
167 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
168 return "tensorflow.data.experimental.DispatcherConfig";
169 }
170 private:
171 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
172 return nullptr;
173 }
174 inline void* MaybeArenaPtr() const {
175 return nullptr;
176 }
177 public:
178
179 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
180 private:
181 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
182 ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto);
183 return ::descriptor_table_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto.file_level_metadata[kIndexInFileMessages];
184 }
185
186 public:
187
188 // nested types ----------------------------------------------------
189
190 // accessors -------------------------------------------------------
191
192 enum : int {
193 kWorkerAddressesFieldNumber = 7,
194 kProtocolFieldNumber = 2,
195 kWorkDirFieldNumber = 3,
196 kPortFieldNumber = 1,
197 kJobGcCheckIntervalMsFieldNumber = 5,
198 kJobGcTimeoutMsFieldNumber = 6,
199 kFaultTolerantModeFieldNumber = 4,
200 kDeploymentModeFieldNumber = 9,
201 kClientTimeoutMsFieldNumber = 8,
202 };
203 // repeated string worker_addresses = 7;
204 int worker_addresses_size() const;
205 void clear_worker_addresses();
206 const std::string& worker_addresses(int index) const;
207 std::string* mutable_worker_addresses(int index);
208 void set_worker_addresses(int index, const std::string& value);
209 void set_worker_addresses(int index, std::string&& value);
210 void set_worker_addresses(int index, const char* value);
211 void set_worker_addresses(int index, const char* value, size_t size);
212 std::string* add_worker_addresses();
213 void add_worker_addresses(const std::string& value);
214 void add_worker_addresses(std::string&& value);
215 void add_worker_addresses(const char* value);
216 void add_worker_addresses(const char* value, size_t size);
217 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>& worker_addresses() const;
218 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>* mutable_worker_addresses();
219
220 // string protocol = 2;
221 void clear_protocol();
222 const std::string& protocol() const;
223 void set_protocol(const std::string& value);
224 void set_protocol(std::string&& value);
225 void set_protocol(const char* value);
226 void set_protocol(const char* value, size_t size);
227 std::string* mutable_protocol();
228 std::string* release_protocol();
229 void set_allocated_protocol(std::string* protocol);
230
231 // string work_dir = 3;
232 void clear_work_dir();
233 const std::string& work_dir() const;
234 void set_work_dir(const std::string& value);
235 void set_work_dir(std::string&& value);
236 void set_work_dir(const char* value);
237 void set_work_dir(const char* value, size_t size);
238 std::string* mutable_work_dir();
239 std::string* release_work_dir();
240 void set_allocated_work_dir(std::string* work_dir);
241
242 // int64 port = 1;
243 void clear_port();
244 ::PROTOBUF_NAMESPACE_ID::int64 port() const;
245 void set_port(::PROTOBUF_NAMESPACE_ID::int64 value);
246
247 // int64 job_gc_check_interval_ms = 5;
248 void clear_job_gc_check_interval_ms();
249 ::PROTOBUF_NAMESPACE_ID::int64 job_gc_check_interval_ms() const;
250 void set_job_gc_check_interval_ms(::PROTOBUF_NAMESPACE_ID::int64 value);
251
252 // int64 job_gc_timeout_ms = 6;
253 void clear_job_gc_timeout_ms();
254 ::PROTOBUF_NAMESPACE_ID::int64 job_gc_timeout_ms() const;
255 void set_job_gc_timeout_ms(::PROTOBUF_NAMESPACE_ID::int64 value);
256
257 // bool fault_tolerant_mode = 4;
258 void clear_fault_tolerant_mode();
259 bool fault_tolerant_mode() const;
260 void set_fault_tolerant_mode(bool value);
261
262 // .tensorflow.data.DeploymentMode deployment_mode = 9;
263 void clear_deployment_mode();
264 ::tensorflow::data::DeploymentMode deployment_mode() const;
265 void set_deployment_mode(::tensorflow::data::DeploymentMode value);
266
267 // int64 client_timeout_ms = 8;
268 void clear_client_timeout_ms();
269 ::PROTOBUF_NAMESPACE_ID::int64 client_timeout_ms() const;
270 void set_client_timeout_ms(::PROTOBUF_NAMESPACE_ID::int64 value);
271
272 // @@protoc_insertion_point(class_scope:tensorflow.data.experimental.DispatcherConfig)
273 private:
274 class _Internal;
275
276 ::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
277 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string> worker_addresses_;
278 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr protocol_;
279 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr work_dir_;
280 ::PROTOBUF_NAMESPACE_ID::int64 port_;
281 ::PROTOBUF_NAMESPACE_ID::int64 job_gc_check_interval_ms_;
282 ::PROTOBUF_NAMESPACE_ID::int64 job_gc_timeout_ms_;
283 bool fault_tolerant_mode_;
284 int deployment_mode_;
285 ::PROTOBUF_NAMESPACE_ID::int64 client_timeout_ms_;
286 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
287 friend struct ::TableStruct_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto;
288};
289// -------------------------------------------------------------------
290
291class WorkerConfig :
292 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tensorflow.data.experimental.WorkerConfig) */ {
293 public:
294 WorkerConfig();
295 virtual ~WorkerConfig();
296
297 WorkerConfig(const WorkerConfig& from);
298 WorkerConfig(WorkerConfig&& from) noexcept
299 : WorkerConfig() {
300 *this = ::std::move(from);
301 }
302
303 inline WorkerConfig& operator=(const WorkerConfig& from) {
304 CopyFrom(from);
305 return *this;
306 }
307 inline WorkerConfig& operator=(WorkerConfig&& from) noexcept {
308 if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
309 if (this != &from) InternalSwap(&from);
310 } else {
311 CopyFrom(from);
312 }
313 return *this;
314 }
315
316 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
317 return GetDescriptor();
318 }
319 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
320 return GetMetadataStatic().descriptor;
321 }
322 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
323 return GetMetadataStatic().reflection;
324 }
325 static const WorkerConfig& default_instance();
326
327 static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
328 static inline const WorkerConfig* internal_default_instance() {
329 return reinterpret_cast<const WorkerConfig*>(
330 &_WorkerConfig_default_instance_);
331 }
332 static constexpr int kIndexInFileMessages =
333 1;
334
335 friend void swap(WorkerConfig& a, WorkerConfig& b) {
336 a.Swap(&b);
337 }
338 inline void Swap(WorkerConfig* other) {
339 if (other == this) return;
340 InternalSwap(other);
341 }
342
343 // implements Message ----------------------------------------------
344
345 inline WorkerConfig* New() const final {
346 return CreateMaybeMessage<WorkerConfig>(nullptr);
347 }
348
349 WorkerConfig* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
350 return CreateMaybeMessage<WorkerConfig>(arena);
351 }
352 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
353 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
354 void CopyFrom(const WorkerConfig& from);
355 void MergeFrom(const WorkerConfig& from);
356 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
357 bool IsInitialized() const final;
358
359 size_t ByteSizeLong() const final;
360 #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
361 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
362 #else
363 bool MergePartialFromCodedStream(
364 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
365 #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
366 void SerializeWithCachedSizes(
367 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
368 ::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
369 ::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
370 int GetCachedSize() const final { return _cached_size_.Get(); }
371
372 private:
373 inline void SharedCtor();
374 inline void SharedDtor();
375 void SetCachedSize(int size) const final;
376 void InternalSwap(WorkerConfig* other);
377 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
378 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
379 return "tensorflow.data.experimental.WorkerConfig";
380 }
381 private:
382 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
383 return nullptr;
384 }
385 inline void* MaybeArenaPtr() const {
386 return nullptr;
387 }
388 public:
389
390 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
391 private:
392 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
393 ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto);
394 return ::descriptor_table_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto.file_level_metadata[kIndexInFileMessages];
395 }
396
397 public:
398
399 // nested types ----------------------------------------------------
400
401 // accessors -------------------------------------------------------
402
403 enum : int {
404 kWorkerTagsFieldNumber = 10,
405 kProtocolFieldNumber = 2,
406 kDispatcherAddressFieldNumber = 3,
407 kWorkerAddressFieldNumber = 4,
408 kDataTransferProtocolFieldNumber = 7,
409 kDataTransferAddressFieldNumber = 8,
410 kPortFieldNumber = 1,
411 kHeartbeatIntervalMsFieldNumber = 5,
412 kDispatcherTimeoutMsFieldNumber = 6,
413 kShutdownQuietPeriodMsFieldNumber = 9,
414 kCrossTrainerCacheSizeBytesFieldNumber = 11,
415 };
416 // repeated string worker_tags = 10;
417 int worker_tags_size() const;
418 void clear_worker_tags();
419 const std::string& worker_tags(int index) const;
420 std::string* mutable_worker_tags(int index);
421 void set_worker_tags(int index, const std::string& value);
422 void set_worker_tags(int index, std::string&& value);
423 void set_worker_tags(int index, const char* value);
424 void set_worker_tags(int index, const char* value, size_t size);
425 std::string* add_worker_tags();
426 void add_worker_tags(const std::string& value);
427 void add_worker_tags(std::string&& value);
428 void add_worker_tags(const char* value);
429 void add_worker_tags(const char* value, size_t size);
430 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>& worker_tags() const;
431 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>* mutable_worker_tags();
432
433 // string protocol = 2;
434 void clear_protocol();
435 const std::string& protocol() const;
436 void set_protocol(const std::string& value);
437 void set_protocol(std::string&& value);
438 void set_protocol(const char* value);
439 void set_protocol(const char* value, size_t size);
440 std::string* mutable_protocol();
441 std::string* release_protocol();
442 void set_allocated_protocol(std::string* protocol);
443
444 // string dispatcher_address = 3;
445 void clear_dispatcher_address();
446 const std::string& dispatcher_address() const;
447 void set_dispatcher_address(const std::string& value);
448 void set_dispatcher_address(std::string&& value);
449 void set_dispatcher_address(const char* value);
450 void set_dispatcher_address(const char* value, size_t size);
451 std::string* mutable_dispatcher_address();
452 std::string* release_dispatcher_address();
453 void set_allocated_dispatcher_address(std::string* dispatcher_address);
454
455 // string worker_address = 4;
456 void clear_worker_address();
457 const std::string& worker_address() const;
458 void set_worker_address(const std::string& value);
459 void set_worker_address(std::string&& value);
460 void set_worker_address(const char* value);
461 void set_worker_address(const char* value, size_t size);
462 std::string* mutable_worker_address();
463 std::string* release_worker_address();
464 void set_allocated_worker_address(std::string* worker_address);
465
466 // string data_transfer_protocol = 7;
467 void clear_data_transfer_protocol();
468 const std::string& data_transfer_protocol() const;
469 void set_data_transfer_protocol(const std::string& value);
470 void set_data_transfer_protocol(std::string&& value);
471 void set_data_transfer_protocol(const char* value);
472 void set_data_transfer_protocol(const char* value, size_t size);
473 std::string* mutable_data_transfer_protocol();
474 std::string* release_data_transfer_protocol();
475 void set_allocated_data_transfer_protocol(std::string* data_transfer_protocol);
476
477 // string data_transfer_address = 8;
478 void clear_data_transfer_address();
479 const std::string& data_transfer_address() const;
480 void set_data_transfer_address(const std::string& value);
481 void set_data_transfer_address(std::string&& value);
482 void set_data_transfer_address(const char* value);
483 void set_data_transfer_address(const char* value, size_t size);
484 std::string* mutable_data_transfer_address();
485 std::string* release_data_transfer_address();
486 void set_allocated_data_transfer_address(std::string* data_transfer_address);
487
488 // int64 port = 1;
489 void clear_port();
490 ::PROTOBUF_NAMESPACE_ID::int64 port() const;
491 void set_port(::PROTOBUF_NAMESPACE_ID::int64 value);
492
493 // int64 heartbeat_interval_ms = 5;
494 void clear_heartbeat_interval_ms();
495 ::PROTOBUF_NAMESPACE_ID::int64 heartbeat_interval_ms() const;
496 void set_heartbeat_interval_ms(::PROTOBUF_NAMESPACE_ID::int64 value);
497
498 // int64 dispatcher_timeout_ms = 6;
499 void clear_dispatcher_timeout_ms();
500 ::PROTOBUF_NAMESPACE_ID::int64 dispatcher_timeout_ms() const;
501 void set_dispatcher_timeout_ms(::PROTOBUF_NAMESPACE_ID::int64 value);
502
503 // int64 shutdown_quiet_period_ms = 9;
504 void clear_shutdown_quiet_period_ms();
505 ::PROTOBUF_NAMESPACE_ID::int64 shutdown_quiet_period_ms() const;
506 void set_shutdown_quiet_period_ms(::PROTOBUF_NAMESPACE_ID::int64 value);
507
508 // int64 cross_trainer_cache_size_bytes = 11;
509 void clear_cross_trainer_cache_size_bytes();
510 ::PROTOBUF_NAMESPACE_ID::int64 cross_trainer_cache_size_bytes() const;
511 void set_cross_trainer_cache_size_bytes(::PROTOBUF_NAMESPACE_ID::int64 value);
512
513 // @@protoc_insertion_point(class_scope:tensorflow.data.experimental.WorkerConfig)
514 private:
515 class _Internal;
516
517 ::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
518 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string> worker_tags_;
519 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr protocol_;
520 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr dispatcher_address_;
521 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr worker_address_;
522 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr data_transfer_protocol_;
523 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr data_transfer_address_;
524 ::PROTOBUF_NAMESPACE_ID::int64 port_;
525 ::PROTOBUF_NAMESPACE_ID::int64 heartbeat_interval_ms_;
526 ::PROTOBUF_NAMESPACE_ID::int64 dispatcher_timeout_ms_;
527 ::PROTOBUF_NAMESPACE_ID::int64 shutdown_quiet_period_ms_;
528 ::PROTOBUF_NAMESPACE_ID::int64 cross_trainer_cache_size_bytes_;
529 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
530 friend struct ::TableStruct_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto;
531};
532// ===================================================================
533
534
535// ===================================================================
536
537#ifdef __GNUC__
538 #pragma GCC diagnostic push
539 #pragma GCC diagnostic ignored "-Wstrict-aliasing"
540#endif // __GNUC__
541// DispatcherConfig
542
543// int64 port = 1;
544inline void DispatcherConfig::clear_port() {
545 port_ = PROTOBUF_LONGLONG(0);
546}
547inline ::PROTOBUF_NAMESPACE_ID::int64 DispatcherConfig::port() const {
548 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.port)
549 return port_;
550}
551inline void DispatcherConfig::set_port(::PROTOBUF_NAMESPACE_ID::int64 value) {
552
553 port_ = value;
554 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.port)
555}
556
557// string protocol = 2;
558inline void DispatcherConfig::clear_protocol() {
559 protocol_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
560}
561inline const std::string& DispatcherConfig::protocol() const {
562 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.protocol)
563 return protocol_.GetNoArena();
564}
565inline void DispatcherConfig::set_protocol(const std::string& value) {
566
567 protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
568 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.protocol)
569}
570inline void DispatcherConfig::set_protocol(std::string&& value) {
571
572 protocol_.SetNoArena(
573 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
574 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.DispatcherConfig.protocol)
575}
576inline void DispatcherConfig::set_protocol(const char* value) {
577 GOOGLE_DCHECK(value != nullptr);
578
579 protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
580 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.DispatcherConfig.protocol)
581}
582inline void DispatcherConfig::set_protocol(const char* value, size_t size) {
583
584 protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
585 ::std::string(reinterpret_cast<const char*>(value), size));
586 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.DispatcherConfig.protocol)
587}
588inline std::string* DispatcherConfig::mutable_protocol() {
589
590 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.DispatcherConfig.protocol)
591 return protocol_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
592}
593inline std::string* DispatcherConfig::release_protocol() {
594 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.DispatcherConfig.protocol)
595
596 return protocol_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
597}
598inline void DispatcherConfig::set_allocated_protocol(std::string* protocol) {
599 if (protocol != nullptr) {
600
601 } else {
602
603 }
604 protocol_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), protocol);
605 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.DispatcherConfig.protocol)
606}
607
608// string work_dir = 3;
609inline void DispatcherConfig::clear_work_dir() {
610 work_dir_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
611}
612inline const std::string& DispatcherConfig::work_dir() const {
613 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.work_dir)
614 return work_dir_.GetNoArena();
615}
616inline void DispatcherConfig::set_work_dir(const std::string& value) {
617
618 work_dir_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
619 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.work_dir)
620}
621inline void DispatcherConfig::set_work_dir(std::string&& value) {
622
623 work_dir_.SetNoArena(
624 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
625 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.DispatcherConfig.work_dir)
626}
627inline void DispatcherConfig::set_work_dir(const char* value) {
628 GOOGLE_DCHECK(value != nullptr);
629
630 work_dir_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
631 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.DispatcherConfig.work_dir)
632}
633inline void DispatcherConfig::set_work_dir(const char* value, size_t size) {
634
635 work_dir_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
636 ::std::string(reinterpret_cast<const char*>(value), size));
637 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.DispatcherConfig.work_dir)
638}
639inline std::string* DispatcherConfig::mutable_work_dir() {
640
641 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.DispatcherConfig.work_dir)
642 return work_dir_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
643}
644inline std::string* DispatcherConfig::release_work_dir() {
645 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.DispatcherConfig.work_dir)
646
647 return work_dir_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
648}
649inline void DispatcherConfig::set_allocated_work_dir(std::string* work_dir) {
650 if (work_dir != nullptr) {
651
652 } else {
653
654 }
655 work_dir_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), work_dir);
656 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.DispatcherConfig.work_dir)
657}
658
659// bool fault_tolerant_mode = 4;
660inline void DispatcherConfig::clear_fault_tolerant_mode() {
661 fault_tolerant_mode_ = false;
662}
663inline bool DispatcherConfig::fault_tolerant_mode() const {
664 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.fault_tolerant_mode)
665 return fault_tolerant_mode_;
666}
667inline void DispatcherConfig::set_fault_tolerant_mode(bool value) {
668
669 fault_tolerant_mode_ = value;
670 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.fault_tolerant_mode)
671}
672
673// repeated string worker_addresses = 7;
674inline int DispatcherConfig::worker_addresses_size() const {
675 return worker_addresses_.size();
676}
677inline void DispatcherConfig::clear_worker_addresses() {
678 worker_addresses_.Clear();
679}
680inline const std::string& DispatcherConfig::worker_addresses(int index) const {
681 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
682 return worker_addresses_.Get(index);
683}
684inline std::string* DispatcherConfig::mutable_worker_addresses(int index) {
685 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
686 return worker_addresses_.Mutable(index);
687}
688inline void DispatcherConfig::set_worker_addresses(int index, const std::string& value) {
689 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
690 worker_addresses_.Mutable(index)->assign(value);
691}
692inline void DispatcherConfig::set_worker_addresses(int index, std::string&& value) {
693 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
694 worker_addresses_.Mutable(index)->assign(std::move(value));
695}
696inline void DispatcherConfig::set_worker_addresses(int index, const char* value) {
697 GOOGLE_DCHECK(value != nullptr);
698 worker_addresses_.Mutable(index)->assign(value);
699 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
700}
701inline void DispatcherConfig::set_worker_addresses(int index, const char* value, size_t size) {
702 worker_addresses_.Mutable(index)->assign(
703 reinterpret_cast<const char*>(value), size);
704 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
705}
706inline std::string* DispatcherConfig::add_worker_addresses() {
707 // @@protoc_insertion_point(field_add_mutable:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
708 return worker_addresses_.Add();
709}
710inline void DispatcherConfig::add_worker_addresses(const std::string& value) {
711 worker_addresses_.Add()->assign(value);
712 // @@protoc_insertion_point(field_add:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
713}
714inline void DispatcherConfig::add_worker_addresses(std::string&& value) {
715 worker_addresses_.Add(std::move(value));
716 // @@protoc_insertion_point(field_add:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
717}
718inline void DispatcherConfig::add_worker_addresses(const char* value) {
719 GOOGLE_DCHECK(value != nullptr);
720 worker_addresses_.Add()->assign(value);
721 // @@protoc_insertion_point(field_add_char:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
722}
723inline void DispatcherConfig::add_worker_addresses(const char* value, size_t size) {
724 worker_addresses_.Add()->assign(reinterpret_cast<const char*>(value), size);
725 // @@protoc_insertion_point(field_add_pointer:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
726}
727inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>&
728DispatcherConfig::worker_addresses() const {
729 // @@protoc_insertion_point(field_list:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
730 return worker_addresses_;
731}
732inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>*
733DispatcherConfig::mutable_worker_addresses() {
734 // @@protoc_insertion_point(field_mutable_list:tensorflow.data.experimental.DispatcherConfig.worker_addresses)
735 return &worker_addresses_;
736}
737
738// .tensorflow.data.DeploymentMode deployment_mode = 9;
739inline void DispatcherConfig::clear_deployment_mode() {
740 deployment_mode_ = 0;
741}
742inline ::tensorflow::data::DeploymentMode DispatcherConfig::deployment_mode() const {
743 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.deployment_mode)
744 return static_cast< ::tensorflow::data::DeploymentMode >(deployment_mode_);
745}
746inline void DispatcherConfig::set_deployment_mode(::tensorflow::data::DeploymentMode value) {
747
748 deployment_mode_ = value;
749 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.deployment_mode)
750}
751
752// int64 job_gc_check_interval_ms = 5;
753inline void DispatcherConfig::clear_job_gc_check_interval_ms() {
754 job_gc_check_interval_ms_ = PROTOBUF_LONGLONG(0);
755}
756inline ::PROTOBUF_NAMESPACE_ID::int64 DispatcherConfig::job_gc_check_interval_ms() const {
757 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.job_gc_check_interval_ms)
758 return job_gc_check_interval_ms_;
759}
760inline void DispatcherConfig::set_job_gc_check_interval_ms(::PROTOBUF_NAMESPACE_ID::int64 value) {
761
762 job_gc_check_interval_ms_ = value;
763 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.job_gc_check_interval_ms)
764}
765
766// int64 job_gc_timeout_ms = 6;
767inline void DispatcherConfig::clear_job_gc_timeout_ms() {
768 job_gc_timeout_ms_ = PROTOBUF_LONGLONG(0);
769}
770inline ::PROTOBUF_NAMESPACE_ID::int64 DispatcherConfig::job_gc_timeout_ms() const {
771 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.job_gc_timeout_ms)
772 return job_gc_timeout_ms_;
773}
774inline void DispatcherConfig::set_job_gc_timeout_ms(::PROTOBUF_NAMESPACE_ID::int64 value) {
775
776 job_gc_timeout_ms_ = value;
777 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.job_gc_timeout_ms)
778}
779
780// int64 client_timeout_ms = 8;
781inline void DispatcherConfig::clear_client_timeout_ms() {
782 client_timeout_ms_ = PROTOBUF_LONGLONG(0);
783}
784inline ::PROTOBUF_NAMESPACE_ID::int64 DispatcherConfig::client_timeout_ms() const {
785 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.DispatcherConfig.client_timeout_ms)
786 return client_timeout_ms_;
787}
788inline void DispatcherConfig::set_client_timeout_ms(::PROTOBUF_NAMESPACE_ID::int64 value) {
789
790 client_timeout_ms_ = value;
791 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.DispatcherConfig.client_timeout_ms)
792}
793
794// -------------------------------------------------------------------
795
796// WorkerConfig
797
798// int64 port = 1;
799inline void WorkerConfig::clear_port() {
800 port_ = PROTOBUF_LONGLONG(0);
801}
802inline ::PROTOBUF_NAMESPACE_ID::int64 WorkerConfig::port() const {
803 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.port)
804 return port_;
805}
806inline void WorkerConfig::set_port(::PROTOBUF_NAMESPACE_ID::int64 value) {
807
808 port_ = value;
809 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.port)
810}
811
812// string protocol = 2;
813inline void WorkerConfig::clear_protocol() {
814 protocol_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
815}
816inline const std::string& WorkerConfig::protocol() const {
817 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.protocol)
818 return protocol_.GetNoArena();
819}
820inline void WorkerConfig::set_protocol(const std::string& value) {
821
822 protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
823 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.protocol)
824}
825inline void WorkerConfig::set_protocol(std::string&& value) {
826
827 protocol_.SetNoArena(
828 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
829 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.WorkerConfig.protocol)
830}
831inline void WorkerConfig::set_protocol(const char* value) {
832 GOOGLE_DCHECK(value != nullptr);
833
834 protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
835 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.WorkerConfig.protocol)
836}
837inline void WorkerConfig::set_protocol(const char* value, size_t size) {
838
839 protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
840 ::std::string(reinterpret_cast<const char*>(value), size));
841 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.WorkerConfig.protocol)
842}
843inline std::string* WorkerConfig::mutable_protocol() {
844
845 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.WorkerConfig.protocol)
846 return protocol_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
847}
848inline std::string* WorkerConfig::release_protocol() {
849 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.WorkerConfig.protocol)
850
851 return protocol_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
852}
853inline void WorkerConfig::set_allocated_protocol(std::string* protocol) {
854 if (protocol != nullptr) {
855
856 } else {
857
858 }
859 protocol_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), protocol);
860 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.WorkerConfig.protocol)
861}
862
863// string dispatcher_address = 3;
864inline void WorkerConfig::clear_dispatcher_address() {
865 dispatcher_address_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
866}
867inline const std::string& WorkerConfig::dispatcher_address() const {
868 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
869 return dispatcher_address_.GetNoArena();
870}
871inline void WorkerConfig::set_dispatcher_address(const std::string& value) {
872
873 dispatcher_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
874 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
875}
876inline void WorkerConfig::set_dispatcher_address(std::string&& value) {
877
878 dispatcher_address_.SetNoArena(
879 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
880 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
881}
882inline void WorkerConfig::set_dispatcher_address(const char* value) {
883 GOOGLE_DCHECK(value != nullptr);
884
885 dispatcher_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
886 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
887}
888inline void WorkerConfig::set_dispatcher_address(const char* value, size_t size) {
889
890 dispatcher_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
891 ::std::string(reinterpret_cast<const char*>(value), size));
892 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
893}
894inline std::string* WorkerConfig::mutable_dispatcher_address() {
895
896 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
897 return dispatcher_address_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
898}
899inline std::string* WorkerConfig::release_dispatcher_address() {
900 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
901
902 return dispatcher_address_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
903}
904inline void WorkerConfig::set_allocated_dispatcher_address(std::string* dispatcher_address) {
905 if (dispatcher_address != nullptr) {
906
907 } else {
908
909 }
910 dispatcher_address_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), dispatcher_address);
911 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.WorkerConfig.dispatcher_address)
912}
913
914// string worker_address = 4;
915inline void WorkerConfig::clear_worker_address() {
916 worker_address_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
917}
918inline const std::string& WorkerConfig::worker_address() const {
919 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.worker_address)
920 return worker_address_.GetNoArena();
921}
922inline void WorkerConfig::set_worker_address(const std::string& value) {
923
924 worker_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
925 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.worker_address)
926}
927inline void WorkerConfig::set_worker_address(std::string&& value) {
928
929 worker_address_.SetNoArena(
930 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
931 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.WorkerConfig.worker_address)
932}
933inline void WorkerConfig::set_worker_address(const char* value) {
934 GOOGLE_DCHECK(value != nullptr);
935
936 worker_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
937 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.WorkerConfig.worker_address)
938}
939inline void WorkerConfig::set_worker_address(const char* value, size_t size) {
940
941 worker_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
942 ::std::string(reinterpret_cast<const char*>(value), size));
943 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.WorkerConfig.worker_address)
944}
945inline std::string* WorkerConfig::mutable_worker_address() {
946
947 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.WorkerConfig.worker_address)
948 return worker_address_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
949}
950inline std::string* WorkerConfig::release_worker_address() {
951 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.WorkerConfig.worker_address)
952
953 return worker_address_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
954}
955inline void WorkerConfig::set_allocated_worker_address(std::string* worker_address) {
956 if (worker_address != nullptr) {
957
958 } else {
959
960 }
961 worker_address_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), worker_address);
962 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.WorkerConfig.worker_address)
963}
964
965// repeated string worker_tags = 10;
966inline int WorkerConfig::worker_tags_size() const {
967 return worker_tags_.size();
968}
969inline void WorkerConfig::clear_worker_tags() {
970 worker_tags_.Clear();
971}
972inline const std::string& WorkerConfig::worker_tags(int index) const {
973 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.worker_tags)
974 return worker_tags_.Get(index);
975}
976inline std::string* WorkerConfig::mutable_worker_tags(int index) {
977 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.WorkerConfig.worker_tags)
978 return worker_tags_.Mutable(index);
979}
980inline void WorkerConfig::set_worker_tags(int index, const std::string& value) {
981 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.worker_tags)
982 worker_tags_.Mutable(index)->assign(value);
983}
984inline void WorkerConfig::set_worker_tags(int index, std::string&& value) {
985 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.worker_tags)
986 worker_tags_.Mutable(index)->assign(std::move(value));
987}
988inline void WorkerConfig::set_worker_tags(int index, const char* value) {
989 GOOGLE_DCHECK(value != nullptr);
990 worker_tags_.Mutable(index)->assign(value);
991 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.WorkerConfig.worker_tags)
992}
993inline void WorkerConfig::set_worker_tags(int index, const char* value, size_t size) {
994 worker_tags_.Mutable(index)->assign(
995 reinterpret_cast<const char*>(value), size);
996 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.WorkerConfig.worker_tags)
997}
998inline std::string* WorkerConfig::add_worker_tags() {
999 // @@protoc_insertion_point(field_add_mutable:tensorflow.data.experimental.WorkerConfig.worker_tags)
1000 return worker_tags_.Add();
1001}
1002inline void WorkerConfig::add_worker_tags(const std::string& value) {
1003 worker_tags_.Add()->assign(value);
1004 // @@protoc_insertion_point(field_add:tensorflow.data.experimental.WorkerConfig.worker_tags)
1005}
1006inline void WorkerConfig::add_worker_tags(std::string&& value) {
1007 worker_tags_.Add(std::move(value));
1008 // @@protoc_insertion_point(field_add:tensorflow.data.experimental.WorkerConfig.worker_tags)
1009}
1010inline void WorkerConfig::add_worker_tags(const char* value) {
1011 GOOGLE_DCHECK(value != nullptr);
1012 worker_tags_.Add()->assign(value);
1013 // @@protoc_insertion_point(field_add_char:tensorflow.data.experimental.WorkerConfig.worker_tags)
1014}
1015inline void WorkerConfig::add_worker_tags(const char* value, size_t size) {
1016 worker_tags_.Add()->assign(reinterpret_cast<const char*>(value), size);
1017 // @@protoc_insertion_point(field_add_pointer:tensorflow.data.experimental.WorkerConfig.worker_tags)
1018}
1019inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>&
1020WorkerConfig::worker_tags() const {
1021 // @@protoc_insertion_point(field_list:tensorflow.data.experimental.WorkerConfig.worker_tags)
1022 return worker_tags_;
1023}
1024inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField<std::string>*
1025WorkerConfig::mutable_worker_tags() {
1026 // @@protoc_insertion_point(field_mutable_list:tensorflow.data.experimental.WorkerConfig.worker_tags)
1027 return &worker_tags_;
1028}
1029
1030// int64 heartbeat_interval_ms = 5;
1031inline void WorkerConfig::clear_heartbeat_interval_ms() {
1032 heartbeat_interval_ms_ = PROTOBUF_LONGLONG(0);
1033}
1034inline ::PROTOBUF_NAMESPACE_ID::int64 WorkerConfig::heartbeat_interval_ms() const {
1035 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.heartbeat_interval_ms)
1036 return heartbeat_interval_ms_;
1037}
1038inline void WorkerConfig::set_heartbeat_interval_ms(::PROTOBUF_NAMESPACE_ID::int64 value) {
1039
1040 heartbeat_interval_ms_ = value;
1041 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.heartbeat_interval_ms)
1042}
1043
1044// int64 dispatcher_timeout_ms = 6;
1045inline void WorkerConfig::clear_dispatcher_timeout_ms() {
1046 dispatcher_timeout_ms_ = PROTOBUF_LONGLONG(0);
1047}
1048inline ::PROTOBUF_NAMESPACE_ID::int64 WorkerConfig::dispatcher_timeout_ms() const {
1049 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.dispatcher_timeout_ms)
1050 return dispatcher_timeout_ms_;
1051}
1052inline void WorkerConfig::set_dispatcher_timeout_ms(::PROTOBUF_NAMESPACE_ID::int64 value) {
1053
1054 dispatcher_timeout_ms_ = value;
1055 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.dispatcher_timeout_ms)
1056}
1057
1058// string data_transfer_protocol = 7;
1059inline void WorkerConfig::clear_data_transfer_protocol() {
1060 data_transfer_protocol_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
1061}
1062inline const std::string& WorkerConfig::data_transfer_protocol() const {
1063 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1064 return data_transfer_protocol_.GetNoArena();
1065}
1066inline void WorkerConfig::set_data_transfer_protocol(const std::string& value) {
1067
1068 data_transfer_protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
1069 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1070}
1071inline void WorkerConfig::set_data_transfer_protocol(std::string&& value) {
1072
1073 data_transfer_protocol_.SetNoArena(
1074 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
1075 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1076}
1077inline void WorkerConfig::set_data_transfer_protocol(const char* value) {
1078 GOOGLE_DCHECK(value != nullptr);
1079
1080 data_transfer_protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
1081 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1082}
1083inline void WorkerConfig::set_data_transfer_protocol(const char* value, size_t size) {
1084
1085 data_transfer_protocol_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
1086 ::std::string(reinterpret_cast<const char*>(value), size));
1087 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1088}
1089inline std::string* WorkerConfig::mutable_data_transfer_protocol() {
1090
1091 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1092 return data_transfer_protocol_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
1093}
1094inline std::string* WorkerConfig::release_data_transfer_protocol() {
1095 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1096
1097 return data_transfer_protocol_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
1098}
1099inline void WorkerConfig::set_allocated_data_transfer_protocol(std::string* data_transfer_protocol) {
1100 if (data_transfer_protocol != nullptr) {
1101
1102 } else {
1103
1104 }
1105 data_transfer_protocol_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), data_transfer_protocol);
1106 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.WorkerConfig.data_transfer_protocol)
1107}
1108
1109// string data_transfer_address = 8;
1110inline void WorkerConfig::clear_data_transfer_address() {
1111 data_transfer_address_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
1112}
1113inline const std::string& WorkerConfig::data_transfer_address() const {
1114 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1115 return data_transfer_address_.GetNoArena();
1116}
1117inline void WorkerConfig::set_data_transfer_address(const std::string& value) {
1118
1119 data_transfer_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
1120 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1121}
1122inline void WorkerConfig::set_data_transfer_address(std::string&& value) {
1123
1124 data_transfer_address_.SetNoArena(
1125 &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
1126 // @@protoc_insertion_point(field_set_rvalue:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1127}
1128inline void WorkerConfig::set_data_transfer_address(const char* value) {
1129 GOOGLE_DCHECK(value != nullptr);
1130
1131 data_transfer_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
1132 // @@protoc_insertion_point(field_set_char:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1133}
1134inline void WorkerConfig::set_data_transfer_address(const char* value, size_t size) {
1135
1136 data_transfer_address_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
1137 ::std::string(reinterpret_cast<const char*>(value), size));
1138 // @@protoc_insertion_point(field_set_pointer:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1139}
1140inline std::string* WorkerConfig::mutable_data_transfer_address() {
1141
1142 // @@protoc_insertion_point(field_mutable:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1143 return data_transfer_address_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
1144}
1145inline std::string* WorkerConfig::release_data_transfer_address() {
1146 // @@protoc_insertion_point(field_release:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1147
1148 return data_transfer_address_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
1149}
1150inline void WorkerConfig::set_allocated_data_transfer_address(std::string* data_transfer_address) {
1151 if (data_transfer_address != nullptr) {
1152
1153 } else {
1154
1155 }
1156 data_transfer_address_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), data_transfer_address);
1157 // @@protoc_insertion_point(field_set_allocated:tensorflow.data.experimental.WorkerConfig.data_transfer_address)
1158}
1159
1160// int64 cross_trainer_cache_size_bytes = 11;
1161inline void WorkerConfig::clear_cross_trainer_cache_size_bytes() {
1162 cross_trainer_cache_size_bytes_ = PROTOBUF_LONGLONG(0);
1163}
1164inline ::PROTOBUF_NAMESPACE_ID::int64 WorkerConfig::cross_trainer_cache_size_bytes() const {
1165 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.cross_trainer_cache_size_bytes)
1166 return cross_trainer_cache_size_bytes_;
1167}
1168inline void WorkerConfig::set_cross_trainer_cache_size_bytes(::PROTOBUF_NAMESPACE_ID::int64 value) {
1169
1170 cross_trainer_cache_size_bytes_ = value;
1171 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.cross_trainer_cache_size_bytes)
1172}
1173
1174// int64 shutdown_quiet_period_ms = 9;
1175inline void WorkerConfig::clear_shutdown_quiet_period_ms() {
1176 shutdown_quiet_period_ms_ = PROTOBUF_LONGLONG(0);
1177}
1178inline ::PROTOBUF_NAMESPACE_ID::int64 WorkerConfig::shutdown_quiet_period_ms() const {
1179 // @@protoc_insertion_point(field_get:tensorflow.data.experimental.WorkerConfig.shutdown_quiet_period_ms)
1180 return shutdown_quiet_period_ms_;
1181}
1182inline void WorkerConfig::set_shutdown_quiet_period_ms(::PROTOBUF_NAMESPACE_ID::int64 value) {
1183
1184 shutdown_quiet_period_ms_ = value;
1185 // @@protoc_insertion_point(field_set:tensorflow.data.experimental.WorkerConfig.shutdown_quiet_period_ms)
1186}
1187
1188#ifdef __GNUC__
1189 #pragma GCC diagnostic pop
1190#endif // __GNUC__
1191// -------------------------------------------------------------------
1192
1193
1194// @@protoc_insertion_point(namespace_scope)
1195
1196} // namespace experimental
1197} // namespace data
1198} // namespace tensorflow
1199
1200// @@protoc_insertion_point(global_scope)
1201
1202#include <google/protobuf/port_undef.inc>
1203#endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_tensorflow_2fcore_2fprotobuf_2fservice_5fconfig_2eproto
1204