1717#![ allow( trivial_casts) ]
1818#![ allow( unused_imports) ]
1919#![ allow( unused_results) ]
20- //! Generated file from `tensorflow/ tsl/protobuf/coordination_config.proto`
20+ //! Generated file from `tsl/protobuf/coordination_config.proto`
2121
2222/// Generated files are compatible only with the same version
2323/// of protobuf runtime.
@@ -230,6 +230,7 @@ pub struct CoordinationServiceConfig {
230230 pub agent_destruction_without_shutdown : bool ,
231231 pub recoverable_jobs : :: protobuf:: RepeatedField < :: std:: string:: String > ,
232232 pub allow_new_incarnation_to_reconnect : bool ,
233+ pub force_disable : bool ,
233234 // special fields
234235 pub unknown_fields : :: protobuf:: UnknownFields ,
235236 pub cached_size : :: protobuf:: CachedSize ,
@@ -437,6 +438,21 @@ impl CoordinationServiceConfig {
437438 pub fn set_allow_new_incarnation_to_reconnect ( & mut self , v : bool ) {
438439 self . allow_new_incarnation_to_reconnect = v;
439440 }
441+
442+ // bool force_disable = 12;
443+
444+
445+ pub fn get_force_disable ( & self ) -> bool {
446+ self . force_disable
447+ }
448+ pub fn clear_force_disable ( & mut self ) {
449+ self . force_disable = false ;
450+ }
451+
452+ // Param is passed by value, moved
453+ pub fn set_force_disable ( & mut self , v : bool ) {
454+ self . force_disable = v;
455+ }
440456}
441457
442458impl :: protobuf:: Message for CoordinationServiceConfig {
@@ -507,6 +523,13 @@ impl ::protobuf::Message for CoordinationServiceConfig {
507523 let tmp = is. read_bool ( ) ?;
508524 self . allow_new_incarnation_to_reconnect = tmp;
509525 } ,
526+ 12 => {
527+ if wire_type != :: protobuf:: wire_format:: WireTypeVarint {
528+ return :: std:: result:: Result :: Err ( :: protobuf:: rt:: unexpected_wire_type ( wire_type) ) ;
529+ }
530+ let tmp = is. read_bool ( ) ?;
531+ self . force_disable = tmp;
532+ } ,
510533 _ => {
511534 :: protobuf:: rt:: read_unknown_or_skip_group ( field_number, wire_type, is, self . mut_unknown_fields ( ) ) ?;
512535 } ,
@@ -550,6 +573,9 @@ impl ::protobuf::Message for CoordinationServiceConfig {
550573 if self . allow_new_incarnation_to_reconnect != false {
551574 my_size += 2 ;
552575 }
576+ if self . force_disable != false {
577+ my_size += 2 ;
578+ }
553579 my_size += :: protobuf:: rt:: unknown_fields_size ( self . get_unknown_fields ( ) ) ;
554580 self . cached_size . set ( my_size) ;
555581 my_size
@@ -588,6 +614,9 @@ impl ::protobuf::Message for CoordinationServiceConfig {
588614 if self . allow_new_incarnation_to_reconnect != false {
589615 os. write_bool ( 11 , self . allow_new_incarnation_to_reconnect ) ?;
590616 }
617+ if self . force_disable != false {
618+ os. write_bool ( 12 , self . force_disable ) ?;
619+ }
591620 os. write_unknown_fields ( self . get_unknown_fields ( ) ) ?;
592621 :: std:: result:: Result :: Ok ( ( ) )
593622 }
@@ -676,6 +705,11 @@ impl ::protobuf::Message for CoordinationServiceConfig {
676705 |m : & CoordinationServiceConfig | { & m. allow_new_incarnation_to_reconnect } ,
677706 |m : & mut CoordinationServiceConfig | { & mut m. allow_new_incarnation_to_reconnect } ,
678707 ) ) ;
708+ fields. push ( :: protobuf:: reflect:: accessor:: make_simple_field_accessor :: < _ , :: protobuf:: types:: ProtobufTypeBool > (
709+ "force_disable" ,
710+ |m : & CoordinationServiceConfig | { & m. force_disable } ,
711+ |m : & mut CoordinationServiceConfig | { & mut m. force_disable } ,
712+ ) ) ;
679713 :: protobuf:: reflect:: MessageDescriptor :: new_pb_name :: < CoordinationServiceConfig > (
680714 "CoordinationServiceConfig" ,
681715 fields,
@@ -702,6 +736,7 @@ impl ::protobuf::Clear for CoordinationServiceConfig {
702736 self . agent_destruction_without_shutdown = false ;
703737 self . recoverable_jobs . clear ( ) ;
704738 self . allow_new_incarnation_to_reconnect = false ;
739+ self . force_disable = false ;
705740 self . unknown_fields . clear ( ) ;
706741 }
707742}
@@ -719,23 +754,24 @@ impl ::protobuf::reflect::ProtobufValue for CoordinationServiceConfig {
719754}
720755
721756static file_descriptor_proto_data: & ' static [ u8 ] = b"\
722- \n 1tensorflow/tsl/protobuf/coordination_config.proto\x12 \n tensorflow\" A\
723- \n \x0e CoordinatedJob\x12 \x12 \n \x04 name\x18 \x01 \x20 \x01 (\t R\x04 name\x12 \
724- \x1b \n \t num_tasks\x18 \x02 \x20 \x01 (\x05 R\x08 numTasks\" \xec \x04 \n \x19 Coord\
725- inationServiceConfig\x12 !\n \x0c service_type\x18 \x01 \x20 \x01 (\t R\x0b servi\
726- ceType\x12 %\n \x0e service_leader\x18 \x02 \x20 \x01 (\t R\r serviceLeader\x12 .\
727- \n \x13 enable_health_check\x18 \x03 \x20 \x01 (\x08 R\x11 enableHealthCheck\x12 \
728- B\n \x1e cluster_register_timeout_in_ms\x18 \x04 \x20 \x01 (\x03 R\x1a clusterRe\
729- gisterTimeoutInMs\x12 5\n \x17 heartbeat_timeout_in_ms\x18 \x05 \x20 \x01 (\x03 \
730- R\x14 heartbeatTimeoutInMs\x12 L\n \x14 coordinated_job_list\x18 \n \x20 \x03 (\
731- \x0b 2\x1a .tensorflow.CoordinatedJobR\x12 coordinatedJobList\x12 B\n \x1e shu\
732- tdown_barrier_timeout_in_ms\x18 \x07 \x20 \x01 (\x03 R\x1a shutdownBarrierTime\
733- outInMs\x12 K\n \" agent_destruction_without_shutdown\x18 \x08 \x20 \x01 (\x08 R\
734- \x1f agentDestructionWithoutShutdown\x12 )\n \x10 recoverable_jobs\x18 \t \x20 \
735- \x03 (\t R\x0f recoverableJobs\x12 J\n \" allow_new_incarnation_to_reconnect\
736- \x18 \x0b \x20 \x01 (\x08 R\x1e allowNewIncarnationToReconnectJ\x04 \x08 \x06 \
737- \x10 \x07 BWZUgithub.com/tensorflow/tensorflow/tensorflow/go/core/protobuf\
738- /for_core_protos_go_protob\x06 proto3\
757+ \n &tsl/protobuf/coordination_config.proto\x12 \n tensorflow\" A\n \x0e Coordi\
758+ natedJob\x12 \x12 \n \x04 name\x18 \x01 \x20 \x01 (\t R\x04 name\x12 \x1b \n \t num_ta\
759+ sks\x18 \x02 \x20 \x01 (\x05 R\x08 numTasks\" \x91 \x05 \n \x19 CoordinationService\
760+ Config\x12 !\n \x0c service_type\x18 \x01 \x20 \x01 (\t R\x0b serviceType\x12 %\n \
761+ \x0e service_leader\x18 \x02 \x20 \x01 (\t R\r serviceLeader\x12 .\n \x13 enable_h\
762+ ealth_check\x18 \x03 \x20 \x01 (\x08 R\x11 enableHealthCheck\x12 B\n \x1e cluster\
763+ _register_timeout_in_ms\x18 \x04 \x20 \x01 (\x03 R\x1a clusterRegisterTimeoutI\
764+ nMs\x12 5\n \x17 heartbeat_timeout_in_ms\x18 \x05 \x20 \x01 (\x03 R\x14 heartbeat\
765+ TimeoutInMs\x12 L\n \x14 coordinated_job_list\x18 \n \x20 \x03 (\x0b 2\x1a .tenso\
766+ rflow.CoordinatedJobR\x12 coordinatedJobList\x12 B\n \x1e shutdown_barrier_t\
767+ imeout_in_ms\x18 \x07 \x20 \x01 (\x03 R\x1a shutdownBarrierTimeoutInMs\x12 K\n \
768+ \" agent_destruction_without_shutdown\x18 \x08 \x20 \x01 (\x08 R\x1f agentDestr\
769+ uctionWithoutShutdown\x12 )\n \x10 recoverable_jobs\x18 \t \x20 \x03 (\t R\x0f re\
770+ coverableJobs\x12 J\n \" allow_new_incarnation_to_reconnect\x18 \x0b \x20 \x01 \
771+ (\x08 R\x1e allowNewIncarnationToReconnect\x12 #\n \r force_disable\x18 \x0c \
772+ \x20 \x01 (\x08 R\x0c forceDisableJ\x04 \x08 \x06 \x10 \x07 BWZUgithub.com/tensor\
773+ flow/tensorflow/tensorflow/go/core/protobuf/for_core_protos_go_protob\
774+ \x06 proto3\
739775 ";
740776
741777static file_descriptor_proto_lazy: :: protobuf:: rt:: LazyV2 < :: protobuf:: descriptor:: FileDescriptorProto > = :: protobuf:: rt:: LazyV2 :: INIT ;
0 commit comments