From a3b66e4b0e38a476d7d902012b199d21cc230906 Mon Sep 17 00:00:00 2001 From: Charles Beauville Date: Wed, 17 Jan 2024 16:33:00 +0100 Subject: [PATCH] Recompile protos --- src/py/flwr/proto/driver_pb2.py | 109 ++++++++-- src/py/flwr/proto/fleet_pb2.py | 135 +++++++++--- src/py/flwr/proto/node_pb2.py | 21 +- src/py/flwr/proto/task_pb2.py | 147 ++++++++++--- src/py/flwr/proto/transport_pb2.py | 318 ++++++++++++++++++++++++----- 5 files changed, 596 insertions(+), 134 deletions(-) diff --git a/src/py/flwr/proto/driver_pb2.py b/src/py/flwr/proto/driver_pb2.py index 007d50b3835d..615bf4672afa 100644 --- a/src/py/flwr/proto/driver_pb2.py +++ b/src/py/flwr/proto/driver_pb2.py @@ -4,8 +4,9 @@ """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -17,28 +18,92 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x17\x66lwr/proto/driver.proto\x12\nflwr.proto\x1a\x15\x66lwr/proto/node.proto\x1a\x15\x66lwr/proto/task.proto\"\x12\n\x10\x43reateRunRequest\"#\n\x11\x43reateRunResponse\x12\x0e\n\x06run_id\x18\x01 \x01(\x12\"!\n\x0fGetNodesRequest\x12\x0e\n\x06run_id\x18\x01 \x01(\x12\"3\n\x10GetNodesResponse\x12\x1f\n\x05nodes\x18\x01 \x03(\x0b\x32\x10.flwr.proto.Node\"@\n\x12PushTaskInsRequest\x12*\n\rtask_ins_list\x18\x01 \x03(\x0b\x32\x13.flwr.proto.TaskIns\"\'\n\x13PushTaskInsResponse\x12\x10\n\x08task_ids\x18\x02 \x03(\t\"F\n\x12PullTaskResRequest\x12\x1e\n\x04node\x18\x01 \x01(\x0b\x32\x10.flwr.proto.Node\x12\x10\n\x08task_ids\x18\x02 \x03(\t\"A\n\x13PullTaskResResponse\x12*\n\rtask_res_list\x18\x01 \x03(\x0b\x32\x13.flwr.proto.TaskRes2\xc1\x02\n\x06\x44river\x12J\n\tCreateRun\x12\x1c.flwr.proto.CreateRunRequest\x1a\x1d.flwr.proto.CreateRunResponse\"\x00\x12G\n\x08GetNodes\x12\x1b.flwr.proto.GetNodesRequest\x1a\x1c.flwr.proto.GetNodesResponse\"\x00\x12P\n\x0bPushTaskIns\x12\x1e.flwr.proto.PushTaskInsRequest\x1a\x1f.flwr.proto.PushTaskInsResponse\"\x00\x12P\n\x0bPullTaskRes\x12\x1e.flwr.proto.PullTaskResRequest\x1a\x1f.flwr.proto.PullTaskResResponse\"\x00\x62\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'flwr.proto.driver_pb2', _globals) + +_CREATERUNREQUEST = DESCRIPTOR.message_types_by_name['CreateRunRequest'] +_CREATERUNRESPONSE = DESCRIPTOR.message_types_by_name['CreateRunResponse'] +_GETNODESREQUEST = DESCRIPTOR.message_types_by_name['GetNodesRequest'] +_GETNODESRESPONSE = DESCRIPTOR.message_types_by_name['GetNodesResponse'] +_PUSHTASKINSREQUEST = DESCRIPTOR.message_types_by_name['PushTaskInsRequest'] +_PUSHTASKINSRESPONSE = DESCRIPTOR.message_types_by_name['PushTaskInsResponse'] +_PULLTASKRESREQUEST = DESCRIPTOR.message_types_by_name['PullTaskResRequest'] +_PULLTASKRESRESPONSE = DESCRIPTOR.message_types_by_name['PullTaskResResponse'] +CreateRunRequest = _reflection.GeneratedProtocolMessageType('CreateRunRequest', (_message.Message,), { + 'DESCRIPTOR' : _CREATERUNREQUEST, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.CreateRunRequest) + }) +_sym_db.RegisterMessage(CreateRunRequest) + +CreateRunResponse = _reflection.GeneratedProtocolMessageType('CreateRunResponse', (_message.Message,), { + 'DESCRIPTOR' : _CREATERUNRESPONSE, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.CreateRunResponse) + }) +_sym_db.RegisterMessage(CreateRunResponse) + +GetNodesRequest = _reflection.GeneratedProtocolMessageType('GetNodesRequest', (_message.Message,), { + 'DESCRIPTOR' : _GETNODESREQUEST, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.GetNodesRequest) + }) +_sym_db.RegisterMessage(GetNodesRequest) + +GetNodesResponse = _reflection.GeneratedProtocolMessageType('GetNodesResponse', (_message.Message,), { + 'DESCRIPTOR' : _GETNODESRESPONSE, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.GetNodesResponse) + }) +_sym_db.RegisterMessage(GetNodesResponse) + +PushTaskInsRequest = _reflection.GeneratedProtocolMessageType('PushTaskInsRequest', (_message.Message,), { + 'DESCRIPTOR' : _PUSHTASKINSREQUEST, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PushTaskInsRequest) + }) +_sym_db.RegisterMessage(PushTaskInsRequest) + +PushTaskInsResponse = _reflection.GeneratedProtocolMessageType('PushTaskInsResponse', (_message.Message,), { + 'DESCRIPTOR' : _PUSHTASKINSRESPONSE, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PushTaskInsResponse) + }) +_sym_db.RegisterMessage(PushTaskInsResponse) + +PullTaskResRequest = _reflection.GeneratedProtocolMessageType('PullTaskResRequest', (_message.Message,), { + 'DESCRIPTOR' : _PULLTASKRESREQUEST, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PullTaskResRequest) + }) +_sym_db.RegisterMessage(PullTaskResRequest) + +PullTaskResResponse = _reflection.GeneratedProtocolMessageType('PullTaskResResponse', (_message.Message,), { + 'DESCRIPTOR' : _PULLTASKRESRESPONSE, + '__module__' : 'flwr.proto.driver_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PullTaskResResponse) + }) +_sym_db.RegisterMessage(PullTaskResResponse) + +_DRIVER = DESCRIPTOR.services_by_name['Driver'] if _descriptor._USE_C_DESCRIPTORS == False: + DESCRIPTOR._options = None - _globals['_CREATEWORKLOADREQUEST']._serialized_start=85 - _globals['_CREATEWORKLOADREQUEST']._serialized_end=108 - _globals['_CREATEWORKLOADRESPONSE']._serialized_start=110 - _globals['_CREATEWORKLOADRESPONSE']._serialized_end=155 - _globals['_GETNODESREQUEST']._serialized_start=157 - _globals['_GETNODESREQUEST']._serialized_end=195 - _globals['_GETNODESRESPONSE']._serialized_start=197 - _globals['_GETNODESRESPONSE']._serialized_end=248 - _globals['_PUSHTASKINSREQUEST']._serialized_start=250 - _globals['_PUSHTASKINSREQUEST']._serialized_end=314 - _globals['_PUSHTASKINSRESPONSE']._serialized_start=316 - _globals['_PUSHTASKINSRESPONSE']._serialized_end=355 - _globals['_PULLTASKRESREQUEST']._serialized_start=357 - _globals['_PULLTASKRESREQUEST']._serialized_end=427 - _globals['_PULLTASKRESRESPONSE']._serialized_start=429 - _globals['_PULLTASKRESRESPONSE']._serialized_end=494 - _globals['_DRIVER']._serialized_start=497 - _globals['_DRIVER']._serialized_end=833 + _CREATERUNREQUEST._serialized_start=85 + _CREATERUNREQUEST._serialized_end=103 + _CREATERUNRESPONSE._serialized_start=105 + _CREATERUNRESPONSE._serialized_end=140 + _GETNODESREQUEST._serialized_start=142 + _GETNODESREQUEST._serialized_end=175 + _GETNODESRESPONSE._serialized_start=177 + _GETNODESRESPONSE._serialized_end=228 + _PUSHTASKINSREQUEST._serialized_start=230 + _PUSHTASKINSREQUEST._serialized_end=294 + _PUSHTASKINSRESPONSE._serialized_start=296 + _PUSHTASKINSRESPONSE._serialized_end=335 + _PULLTASKRESREQUEST._serialized_start=337 + _PULLTASKRESREQUEST._serialized_end=407 + _PULLTASKRESRESPONSE._serialized_start=409 + _PULLTASKRESRESPONSE._serialized_end=474 + _DRIVER._serialized_start=477 + _DRIVER._serialized_end=798 # @@protoc_insertion_point(module_scope) diff --git a/src/py/flwr/proto/fleet_pb2.py b/src/py/flwr/proto/fleet_pb2.py index c51a8064a1f1..e86a53e2139e 100644 --- a/src/py/flwr/proto/fleet_pb2.py +++ b/src/py/flwr/proto/fleet_pb2.py @@ -4,8 +4,9 @@ """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -17,33 +18,115 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x16\x66lwr/proto/fleet.proto\x12\nflwr.proto\x1a\x15\x66lwr/proto/node.proto\x1a\x15\x66lwr/proto/task.proto\"\x13\n\x11\x43reateNodeRequest\"4\n\x12\x43reateNodeResponse\x12\x1e\n\x04node\x18\x01 \x01(\x0b\x32\x10.flwr.proto.Node\"3\n\x11\x44\x65leteNodeRequest\x12\x1e\n\x04node\x18\x01 \x01(\x0b\x32\x10.flwr.proto.Node\"\x14\n\x12\x44\x65leteNodeResponse\"F\n\x12PullTaskInsRequest\x12\x1e\n\x04node\x18\x01 \x01(\x0b\x32\x10.flwr.proto.Node\x12\x10\n\x08task_ids\x18\x02 \x03(\t\"k\n\x13PullTaskInsResponse\x12(\n\treconnect\x18\x01 \x01(\x0b\x32\x15.flwr.proto.Reconnect\x12*\n\rtask_ins_list\x18\x02 \x03(\x0b\x32\x13.flwr.proto.TaskIns\"@\n\x12PushTaskResRequest\x12*\n\rtask_res_list\x18\x01 \x03(\x0b\x32\x13.flwr.proto.TaskRes\"\xae\x01\n\x13PushTaskResResponse\x12(\n\treconnect\x18\x01 \x01(\x0b\x32\x15.flwr.proto.Reconnect\x12=\n\x07results\x18\x02 \x03(\x0b\x32,.flwr.proto.PushTaskResResponse.ResultsEntry\x1a.\n\x0cResultsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\r:\x02\x38\x01\"\x1e\n\tReconnect\x12\x11\n\treconnect\x18\x01 \x01(\x04\x32\xc9\x02\n\x05\x46leet\x12M\n\nCreateNode\x12\x1d.flwr.proto.CreateNodeRequest\x1a\x1e.flwr.proto.CreateNodeResponse\"\x00\x12M\n\nDeleteNode\x12\x1d.flwr.proto.DeleteNodeRequest\x1a\x1e.flwr.proto.DeleteNodeResponse\"\x00\x12P\n\x0bPullTaskIns\x12\x1e.flwr.proto.PullTaskInsRequest\x1a\x1f.flwr.proto.PullTaskInsResponse\"\x00\x12P\n\x0bPushTaskRes\x12\x1e.flwr.proto.PushTaskResRequest\x1a\x1f.flwr.proto.PushTaskResResponse\"\x00\x62\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'flwr.proto.fleet_pb2', _globals) + + +_CREATENODEREQUEST = DESCRIPTOR.message_types_by_name['CreateNodeRequest'] +_CREATENODERESPONSE = DESCRIPTOR.message_types_by_name['CreateNodeResponse'] +_DELETENODEREQUEST = DESCRIPTOR.message_types_by_name['DeleteNodeRequest'] +_DELETENODERESPONSE = DESCRIPTOR.message_types_by_name['DeleteNodeResponse'] +_PULLTASKINSREQUEST = DESCRIPTOR.message_types_by_name['PullTaskInsRequest'] +_PULLTASKINSRESPONSE = DESCRIPTOR.message_types_by_name['PullTaskInsResponse'] +_PUSHTASKRESREQUEST = DESCRIPTOR.message_types_by_name['PushTaskResRequest'] +_PUSHTASKRESRESPONSE = DESCRIPTOR.message_types_by_name['PushTaskResResponse'] +_PUSHTASKRESRESPONSE_RESULTSENTRY = _PUSHTASKRESRESPONSE.nested_types_by_name['ResultsEntry'] +_RECONNECT = DESCRIPTOR.message_types_by_name['Reconnect'] +CreateNodeRequest = _reflection.GeneratedProtocolMessageType('CreateNodeRequest', (_message.Message,), { + 'DESCRIPTOR' : _CREATENODEREQUEST, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.CreateNodeRequest) + }) +_sym_db.RegisterMessage(CreateNodeRequest) + +CreateNodeResponse = _reflection.GeneratedProtocolMessageType('CreateNodeResponse', (_message.Message,), { + 'DESCRIPTOR' : _CREATENODERESPONSE, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.CreateNodeResponse) + }) +_sym_db.RegisterMessage(CreateNodeResponse) + +DeleteNodeRequest = _reflection.GeneratedProtocolMessageType('DeleteNodeRequest', (_message.Message,), { + 'DESCRIPTOR' : _DELETENODEREQUEST, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.DeleteNodeRequest) + }) +_sym_db.RegisterMessage(DeleteNodeRequest) + +DeleteNodeResponse = _reflection.GeneratedProtocolMessageType('DeleteNodeResponse', (_message.Message,), { + 'DESCRIPTOR' : _DELETENODERESPONSE, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.DeleteNodeResponse) + }) +_sym_db.RegisterMessage(DeleteNodeResponse) + +PullTaskInsRequest = _reflection.GeneratedProtocolMessageType('PullTaskInsRequest', (_message.Message,), { + 'DESCRIPTOR' : _PULLTASKINSREQUEST, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PullTaskInsRequest) + }) +_sym_db.RegisterMessage(PullTaskInsRequest) + +PullTaskInsResponse = _reflection.GeneratedProtocolMessageType('PullTaskInsResponse', (_message.Message,), { + 'DESCRIPTOR' : _PULLTASKINSRESPONSE, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PullTaskInsResponse) + }) +_sym_db.RegisterMessage(PullTaskInsResponse) + +PushTaskResRequest = _reflection.GeneratedProtocolMessageType('PushTaskResRequest', (_message.Message,), { + 'DESCRIPTOR' : _PUSHTASKRESREQUEST, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PushTaskResRequest) + }) +_sym_db.RegisterMessage(PushTaskResRequest) + +PushTaskResResponse = _reflection.GeneratedProtocolMessageType('PushTaskResResponse', (_message.Message,), { + + 'ResultsEntry' : _reflection.GeneratedProtocolMessageType('ResultsEntry', (_message.Message,), { + 'DESCRIPTOR' : _PUSHTASKRESRESPONSE_RESULTSENTRY, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PushTaskResResponse.ResultsEntry) + }) + , + 'DESCRIPTOR' : _PUSHTASKRESRESPONSE, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.PushTaskResResponse) + }) +_sym_db.RegisterMessage(PushTaskResResponse) +_sym_db.RegisterMessage(PushTaskResResponse.ResultsEntry) + +Reconnect = _reflection.GeneratedProtocolMessageType('Reconnect', (_message.Message,), { + 'DESCRIPTOR' : _RECONNECT, + '__module__' : 'flwr.proto.fleet_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Reconnect) + }) +_sym_db.RegisterMessage(Reconnect) + +_FLEET = DESCRIPTOR.services_by_name['Fleet'] if _descriptor._USE_C_DESCRIPTORS == False: + DESCRIPTOR._options = None _PUSHTASKRESRESPONSE_RESULTSENTRY._options = None _PUSHTASKRESRESPONSE_RESULTSENTRY._serialized_options = b'8\001' - _globals['_CREATENODEREQUEST']._serialized_start=84 - _globals['_CREATENODEREQUEST']._serialized_end=103 - _globals['_CREATENODERESPONSE']._serialized_start=105 - _globals['_CREATENODERESPONSE']._serialized_end=157 - _globals['_DELETENODEREQUEST']._serialized_start=159 - _globals['_DELETENODEREQUEST']._serialized_end=210 - _globals['_DELETENODERESPONSE']._serialized_start=212 - _globals['_DELETENODERESPONSE']._serialized_end=232 - _globals['_PULLTASKINSREQUEST']._serialized_start=234 - _globals['_PULLTASKINSREQUEST']._serialized_end=304 - _globals['_PULLTASKINSRESPONSE']._serialized_start=306 - _globals['_PULLTASKINSRESPONSE']._serialized_end=413 - _globals['_PUSHTASKRESREQUEST']._serialized_start=415 - _globals['_PUSHTASKRESREQUEST']._serialized_end=479 - _globals['_PUSHTASKRESRESPONSE']._serialized_start=482 - _globals['_PUSHTASKRESRESPONSE']._serialized_end=656 - _globals['_PUSHTASKRESRESPONSE_RESULTSENTRY']._serialized_start=610 - _globals['_PUSHTASKRESRESPONSE_RESULTSENTRY']._serialized_end=656 - _globals['_RECONNECT']._serialized_start=658 - _globals['_RECONNECT']._serialized_end=688 - _globals['_FLEET']._serialized_start=691 - _globals['_FLEET']._serialized_end=1020 + _CREATENODEREQUEST._serialized_start=84 + _CREATENODEREQUEST._serialized_end=103 + _CREATENODERESPONSE._serialized_start=105 + _CREATENODERESPONSE._serialized_end=157 + _DELETENODEREQUEST._serialized_start=159 + _DELETENODEREQUEST._serialized_end=210 + _DELETENODERESPONSE._serialized_start=212 + _DELETENODERESPONSE._serialized_end=232 + _PULLTASKINSREQUEST._serialized_start=234 + _PULLTASKINSREQUEST._serialized_end=304 + _PULLTASKINSRESPONSE._serialized_start=306 + _PULLTASKINSRESPONSE._serialized_end=413 + _PUSHTASKRESREQUEST._serialized_start=415 + _PUSHTASKRESREQUEST._serialized_end=479 + _PUSHTASKRESRESPONSE._serialized_start=482 + _PUSHTASKRESRESPONSE._serialized_end=656 + _PUSHTASKRESRESPONSE_RESULTSENTRY._serialized_start=610 + _PUSHTASKRESRESPONSE_RESULTSENTRY._serialized_end=656 + _RECONNECT._serialized_start=658 + _RECONNECT._serialized_end=688 + _FLEET._serialized_start=691 + _FLEET._serialized_end=1020 # @@protoc_insertion_point(module_scope) diff --git a/src/py/flwr/proto/node_pb2.py b/src/py/flwr/proto/node_pb2.py index 8c71d8544553..9d91900d8f53 100644 --- a/src/py/flwr/proto/node_pb2.py +++ b/src/py/flwr/proto/node_pb2.py @@ -4,8 +4,9 @@ """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -15,11 +16,19 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15\x66lwr/proto/node.proto\x12\nflwr.proto\"*\n\x04Node\x12\x0f\n\x07node_id\x18\x01 \x01(\x12\x12\x11\n\tanonymous\x18\x02 \x01(\x08\x62\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'flwr.proto.node_pb2', _globals) + + +_NODE = DESCRIPTOR.message_types_by_name['Node'] +Node = _reflection.GeneratedProtocolMessageType('Node', (_message.Message,), { + 'DESCRIPTOR' : _NODE, + '__module__' : 'flwr.proto.node_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Node) + }) +_sym_db.RegisterMessage(Node) + if _descriptor._USE_C_DESCRIPTORS == False: + DESCRIPTOR._options = None - _globals['_NODE']._serialized_start=37 - _globals['_NODE']._serialized_end=79 + _NODE._serialized_start=37 + _NODE._serialized_end=79 # @@protoc_insertion_point(module_scope) diff --git a/src/py/flwr/proto/task_pb2.py b/src/py/flwr/proto/task_pb2.py index bf2db40971c0..ba0e2e3f5218 100644 --- a/src/py/flwr/proto/task_pb2.py +++ b/src/py/flwr/proto/task_pb2.py @@ -4,8 +4,9 @@ """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -17,10 +18,104 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15\x66lwr/proto/task.proto\x12\nflwr.proto\x1a\x15\x66lwr/proto/node.proto\x1a\x1a\x66lwr/proto/transport.proto\"\xbe\x02\n\x04Task\x12\"\n\x08producer\x18\x01 \x01(\x0b\x32\x10.flwr.proto.Node\x12\"\n\x08\x63onsumer\x18\x02 \x01(\x0b\x32\x10.flwr.proto.Node\x12\x12\n\ncreated_at\x18\x03 \x01(\t\x12\x14\n\x0c\x64\x65livered_at\x18\x04 \x01(\t\x12\x0b\n\x03ttl\x18\x05 \x01(\t\x12\x10\n\x08\x61ncestry\x18\x06 \x03(\t\x12)\n\x02sa\x18\x07 \x01(\x0b\x32\x1d.flwr.proto.SecureAggregation\x12<\n\x15legacy_server_message\x18\x65 \x01(\x0b\x32\x19.flwr.proto.ServerMessageB\x02\x18\x01\x12<\n\x15legacy_client_message\x18\x66 \x01(\x0b\x32\x19.flwr.proto.ClientMessageB\x02\x18\x01\"\\\n\x07TaskIns\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x10\n\x08group_id\x18\x02 \x01(\t\x12\x0e\n\x06run_id\x18\x03 \x01(\x12\x12\x1e\n\x04task\x18\x04 \x01(\x0b\x32\x10.flwr.proto.Task\"\\\n\x07TaskRes\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x10\n\x08group_id\x18\x02 \x01(\t\x12\x0e\n\x06run_id\x18\x03 \x01(\x12\x12\x1e\n\x04task\x18\x04 \x01(\x0b\x32\x10.flwr.proto.Task\"\xf3\x03\n\x05Value\x12\x10\n\x06\x64ouble\x18\x01 \x01(\x01H\x00\x12\x10\n\x06sint64\x18\x02 \x01(\x12H\x00\x12\x0e\n\x04\x62ool\x18\x03 \x01(\x08H\x00\x12\x10\n\x06string\x18\x04 \x01(\tH\x00\x12\x0f\n\x05\x62ytes\x18\x05 \x01(\x0cH\x00\x12\x33\n\x0b\x64ouble_list\x18\x15 \x01(\x0b\x32\x1c.flwr.proto.Value.DoubleListH\x00\x12\x33\n\x0bsint64_list\x18\x16 \x01(\x0b\x32\x1c.flwr.proto.Value.Sint64ListH\x00\x12/\n\tbool_list\x18\x17 \x01(\x0b\x32\x1a.flwr.proto.Value.BoolListH\x00\x12\x33\n\x0bstring_list\x18\x18 \x01(\x0b\x32\x1c.flwr.proto.Value.StringListH\x00\x12\x31\n\nbytes_list\x18\x19 \x01(\x0b\x32\x1b.flwr.proto.Value.BytesListH\x00\x1a\x1a\n\nDoubleList\x12\x0c\n\x04vals\x18\x01 \x03(\x01\x1a\x1a\n\nSint64List\x12\x0c\n\x04vals\x18\x01 \x03(\x12\x1a\x18\n\x08\x42oolList\x12\x0c\n\x04vals\x18\x01 \x03(\x08\x1a\x1a\n\nStringList\x12\x0c\n\x04vals\x18\x01 \x03(\t\x1a\x19\n\tBytesList\x12\x0c\n\x04vals\x18\x01 \x03(\x0c\x42\x07\n\x05value\"\xa0\x01\n\x11SecureAggregation\x12\x44\n\x0cnamed_values\x18\x01 \x03(\x0b\x32..flwr.proto.SecureAggregation.NamedValuesEntry\x1a\x45\n\x10NamedValuesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12 \n\x05value\x18\x02 \x01(\x0b\x32\x11.flwr.proto.Value:\x02\x38\x01\x62\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'flwr.proto.task_pb2', _globals) + + +_TASK = DESCRIPTOR.message_types_by_name['Task'] +_TASKINS = DESCRIPTOR.message_types_by_name['TaskIns'] +_TASKRES = DESCRIPTOR.message_types_by_name['TaskRes'] +_VALUE = DESCRIPTOR.message_types_by_name['Value'] +_VALUE_DOUBLELIST = _VALUE.nested_types_by_name['DoubleList'] +_VALUE_SINT64LIST = _VALUE.nested_types_by_name['Sint64List'] +_VALUE_BOOLLIST = _VALUE.nested_types_by_name['BoolList'] +_VALUE_STRINGLIST = _VALUE.nested_types_by_name['StringList'] +_VALUE_BYTESLIST = _VALUE.nested_types_by_name['BytesList'] +_SECUREAGGREGATION = DESCRIPTOR.message_types_by_name['SecureAggregation'] +_SECUREAGGREGATION_NAMEDVALUESENTRY = _SECUREAGGREGATION.nested_types_by_name['NamedValuesEntry'] +Task = _reflection.GeneratedProtocolMessageType('Task', (_message.Message,), { + 'DESCRIPTOR' : _TASK, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Task) + }) +_sym_db.RegisterMessage(Task) + +TaskIns = _reflection.GeneratedProtocolMessageType('TaskIns', (_message.Message,), { + 'DESCRIPTOR' : _TASKINS, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.TaskIns) + }) +_sym_db.RegisterMessage(TaskIns) + +TaskRes = _reflection.GeneratedProtocolMessageType('TaskRes', (_message.Message,), { + 'DESCRIPTOR' : _TASKRES, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.TaskRes) + }) +_sym_db.RegisterMessage(TaskRes) + +Value = _reflection.GeneratedProtocolMessageType('Value', (_message.Message,), { + + 'DoubleList' : _reflection.GeneratedProtocolMessageType('DoubleList', (_message.Message,), { + 'DESCRIPTOR' : _VALUE_DOUBLELIST, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Value.DoubleList) + }) + , + + 'Sint64List' : _reflection.GeneratedProtocolMessageType('Sint64List', (_message.Message,), { + 'DESCRIPTOR' : _VALUE_SINT64LIST, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Value.Sint64List) + }) + , + + 'BoolList' : _reflection.GeneratedProtocolMessageType('BoolList', (_message.Message,), { + 'DESCRIPTOR' : _VALUE_BOOLLIST, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Value.BoolList) + }) + , + + 'StringList' : _reflection.GeneratedProtocolMessageType('StringList', (_message.Message,), { + 'DESCRIPTOR' : _VALUE_STRINGLIST, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Value.StringList) + }) + , + + 'BytesList' : _reflection.GeneratedProtocolMessageType('BytesList', (_message.Message,), { + 'DESCRIPTOR' : _VALUE_BYTESLIST, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Value.BytesList) + }) + , + 'DESCRIPTOR' : _VALUE, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Value) + }) +_sym_db.RegisterMessage(Value) +_sym_db.RegisterMessage(Value.DoubleList) +_sym_db.RegisterMessage(Value.Sint64List) +_sym_db.RegisterMessage(Value.BoolList) +_sym_db.RegisterMessage(Value.StringList) +_sym_db.RegisterMessage(Value.BytesList) + +SecureAggregation = _reflection.GeneratedProtocolMessageType('SecureAggregation', (_message.Message,), { + + 'NamedValuesEntry' : _reflection.GeneratedProtocolMessageType('NamedValuesEntry', (_message.Message,), { + 'DESCRIPTOR' : _SECUREAGGREGATION_NAMEDVALUESENTRY, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.SecureAggregation.NamedValuesEntry) + }) + , + 'DESCRIPTOR' : _SECUREAGGREGATION, + '__module__' : 'flwr.proto.task_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.SecureAggregation) + }) +_sym_db.RegisterMessage(SecureAggregation) +_sym_db.RegisterMessage(SecureAggregation.NamedValuesEntry) + if _descriptor._USE_C_DESCRIPTORS == False: + DESCRIPTOR._options = None _TASK.fields_by_name['legacy_server_message']._options = None _TASK.fields_by_name['legacy_server_message']._serialized_options = b'\030\001' @@ -28,26 +123,26 @@ _TASK.fields_by_name['legacy_client_message']._serialized_options = b'\030\001' _SECUREAGGREGATION_NAMEDVALUESENTRY._options = None _SECUREAGGREGATION_NAMEDVALUESENTRY._serialized_options = b'8\001' - _globals['_TASK']._serialized_start=89 - _globals['_TASK']._serialized_end=407 - _globals['_TASKINS']._serialized_start=409 - _globals['_TASKINS']._serialized_end=506 - _globals['_TASKRES']._serialized_start=508 - _globals['_TASKRES']._serialized_end=605 - _globals['_VALUE']._serialized_start=608 - _globals['_VALUE']._serialized_end=1107 - _globals['_VALUE_DOUBLELIST']._serialized_start=963 - _globals['_VALUE_DOUBLELIST']._serialized_end=989 - _globals['_VALUE_SINT64LIST']._serialized_start=991 - _globals['_VALUE_SINT64LIST']._serialized_end=1017 - _globals['_VALUE_BOOLLIST']._serialized_start=1019 - _globals['_VALUE_BOOLLIST']._serialized_end=1043 - _globals['_VALUE_STRINGLIST']._serialized_start=1045 - _globals['_VALUE_STRINGLIST']._serialized_end=1071 - _globals['_VALUE_BYTESLIST']._serialized_start=1073 - _globals['_VALUE_BYTESLIST']._serialized_end=1098 - _globals['_SECUREAGGREGATION']._serialized_start=1110 - _globals['_SECUREAGGREGATION']._serialized_end=1270 - _globals['_SECUREAGGREGATION_NAMEDVALUESENTRY']._serialized_start=1201 - _globals['_SECUREAGGREGATION_NAMEDVALUESENTRY']._serialized_end=1270 + _TASK._serialized_start=89 + _TASK._serialized_end=407 + _TASKINS._serialized_start=409 + _TASKINS._serialized_end=501 + _TASKRES._serialized_start=503 + _TASKRES._serialized_end=595 + _VALUE._serialized_start=598 + _VALUE._serialized_end=1097 + _VALUE_DOUBLELIST._serialized_start=953 + _VALUE_DOUBLELIST._serialized_end=979 + _VALUE_SINT64LIST._serialized_start=981 + _VALUE_SINT64LIST._serialized_end=1007 + _VALUE_BOOLLIST._serialized_start=1009 + _VALUE_BOOLLIST._serialized_end=1033 + _VALUE_STRINGLIST._serialized_start=1035 + _VALUE_STRINGLIST._serialized_end=1061 + _VALUE_BYTESLIST._serialized_start=1063 + _VALUE_BYTESLIST._serialized_end=1088 + _SECUREAGGREGATION._serialized_start=1100 + _SECUREAGGREGATION._serialized_end=1260 + _SECUREAGGREGATION_NAMEDVALUESENTRY._serialized_start=1191 + _SECUREAGGREGATION_NAMEDVALUESENTRY._serialized_end=1260 # @@protoc_insertion_point(module_scope) diff --git a/src/py/flwr/proto/transport_pb2.py b/src/py/flwr/proto/transport_pb2.py index e9bcda6695a0..1e3785b0e312 100644 --- a/src/py/flwr/proto/transport_pb2.py +++ b/src/py/flwr/proto/transport_pb2.py @@ -2,10 +2,12 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: flwr/proto/transport.proto """Generated protocol buffer code.""" +from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -15,10 +17,218 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1a\x66lwr/proto/transport.proto\x12\nflwr.proto\"9\n\x06Status\x12\x1e\n\x04\x63ode\x18\x01 \x01(\x0e\x32\x10.flwr.proto.Code\x12\x0f\n\x07message\x18\x02 \x01(\t\"2\n\nParameters\x12\x0f\n\x07tensors\x18\x01 \x03(\x0c\x12\x13\n\x0btensor_type\x18\x02 \x01(\t\"\xba\x08\n\rServerMessage\x12?\n\rreconnect_ins\x18\x01 \x01(\x0b\x32&.flwr.proto.ServerMessage.ReconnectInsH\x00\x12H\n\x12get_properties_ins\x18\x02 \x01(\x0b\x32*.flwr.proto.ServerMessage.GetPropertiesInsH\x00\x12H\n\x12get_parameters_ins\x18\x03 \x01(\x0b\x32*.flwr.proto.ServerMessage.GetParametersInsH\x00\x12\x33\n\x07\x66it_ins\x18\x04 \x01(\x0b\x32 .flwr.proto.ServerMessage.FitInsH\x00\x12=\n\x0c\x65valuate_ins\x18\x05 \x01(\x0b\x32%.flwr.proto.ServerMessage.EvaluateInsH\x00\x1a\x1f\n\x0cReconnectIns\x12\x0f\n\x07seconds\x18\x01 \x01(\x03\x1a\x9d\x01\n\x10GetPropertiesIns\x12\x46\n\x06\x63onfig\x18\x01 \x03(\x0b\x32\x36.flwr.proto.ServerMessage.GetPropertiesIns.ConfigEntry\x1a\x41\n\x0b\x43onfigEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x1a\x9d\x01\n\x10GetParametersIns\x12\x46\n\x06\x63onfig\x18\x01 \x03(\x0b\x32\x36.flwr.proto.ServerMessage.GetParametersIns.ConfigEntry\x1a\x41\n\x0b\x43onfigEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x1a\xb5\x01\n\x06\x46itIns\x12*\n\nparameters\x18\x01 \x01(\x0b\x32\x16.flwr.proto.Parameters\x12<\n\x06\x63onfig\x18\x02 \x03(\x0b\x32,.flwr.proto.ServerMessage.FitIns.ConfigEntry\x1a\x41\n\x0b\x43onfigEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x1a\xbf\x01\n\x0b\x45valuateIns\x12*\n\nparameters\x18\x01 \x01(\x0b\x32\x16.flwr.proto.Parameters\x12\x41\n\x06\x63onfig\x18\x02 \x03(\x0b\x32\x31.flwr.proto.ServerMessage.EvaluateIns.ConfigEntry\x1a\x41\n\x0b\x43onfigEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x42\x05\n\x03msg\"\xa0\t\n\rClientMessage\x12\x41\n\x0e\x64isconnect_res\x18\x01 \x01(\x0b\x32\'.flwr.proto.ClientMessage.DisconnectResH\x00\x12H\n\x12get_properties_res\x18\x02 \x01(\x0b\x32*.flwr.proto.ClientMessage.GetPropertiesResH\x00\x12H\n\x12get_parameters_res\x18\x03 \x01(\x0b\x32*.flwr.proto.ClientMessage.GetParametersResH\x00\x12\x33\n\x07\x66it_res\x18\x04 \x01(\x0b\x32 .flwr.proto.ClientMessage.FitResH\x00\x12=\n\x0c\x65valuate_res\x18\x05 \x01(\x0b\x32%.flwr.proto.ClientMessage.EvaluateResH\x00\x1a\x33\n\rDisconnectRes\x12\"\n\x06reason\x18\x01 \x01(\x0e\x32\x12.flwr.proto.Reason\x1a\xcd\x01\n\x10GetPropertiesRes\x12\"\n\x06status\x18\x01 \x01(\x0b\x32\x12.flwr.proto.Status\x12N\n\nproperties\x18\x02 \x03(\x0b\x32:.flwr.proto.ClientMessage.GetPropertiesRes.PropertiesEntry\x1a\x45\n\x0fPropertiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x1a\x62\n\x10GetParametersRes\x12\"\n\x06status\x18\x01 \x01(\x0b\x32\x12.flwr.proto.Status\x12*\n\nparameters\x18\x02 \x01(\x0b\x32\x16.flwr.proto.Parameters\x1a\xf2\x01\n\x06\x46itRes\x12\"\n\x06status\x18\x01 \x01(\x0b\x32\x12.flwr.proto.Status\x12*\n\nparameters\x18\x02 \x01(\x0b\x32\x16.flwr.proto.Parameters\x12\x14\n\x0cnum_examples\x18\x03 \x01(\x03\x12>\n\x07metrics\x18\x04 \x03(\x0b\x32-.flwr.proto.ClientMessage.FitRes.MetricsEntry\x1a\x42\n\x0cMetricsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x1a\xde\x01\n\x0b\x45valuateRes\x12\"\n\x06status\x18\x01 \x01(\x0b\x32\x12.flwr.proto.Status\x12\x0c\n\x04loss\x18\x02 \x01(\x02\x12\x14\n\x0cnum_examples\x18\x03 \x01(\x03\x12\x43\n\x07metrics\x18\x04 \x03(\x0b\x32\x32.flwr.proto.ClientMessage.EvaluateRes.MetricsEntry\x1a\x42\n\x0cMetricsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12!\n\x05value\x18\x02 \x01(\x0b\x32\x12.flwr.proto.Scalar:\x02\x38\x01\x42\x05\n\x03msg\"i\n\x06Scalar\x12\x10\n\x06\x64ouble\x18\x01 \x01(\x01H\x00\x12\x10\n\x06sint64\x18\x08 \x01(\x12H\x00\x12\x0e\n\x04\x62ool\x18\r \x01(\x08H\x00\x12\x10\n\x06string\x18\x0e \x01(\tH\x00\x12\x0f\n\x05\x62ytes\x18\x0f \x01(\x0cH\x00\x42\x08\n\x06scalar*\x8d\x01\n\x04\x43ode\x12\x06\n\x02OK\x10\x00\x12\"\n\x1eGET_PROPERTIES_NOT_IMPLEMENTED\x10\x01\x12\"\n\x1eGET_PARAMETERS_NOT_IMPLEMENTED\x10\x02\x12\x17\n\x13\x46IT_NOT_IMPLEMENTED\x10\x03\x12\x1c\n\x18\x45VALUATE_NOT_IMPLEMENTED\x10\x04*[\n\x06Reason\x12\x0b\n\x07UNKNOWN\x10\x00\x12\r\n\tRECONNECT\x10\x01\x12\x16\n\x12POWER_DISCONNECTED\x10\x02\x12\x14\n\x10WIFI_UNAVAILABLE\x10\x03\x12\x07\n\x03\x41\x43K\x10\x04\x32S\n\rFlowerService\x12\x42\n\x04Join\x12\x19.flwr.proto.ClientMessage\x1a\x19.flwr.proto.ServerMessage\"\x00(\x01\x30\x01\x62\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'flwr.proto.transport_pb2', _globals) +_CODE = DESCRIPTOR.enum_types_by_name['Code'] +Code = enum_type_wrapper.EnumTypeWrapper(_CODE) +_REASON = DESCRIPTOR.enum_types_by_name['Reason'] +Reason = enum_type_wrapper.EnumTypeWrapper(_REASON) +OK = 0 +GET_PROPERTIES_NOT_IMPLEMENTED = 1 +GET_PARAMETERS_NOT_IMPLEMENTED = 2 +FIT_NOT_IMPLEMENTED = 3 +EVALUATE_NOT_IMPLEMENTED = 4 +UNKNOWN = 0 +RECONNECT = 1 +POWER_DISCONNECTED = 2 +WIFI_UNAVAILABLE = 3 +ACK = 4 + + +_STATUS = DESCRIPTOR.message_types_by_name['Status'] +_PARAMETERS = DESCRIPTOR.message_types_by_name['Parameters'] +_SERVERMESSAGE = DESCRIPTOR.message_types_by_name['ServerMessage'] +_SERVERMESSAGE_RECONNECTINS = _SERVERMESSAGE.nested_types_by_name['ReconnectIns'] +_SERVERMESSAGE_GETPROPERTIESINS = _SERVERMESSAGE.nested_types_by_name['GetPropertiesIns'] +_SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY = _SERVERMESSAGE_GETPROPERTIESINS.nested_types_by_name['ConfigEntry'] +_SERVERMESSAGE_GETPARAMETERSINS = _SERVERMESSAGE.nested_types_by_name['GetParametersIns'] +_SERVERMESSAGE_GETPARAMETERSINS_CONFIGENTRY = _SERVERMESSAGE_GETPARAMETERSINS.nested_types_by_name['ConfigEntry'] +_SERVERMESSAGE_FITINS = _SERVERMESSAGE.nested_types_by_name['FitIns'] +_SERVERMESSAGE_FITINS_CONFIGENTRY = _SERVERMESSAGE_FITINS.nested_types_by_name['ConfigEntry'] +_SERVERMESSAGE_EVALUATEINS = _SERVERMESSAGE.nested_types_by_name['EvaluateIns'] +_SERVERMESSAGE_EVALUATEINS_CONFIGENTRY = _SERVERMESSAGE_EVALUATEINS.nested_types_by_name['ConfigEntry'] +_CLIENTMESSAGE = DESCRIPTOR.message_types_by_name['ClientMessage'] +_CLIENTMESSAGE_DISCONNECTRES = _CLIENTMESSAGE.nested_types_by_name['DisconnectRes'] +_CLIENTMESSAGE_GETPROPERTIESRES = _CLIENTMESSAGE.nested_types_by_name['GetPropertiesRes'] +_CLIENTMESSAGE_GETPROPERTIESRES_PROPERTIESENTRY = _CLIENTMESSAGE_GETPROPERTIESRES.nested_types_by_name['PropertiesEntry'] +_CLIENTMESSAGE_GETPARAMETERSRES = _CLIENTMESSAGE.nested_types_by_name['GetParametersRes'] +_CLIENTMESSAGE_FITRES = _CLIENTMESSAGE.nested_types_by_name['FitRes'] +_CLIENTMESSAGE_FITRES_METRICSENTRY = _CLIENTMESSAGE_FITRES.nested_types_by_name['MetricsEntry'] +_CLIENTMESSAGE_EVALUATERES = _CLIENTMESSAGE.nested_types_by_name['EvaluateRes'] +_CLIENTMESSAGE_EVALUATERES_METRICSENTRY = _CLIENTMESSAGE_EVALUATERES.nested_types_by_name['MetricsEntry'] +_SCALAR = DESCRIPTOR.message_types_by_name['Scalar'] +Status = _reflection.GeneratedProtocolMessageType('Status', (_message.Message,), { + 'DESCRIPTOR' : _STATUS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Status) + }) +_sym_db.RegisterMessage(Status) + +Parameters = _reflection.GeneratedProtocolMessageType('Parameters', (_message.Message,), { + 'DESCRIPTOR' : _PARAMETERS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Parameters) + }) +_sym_db.RegisterMessage(Parameters) + +ServerMessage = _reflection.GeneratedProtocolMessageType('ServerMessage', (_message.Message,), { + + 'ReconnectIns' : _reflection.GeneratedProtocolMessageType('ReconnectIns', (_message.Message,), { + 'DESCRIPTOR' : _SERVERMESSAGE_RECONNECTINS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.ReconnectIns) + }) + , + + 'GetPropertiesIns' : _reflection.GeneratedProtocolMessageType('GetPropertiesIns', (_message.Message,), { + + 'ConfigEntry' : _reflection.GeneratedProtocolMessageType('ConfigEntry', (_message.Message,), { + 'DESCRIPTOR' : _SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.GetPropertiesIns.ConfigEntry) + }) + , + 'DESCRIPTOR' : _SERVERMESSAGE_GETPROPERTIESINS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.GetPropertiesIns) + }) + , + + 'GetParametersIns' : _reflection.GeneratedProtocolMessageType('GetParametersIns', (_message.Message,), { + + 'ConfigEntry' : _reflection.GeneratedProtocolMessageType('ConfigEntry', (_message.Message,), { + 'DESCRIPTOR' : _SERVERMESSAGE_GETPARAMETERSINS_CONFIGENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.GetParametersIns.ConfigEntry) + }) + , + 'DESCRIPTOR' : _SERVERMESSAGE_GETPARAMETERSINS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.GetParametersIns) + }) + , + + 'FitIns' : _reflection.GeneratedProtocolMessageType('FitIns', (_message.Message,), { + + 'ConfigEntry' : _reflection.GeneratedProtocolMessageType('ConfigEntry', (_message.Message,), { + 'DESCRIPTOR' : _SERVERMESSAGE_FITINS_CONFIGENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.FitIns.ConfigEntry) + }) + , + 'DESCRIPTOR' : _SERVERMESSAGE_FITINS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.FitIns) + }) + , + + 'EvaluateIns' : _reflection.GeneratedProtocolMessageType('EvaluateIns', (_message.Message,), { + + 'ConfigEntry' : _reflection.GeneratedProtocolMessageType('ConfigEntry', (_message.Message,), { + 'DESCRIPTOR' : _SERVERMESSAGE_EVALUATEINS_CONFIGENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.EvaluateIns.ConfigEntry) + }) + , + 'DESCRIPTOR' : _SERVERMESSAGE_EVALUATEINS, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage.EvaluateIns) + }) + , + 'DESCRIPTOR' : _SERVERMESSAGE, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ServerMessage) + }) +_sym_db.RegisterMessage(ServerMessage) +_sym_db.RegisterMessage(ServerMessage.ReconnectIns) +_sym_db.RegisterMessage(ServerMessage.GetPropertiesIns) +_sym_db.RegisterMessage(ServerMessage.GetPropertiesIns.ConfigEntry) +_sym_db.RegisterMessage(ServerMessage.GetParametersIns) +_sym_db.RegisterMessage(ServerMessage.GetParametersIns.ConfigEntry) +_sym_db.RegisterMessage(ServerMessage.FitIns) +_sym_db.RegisterMessage(ServerMessage.FitIns.ConfigEntry) +_sym_db.RegisterMessage(ServerMessage.EvaluateIns) +_sym_db.RegisterMessage(ServerMessage.EvaluateIns.ConfigEntry) + +ClientMessage = _reflection.GeneratedProtocolMessageType('ClientMessage', (_message.Message,), { + + 'DisconnectRes' : _reflection.GeneratedProtocolMessageType('DisconnectRes', (_message.Message,), { + 'DESCRIPTOR' : _CLIENTMESSAGE_DISCONNECTRES, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.DisconnectRes) + }) + , + + 'GetPropertiesRes' : _reflection.GeneratedProtocolMessageType('GetPropertiesRes', (_message.Message,), { + + 'PropertiesEntry' : _reflection.GeneratedProtocolMessageType('PropertiesEntry', (_message.Message,), { + 'DESCRIPTOR' : _CLIENTMESSAGE_GETPROPERTIESRES_PROPERTIESENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.GetPropertiesRes.PropertiesEntry) + }) + , + 'DESCRIPTOR' : _CLIENTMESSAGE_GETPROPERTIESRES, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.GetPropertiesRes) + }) + , + + 'GetParametersRes' : _reflection.GeneratedProtocolMessageType('GetParametersRes', (_message.Message,), { + 'DESCRIPTOR' : _CLIENTMESSAGE_GETPARAMETERSRES, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.GetParametersRes) + }) + , + + 'FitRes' : _reflection.GeneratedProtocolMessageType('FitRes', (_message.Message,), { + + 'MetricsEntry' : _reflection.GeneratedProtocolMessageType('MetricsEntry', (_message.Message,), { + 'DESCRIPTOR' : _CLIENTMESSAGE_FITRES_METRICSENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.FitRes.MetricsEntry) + }) + , + 'DESCRIPTOR' : _CLIENTMESSAGE_FITRES, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.FitRes) + }) + , + + 'EvaluateRes' : _reflection.GeneratedProtocolMessageType('EvaluateRes', (_message.Message,), { + + 'MetricsEntry' : _reflection.GeneratedProtocolMessageType('MetricsEntry', (_message.Message,), { + 'DESCRIPTOR' : _CLIENTMESSAGE_EVALUATERES_METRICSENTRY, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.EvaluateRes.MetricsEntry) + }) + , + 'DESCRIPTOR' : _CLIENTMESSAGE_EVALUATERES, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage.EvaluateRes) + }) + , + 'DESCRIPTOR' : _CLIENTMESSAGE, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.ClientMessage) + }) +_sym_db.RegisterMessage(ClientMessage) +_sym_db.RegisterMessage(ClientMessage.DisconnectRes) +_sym_db.RegisterMessage(ClientMessage.GetPropertiesRes) +_sym_db.RegisterMessage(ClientMessage.GetPropertiesRes.PropertiesEntry) +_sym_db.RegisterMessage(ClientMessage.GetParametersRes) +_sym_db.RegisterMessage(ClientMessage.FitRes) +_sym_db.RegisterMessage(ClientMessage.FitRes.MetricsEntry) +_sym_db.RegisterMessage(ClientMessage.EvaluateRes) +_sym_db.RegisterMessage(ClientMessage.EvaluateRes.MetricsEntry) + +Scalar = _reflection.GeneratedProtocolMessageType('Scalar', (_message.Message,), { + 'DESCRIPTOR' : _SCALAR, + '__module__' : 'flwr.proto.transport_pb2' + # @@protoc_insertion_point(class_scope:flwr.proto.Scalar) + }) +_sym_db.RegisterMessage(Scalar) + +_FLOWERSERVICE = DESCRIPTOR.services_by_name['FlowerService'] if _descriptor._USE_C_DESCRIPTORS == False: + DESCRIPTOR._options = None _SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY._options = None _SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY._serialized_options = b'8\001' @@ -34,54 +244,54 @@ _CLIENTMESSAGE_FITRES_METRICSENTRY._serialized_options = b'8\001' _CLIENTMESSAGE_EVALUATERES_METRICSENTRY._options = None _CLIENTMESSAGE_EVALUATERES_METRICSENTRY._serialized_options = b'8\001' - _globals['_CODE']._serialized_start=2533 - _globals['_CODE']._serialized_end=2674 - _globals['_REASON']._serialized_start=2676 - _globals['_REASON']._serialized_end=2767 - _globals['_STATUS']._serialized_start=42 - _globals['_STATUS']._serialized_end=99 - _globals['_PARAMETERS']._serialized_start=101 - _globals['_PARAMETERS']._serialized_end=151 - _globals['_SERVERMESSAGE']._serialized_start=154 - _globals['_SERVERMESSAGE']._serialized_end=1236 - _globals['_SERVERMESSAGE_RECONNECTINS']._serialized_start=500 - _globals['_SERVERMESSAGE_RECONNECTINS']._serialized_end=531 - _globals['_SERVERMESSAGE_GETPROPERTIESINS']._serialized_start=534 - _globals['_SERVERMESSAGE_GETPROPERTIESINS']._serialized_end=691 - _globals['_SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY']._serialized_start=626 - _globals['_SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY']._serialized_end=691 - _globals['_SERVERMESSAGE_GETPARAMETERSINS']._serialized_start=694 - _globals['_SERVERMESSAGE_GETPARAMETERSINS']._serialized_end=851 - _globals['_SERVERMESSAGE_GETPARAMETERSINS_CONFIGENTRY']._serialized_start=626 - _globals['_SERVERMESSAGE_GETPARAMETERSINS_CONFIGENTRY']._serialized_end=691 - _globals['_SERVERMESSAGE_FITINS']._serialized_start=854 - _globals['_SERVERMESSAGE_FITINS']._serialized_end=1035 - _globals['_SERVERMESSAGE_FITINS_CONFIGENTRY']._serialized_start=626 - _globals['_SERVERMESSAGE_FITINS_CONFIGENTRY']._serialized_end=691 - _globals['_SERVERMESSAGE_EVALUATEINS']._serialized_start=1038 - _globals['_SERVERMESSAGE_EVALUATEINS']._serialized_end=1229 - _globals['_SERVERMESSAGE_EVALUATEINS_CONFIGENTRY']._serialized_start=626 - _globals['_SERVERMESSAGE_EVALUATEINS_CONFIGENTRY']._serialized_end=691 - _globals['_CLIENTMESSAGE']._serialized_start=1239 - _globals['_CLIENTMESSAGE']._serialized_end=2423 - _globals['_CLIENTMESSAGE_DISCONNECTRES']._serialized_start=1587 - _globals['_CLIENTMESSAGE_DISCONNECTRES']._serialized_end=1638 - _globals['_CLIENTMESSAGE_GETPROPERTIESRES']._serialized_start=1641 - _globals['_CLIENTMESSAGE_GETPROPERTIESRES']._serialized_end=1846 - _globals['_CLIENTMESSAGE_GETPROPERTIESRES_PROPERTIESENTRY']._serialized_start=1777 - _globals['_CLIENTMESSAGE_GETPROPERTIESRES_PROPERTIESENTRY']._serialized_end=1846 - _globals['_CLIENTMESSAGE_GETPARAMETERSRES']._serialized_start=1848 - _globals['_CLIENTMESSAGE_GETPARAMETERSRES']._serialized_end=1946 - _globals['_CLIENTMESSAGE_FITRES']._serialized_start=1949 - _globals['_CLIENTMESSAGE_FITRES']._serialized_end=2191 - _globals['_CLIENTMESSAGE_FITRES_METRICSENTRY']._serialized_start=2125 - _globals['_CLIENTMESSAGE_FITRES_METRICSENTRY']._serialized_end=2191 - _globals['_CLIENTMESSAGE_EVALUATERES']._serialized_start=2194 - _globals['_CLIENTMESSAGE_EVALUATERES']._serialized_end=2416 - _globals['_CLIENTMESSAGE_EVALUATERES_METRICSENTRY']._serialized_start=2125 - _globals['_CLIENTMESSAGE_EVALUATERES_METRICSENTRY']._serialized_end=2191 - _globals['_SCALAR']._serialized_start=2425 - _globals['_SCALAR']._serialized_end=2530 - _globals['_FLOWERSERVICE']._serialized_start=2769 - _globals['_FLOWERSERVICE']._serialized_end=2852 + _CODE._serialized_start=2533 + _CODE._serialized_end=2674 + _REASON._serialized_start=2676 + _REASON._serialized_end=2767 + _STATUS._serialized_start=42 + _STATUS._serialized_end=99 + _PARAMETERS._serialized_start=101 + _PARAMETERS._serialized_end=151 + _SERVERMESSAGE._serialized_start=154 + _SERVERMESSAGE._serialized_end=1236 + _SERVERMESSAGE_RECONNECTINS._serialized_start=500 + _SERVERMESSAGE_RECONNECTINS._serialized_end=531 + _SERVERMESSAGE_GETPROPERTIESINS._serialized_start=534 + _SERVERMESSAGE_GETPROPERTIESINS._serialized_end=691 + _SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY._serialized_start=626 + _SERVERMESSAGE_GETPROPERTIESINS_CONFIGENTRY._serialized_end=691 + _SERVERMESSAGE_GETPARAMETERSINS._serialized_start=694 + _SERVERMESSAGE_GETPARAMETERSINS._serialized_end=851 + _SERVERMESSAGE_GETPARAMETERSINS_CONFIGENTRY._serialized_start=626 + _SERVERMESSAGE_GETPARAMETERSINS_CONFIGENTRY._serialized_end=691 + _SERVERMESSAGE_FITINS._serialized_start=854 + _SERVERMESSAGE_FITINS._serialized_end=1035 + _SERVERMESSAGE_FITINS_CONFIGENTRY._serialized_start=626 + _SERVERMESSAGE_FITINS_CONFIGENTRY._serialized_end=691 + _SERVERMESSAGE_EVALUATEINS._serialized_start=1038 + _SERVERMESSAGE_EVALUATEINS._serialized_end=1229 + _SERVERMESSAGE_EVALUATEINS_CONFIGENTRY._serialized_start=626 + _SERVERMESSAGE_EVALUATEINS_CONFIGENTRY._serialized_end=691 + _CLIENTMESSAGE._serialized_start=1239 + _CLIENTMESSAGE._serialized_end=2423 + _CLIENTMESSAGE_DISCONNECTRES._serialized_start=1587 + _CLIENTMESSAGE_DISCONNECTRES._serialized_end=1638 + _CLIENTMESSAGE_GETPROPERTIESRES._serialized_start=1641 + _CLIENTMESSAGE_GETPROPERTIESRES._serialized_end=1846 + _CLIENTMESSAGE_GETPROPERTIESRES_PROPERTIESENTRY._serialized_start=1777 + _CLIENTMESSAGE_GETPROPERTIESRES_PROPERTIESENTRY._serialized_end=1846 + _CLIENTMESSAGE_GETPARAMETERSRES._serialized_start=1848 + _CLIENTMESSAGE_GETPARAMETERSRES._serialized_end=1946 + _CLIENTMESSAGE_FITRES._serialized_start=1949 + _CLIENTMESSAGE_FITRES._serialized_end=2191 + _CLIENTMESSAGE_FITRES_METRICSENTRY._serialized_start=2125 + _CLIENTMESSAGE_FITRES_METRICSENTRY._serialized_end=2191 + _CLIENTMESSAGE_EVALUATERES._serialized_start=2194 + _CLIENTMESSAGE_EVALUATERES._serialized_end=2416 + _CLIENTMESSAGE_EVALUATERES_METRICSENTRY._serialized_start=2125 + _CLIENTMESSAGE_EVALUATERES_METRICSENTRY._serialized_end=2191 + _SCALAR._serialized_start=2425 + _SCALAR._serialized_end=2530 + _FLOWERSERVICE._serialized_start=2769 + _FLOWERSERVICE._serialized_end=2852 # @@protoc_insertion_point(module_scope)