diff --git a/python/v1/rainbow/protos/memory_pb2.py b/python/v1/rainbow/protos/memory_pb2.py index 7822ebe..cbc9eec 100644 --- a/python/v1/rainbow/protos/memory_pb2.py +++ b/python/v1/rainbow/protos/memory_pb2.py @@ -7,33 +7,36 @@ from google.protobuf import descriptor_pool as _descriptor_pool 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() - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0cmemory.proto\x12\x07service\"C\n\x0fRegisterRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0f\n\x07payload\x18\x02 \x01(\t\x12\x11\n\tsubsystem\x18\x03 \x01(\t\"2\n\x0eSatisfyRequest\x12\x0f\n\x07payload\x18\x01 \x01(\t\x12\x0f\n\x07matcher\x18\x02 \x01(\t\"\xfc\x01\n\x0fSatisfyResponse\x12\x10\n\x08\x63lusters\x18\x01 \x03(\t\x12\x33\n\x06status\x18\x02 \x01(\x0e\x32#.service.SatisfyResponse.ResultType\x12\x16\n\x0etotal_clusters\x18\x03 \x01(\x05\x12\x15\n\rtotal_matches\x18\x04 \x01(\x05\x12\x18\n\x10total_mismatches\x18\x05 \x01(\x05\"Y\n\nResultType\x12\x1b\n\x17RESULT_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13RESULT_TYPE_SUCCESS\x10\x01\x12\x15\n\x11RESULT_TYPE_ERROR\x10\x02\"\x93\x01\n\x08Response\x12,\n\x06status\x18\x01 \x01(\x0e\x32\x1c.service.Response.ResultType\"Y\n\nResultType\x12\x1b\n\x17RESULT_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13RESULT_TYPE_SUCCESS\x10\x01\x12\x15\n\x11RESULT_TYPE_ERROR\x10\x02\x32\x88\x01\n\x0bMemoryGraph\x12>\n\x07Satisfy\x12\x17.service.SatisfyRequest\x1a\x18.service.SatisfyResponse\"\x00\x12\x39\n\x08Register\x12\x18.service.RegisterRequest\x1a\x11.service.Response\"\x00\x42@Z>github.com/converged-computing/rainbow/backends/memory/serviceb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( + b'\n\x0cmemory.proto\x12\x07service"C\n\x0fRegisterRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0f\n\x07payload\x18\x02 \x01(\t\x12\x11\n\tsubsystem\x18\x03 \x01(\t"2\n\x0eSatisfyRequest\x12\x0f\n\x07payload\x18\x01 \x01(\t\x12\x0f\n\x07matcher\x18\x02 \x01(\t"\xfc\x01\n\x0fSatisfyResponse\x12\x10\n\x08\x63lusters\x18\x01 \x03(\t\x12\x33\n\x06status\x18\x02 \x01(\x0e\x32#.service.SatisfyResponse.ResultType\x12\x16\n\x0etotal_clusters\x18\x03 \x01(\x05\x12\x15\n\rtotal_matches\x18\x04 \x01(\x05\x12\x18\n\x10total_mismatches\x18\x05 \x01(\x05"Y\n\nResultType\x12\x1b\n\x17RESULT_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13RESULT_TYPE_SUCCESS\x10\x01\x12\x15\n\x11RESULT_TYPE_ERROR\x10\x02"\x93\x01\n\x08Response\x12,\n\x06status\x18\x01 \x01(\x0e\x32\x1c.service.Response.ResultType"Y\n\nResultType\x12\x1b\n\x17RESULT_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13RESULT_TYPE_SUCCESS\x10\x01\x12\x15\n\x11RESULT_TYPE_ERROR\x10\x02\x32\x88\x01\n\x0bMemoryGraph\x12>\n\x07Satisfy\x12\x17.service.SatisfyRequest\x1a\x18.service.SatisfyResponse"\x00\x12\x39\n\x08Register\x12\x18.service.RegisterRequest\x1a\x11.service.Response"\x00\x42@Z>github.com/converged-computing/rainbow/backends/memory/serviceb\x06proto3' +) _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'memory_pb2', _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "memory_pb2", _globals) if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None - _globals['DESCRIPTOR']._serialized_options = b'Z>github.com/converged-computing/rainbow/backends/memory/service' - _globals['_REGISTERREQUEST']._serialized_start=25 - _globals['_REGISTERREQUEST']._serialized_end=92 - _globals['_SATISFYREQUEST']._serialized_start=94 - _globals['_SATISFYREQUEST']._serialized_end=144 - _globals['_SATISFYRESPONSE']._serialized_start=147 - _globals['_SATISFYRESPONSE']._serialized_end=399 - _globals['_SATISFYRESPONSE_RESULTTYPE']._serialized_start=310 - _globals['_SATISFYRESPONSE_RESULTTYPE']._serialized_end=399 - _globals['_RESPONSE']._serialized_start=402 - _globals['_RESPONSE']._serialized_end=549 - _globals['_RESPONSE_RESULTTYPE']._serialized_start=310 - _globals['_RESPONSE_RESULTTYPE']._serialized_end=399 - _globals['_MEMORYGRAPH']._serialized_start=552 - _globals['_MEMORYGRAPH']._serialized_end=688 + _globals["DESCRIPTOR"]._options = None + _globals[ + "DESCRIPTOR" + ]._serialized_options = b"Z>github.com/converged-computing/rainbow/backends/memory/service" + _globals["_REGISTERREQUEST"]._serialized_start = 25 + _globals["_REGISTERREQUEST"]._serialized_end = 92 + _globals["_SATISFYREQUEST"]._serialized_start = 94 + _globals["_SATISFYREQUEST"]._serialized_end = 144 + _globals["_SATISFYRESPONSE"]._serialized_start = 147 + _globals["_SATISFYRESPONSE"]._serialized_end = 399 + _globals["_SATISFYRESPONSE_RESULTTYPE"]._serialized_start = 310 + _globals["_SATISFYRESPONSE_RESULTTYPE"]._serialized_end = 399 + _globals["_RESPONSE"]._serialized_start = 402 + _globals["_RESPONSE"]._serialized_end = 549 + _globals["_RESPONSE_RESULTTYPE"]._serialized_start = 310 + _globals["_RESPONSE_RESULTTYPE"]._serialized_end = 399 + _globals["_MEMORYGRAPH"]._serialized_start = 552 + _globals["_MEMORYGRAPH"]._serialized_end = 688 # @@protoc_insertion_point(module_scope) diff --git a/python/v1/rainbow/protos/memory_pb2_grpc.py b/python/v1/rainbow/protos/memory_pb2_grpc.py index 5c24f6f..16d6b76 100644 --- a/python/v1/rainbow/protos/memory_pb2_grpc.py +++ b/python/v1/rainbow/protos/memory_pb2_grpc.py @@ -15,15 +15,15 @@ def __init__(self, channel): channel: A grpc.Channel. """ self.Satisfy = channel.unary_unary( - '/service.MemoryGraph/Satisfy', - request_serializer=memory__pb2.SatisfyRequest.SerializeToString, - response_deserializer=memory__pb2.SatisfyResponse.FromString, - ) + "/service.MemoryGraph/Satisfy", + request_serializer=memory__pb2.SatisfyRequest.SerializeToString, + response_deserializer=memory__pb2.SatisfyResponse.FromString, + ) self.Register = channel.unary_unary( - '/service.MemoryGraph/Register', - request_serializer=memory__pb2.RegisterRequest.SerializeToString, - response_deserializer=memory__pb2.Response.FromString, - ) + "/service.MemoryGraph/Register", + request_serializer=memory__pb2.RegisterRequest.SerializeToString, + response_deserializer=memory__pb2.Response.FromString, + ) class MemoryGraphServicer(object): @@ -32,68 +32,93 @@ class MemoryGraphServicer(object): def Satisfy(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def Register(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def add_MemoryGraphServicer_to_server(servicer, server): rpc_method_handlers = { - 'Satisfy': grpc.unary_unary_rpc_method_handler( - servicer.Satisfy, - request_deserializer=memory__pb2.SatisfyRequest.FromString, - response_serializer=memory__pb2.SatisfyResponse.SerializeToString, - ), - 'Register': grpc.unary_unary_rpc_method_handler( - servicer.Register, - request_deserializer=memory__pb2.RegisterRequest.FromString, - response_serializer=memory__pb2.Response.SerializeToString, - ), + "Satisfy": grpc.unary_unary_rpc_method_handler( + servicer.Satisfy, + request_deserializer=memory__pb2.SatisfyRequest.FromString, + response_serializer=memory__pb2.SatisfyResponse.SerializeToString, + ), + "Register": grpc.unary_unary_rpc_method_handler( + servicer.Register, + request_deserializer=memory__pb2.RegisterRequest.FromString, + response_serializer=memory__pb2.Response.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( - 'service.MemoryGraph', rpc_method_handlers) + "service.MemoryGraph", rpc_method_handlers + ) server.add_generic_rpc_handlers((generic_handler,)) - # This class is part of an EXPERIMENTAL API. +# This class is part of an EXPERIMENTAL API. class MemoryGraph(object): """Missing associated documentation comment in .proto file.""" @staticmethod - def Satisfy(request, + def Satisfy( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/service.MemoryGraph/Satisfy', + "/service.MemoryGraph/Satisfy", memory__pb2.SatisfyRequest.SerializeToString, memory__pb2.SatisfyResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def Register(request, + def Register( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/service.MemoryGraph/Register', + "/service.MemoryGraph/Register", memory__pb2.RegisterRequest.SerializeToString, memory__pb2.Response.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) diff --git a/python/v1/rainbow/protos/rainbow_pb2.py b/python/v1/rainbow/protos/rainbow_pb2.py index b672702..40eb124 100644 --- a/python/v1/rainbow/protos/rainbow_pb2.py +++ b/python/v1/rainbow/protos/rainbow_pb2.py @@ -7,6 +7,7 @@ from google.protobuf import descriptor_pool as _descriptor_pool 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() @@ -14,61 +15,64 @@ from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2 - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rrainbow.proto\x12\x1e\x63onvergedcomputing.org.grpc.v1\x1a\x1fgoogle/protobuf/timestamp.proto\"{\n\x0fRegisterRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\r\n\x05nodes\x18\x03 \x01(\t\x12\x11\n\tsubsystem\x18\x04 \x01(\t\x12(\n\x04sent\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"?\n\rDeleteRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x10\n\x08subsytem\x18\x03 \x01(\t\"\xb8\x01\n\x0e\x44\x65leteResponse\x12I\n\x06status\x18\x01 \x01(\x0e\x32\x39.convergedcomputing.org.grpc.v1.DeleteResponse.ResultType\"[\n\nResultType\x12\x12\n\x0e\x44\x45LETE_SUCCESS\x10\x00\x12\x10\n\x0c\x44\x45LETE_ERROR\x10\x01\x12\x11\n\rDELETE_DENIED\x10\x02\x12\x14\n\x10\x44\x45LETE_NO_EXISTS\x10\x03\"F\n\x12UpdateStateRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x0f\n\x07payload\x18\x03 \x01(\t\"\xdd\x01\n\x13UpdateStateResponse\x12N\n\x06status\x18\x01 \x01(\x0e\x32>.convergedcomputing.org.grpc.v1.UpdateStateResponse.ResultType\"v\n\nResultType\x12\x1c\n\x18UPDATE_STATE_UNSPECIFIED\x10\x00\x12\x18\n\x14UPDATE_STATE_PARTIAL\x10\x01\x12\x18\n\x14UPDATE_STATE_SUCCESS\x10\x02\x12\x16\n\x12UPDATE_STATE_ERROR\x10\x03\"\x92\x03\n\x10SubmitJobRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12J\n\x08\x63lusters\x18\x02 \x03(\x0b\x32\x38.convergedcomputing.org.grpc.v1.SubmitJobRequest.Cluster\x12\x0f\n\x07jobspec\x18\x03 \x01(\t\x12\x18\n\x10select_algorithm\x18\x04 \x01(\t\x12[\n\x0eselect_options\x18\x05 \x03(\x0b\x32\x43.convergedcomputing.org.grpc.v1.SubmitJobRequest.SelectOptionsEntry\x12\x14\n\x0csatisfy_only\x18\x06 \x01(\x08\x12(\n\x04sent\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a\x34\n\x12SelectOptionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a&\n\x07\x43luster\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t\"p\n\x12ReceiveJobsRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x0f\n\x07maxJobs\x18\x03 \x01(\x05\x12(\n\x04sent\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"n\n\x11\x41\x63\x63\x65ptJobsRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x0e\n\x06jobids\x18\x03 \x03(\x05\x12(\n\x04sent\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\x8e\x02\n\x10RegisterResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t\x12\x0e\n\x06secret\x18\x03 \x01(\t\x12K\n\x06status\x18\x04 \x01(\x0e\x32;.convergedcomputing.org.grpc.v1.RegisterResponse.ResultType\"z\n\nResultType\x12\x18\n\x14REGISTER_UNSPECIFIED\x10\x00\x12\x14\n\x10REGISTER_SUCCESS\x10\x01\x12\x12\n\x0eREGISTER_ERROR\x10\x02\x12\x13\n\x0fREGISTER_DENIED\x10\x03\x12\x13\n\x0fREGISTER_EXISTS\x10\x04\"\x86\x02\n\x11SubmitJobResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\r\n\x05jobid\x18\x02 \x01(\x05\x12\x0f\n\x07\x63luster\x18\x03 \x01(\t\x12L\n\x06status\x18\x04 \x01(\x0e\x32<.convergedcomputing.org.grpc.v1.SubmitJobResponse.ResultType\x12\x10\n\x08\x63lusters\x18\x05 \x03(\t\"]\n\nResultType\x12\x16\n\x12SUBMIT_UNSPECIFIED\x10\x00\x12\x12\n\x0eSUBMIT_SUCCESS\x10\x01\x12\x10\n\x0cSUBMIT_ERROR\x10\x02\x12\x11\n\rSUBMIT_DENIED\x10\x03\"\xe8\x02\n\x13ReceiveJobsResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12K\n\x04jobs\x18\x02 \x03(\x0b\x32=.convergedcomputing.org.grpc.v1.ReceiveJobsResponse.JobsEntry\x12N\n\x06status\x18\x03 \x01(\x0e\x32>.convergedcomputing.org.grpc.v1.ReceiveJobsResponse.ResultType\x1a+\n\tJobsEntry\x12\x0b\n\x03key\x18\x01 \x01(\x05\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"s\n\nResultType\x12\x1a\n\x16REQUEST_JOBS_NORESULTS\x10\x00\x12\x18\n\x14REQUEST_JOBS_SUCCESS\x10\x01\x12\x16\n\x12REQUEST_JOBS_ERROR\x10\x02\x12\x17\n\x13REQUEST_JOBS_DENIED\x10\x03\"\xd7\x01\n\x12\x41\x63\x63\x65ptJobsResponse\x12M\n\x06status\x18\x01 \x01(\x0e\x32=.convergedcomputing.org.grpc.v1.AcceptJobsResponse.ResultType\"r\n\nResultType\x12\x1b\n\x17RESULT_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13RESULT_TYPE_PARTIAL\x10\x01\x12\x17\n\x13RESULT_TYPE_SUCCESS\x10\x02\x12\x15\n\x11RESULT_TYPE_ERROR\x10\x03\x32\xb1\x07\n\x10RainbowScheduler\x12m\n\x08Register\x12/.convergedcomputing.org.grpc.v1.RegisterRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12k\n\x06\x44\x65lete\x12/.convergedcomputing.org.grpc.v1.RegisterRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12v\n\x11RegisterSubsystem\x12/.convergedcomputing.org.grpc.v1.RegisterRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12r\n\x0f\x44\x65leteSubsystem\x12-.convergedcomputing.org.grpc.v1.DeleteRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12p\n\tSubmitJob\x12\x30.convergedcomputing.org.grpc.v1.SubmitJobRequest\x1a\x31.convergedcomputing.org.grpc.v1.SubmitJobResponse\x12v\n\x0bUpdateState\x12\x32.convergedcomputing.org.grpc.v1.UpdateStateRequest\x1a\x33.convergedcomputing.org.grpc.v1.UpdateStateResponse\x12v\n\x0bReceiveJobs\x12\x32.convergedcomputing.org.grpc.v1.ReceiveJobsRequest\x1a\x33.convergedcomputing.org.grpc.v1.ReceiveJobsResponse\x12s\n\nAcceptJobs\x12\x31.convergedcomputing.org.grpc.v1.AcceptJobsRequest\x1a\x32.convergedcomputing.org.grpc.v1.AcceptJobsResponseB3Z1github.com/converged-computing/rainbow/pkg/api/v1b\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( + b'\n\rrainbow.proto\x12\x1e\x63onvergedcomputing.org.grpc.v1\x1a\x1fgoogle/protobuf/timestamp.proto"{\n\x0fRegisterRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\r\n\x05nodes\x18\x03 \x01(\t\x12\x11\n\tsubsystem\x18\x04 \x01(\t\x12(\n\x04sent\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"?\n\rDeleteRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x10\n\x08subsytem\x18\x03 \x01(\t"\xb8\x01\n\x0e\x44\x65leteResponse\x12I\n\x06status\x18\x01 \x01(\x0e\x32\x39.convergedcomputing.org.grpc.v1.DeleteResponse.ResultType"[\n\nResultType\x12\x12\n\x0e\x44\x45LETE_SUCCESS\x10\x00\x12\x10\n\x0c\x44\x45LETE_ERROR\x10\x01\x12\x11\n\rDELETE_DENIED\x10\x02\x12\x14\n\x10\x44\x45LETE_NO_EXISTS\x10\x03"F\n\x12UpdateStateRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x0f\n\x07payload\x18\x03 \x01(\t"\xdd\x01\n\x13UpdateStateResponse\x12N\n\x06status\x18\x01 \x01(\x0e\x32>.convergedcomputing.org.grpc.v1.UpdateStateResponse.ResultType"v\n\nResultType\x12\x1c\n\x18UPDATE_STATE_UNSPECIFIED\x10\x00\x12\x18\n\x14UPDATE_STATE_PARTIAL\x10\x01\x12\x18\n\x14UPDATE_STATE_SUCCESS\x10\x02\x12\x16\n\x12UPDATE_STATE_ERROR\x10\x03"\x92\x03\n\x10SubmitJobRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12J\n\x08\x63lusters\x18\x02 \x03(\x0b\x32\x38.convergedcomputing.org.grpc.v1.SubmitJobRequest.Cluster\x12\x0f\n\x07jobspec\x18\x03 \x01(\t\x12\x18\n\x10select_algorithm\x18\x04 \x01(\t\x12[\n\x0eselect_options\x18\x05 \x03(\x0b\x32\x43.convergedcomputing.org.grpc.v1.SubmitJobRequest.SelectOptionsEntry\x12\x14\n\x0csatisfy_only\x18\x06 \x01(\x08\x12(\n\x04sent\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a\x34\n\x12SelectOptionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a&\n\x07\x43luster\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t"p\n\x12ReceiveJobsRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x0f\n\x07maxJobs\x18\x03 \x01(\x05\x12(\n\x04sent\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"n\n\x11\x41\x63\x63\x65ptJobsRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06secret\x18\x02 \x01(\t\x12\x0e\n\x06jobids\x18\x03 \x03(\x05\x12(\n\x04sent\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp"\x8e\x02\n\x10RegisterResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t\x12\x0e\n\x06secret\x18\x03 \x01(\t\x12K\n\x06status\x18\x04 \x01(\x0e\x32;.convergedcomputing.org.grpc.v1.RegisterResponse.ResultType"z\n\nResultType\x12\x18\n\x14REGISTER_UNSPECIFIED\x10\x00\x12\x14\n\x10REGISTER_SUCCESS\x10\x01\x12\x12\n\x0eREGISTER_ERROR\x10\x02\x12\x13\n\x0fREGISTER_DENIED\x10\x03\x12\x13\n\x0fREGISTER_EXISTS\x10\x04"\x86\x02\n\x11SubmitJobResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12\r\n\x05jobid\x18\x02 \x01(\x05\x12\x0f\n\x07\x63luster\x18\x03 \x01(\t\x12L\n\x06status\x18\x04 \x01(\x0e\x32<.convergedcomputing.org.grpc.v1.SubmitJobResponse.ResultType\x12\x10\n\x08\x63lusters\x18\x05 \x03(\t"]\n\nResultType\x12\x16\n\x12SUBMIT_UNSPECIFIED\x10\x00\x12\x12\n\x0eSUBMIT_SUCCESS\x10\x01\x12\x10\n\x0cSUBMIT_ERROR\x10\x02\x12\x11\n\rSUBMIT_DENIED\x10\x03"\xe8\x02\n\x13ReceiveJobsResponse\x12\x12\n\nrequest_id\x18\x01 \x01(\t\x12K\n\x04jobs\x18\x02 \x03(\x0b\x32=.convergedcomputing.org.grpc.v1.ReceiveJobsResponse.JobsEntry\x12N\n\x06status\x18\x03 \x01(\x0e\x32>.convergedcomputing.org.grpc.v1.ReceiveJobsResponse.ResultType\x1a+\n\tJobsEntry\x12\x0b\n\x03key\x18\x01 \x01(\x05\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01"s\n\nResultType\x12\x1a\n\x16REQUEST_JOBS_NORESULTS\x10\x00\x12\x18\n\x14REQUEST_JOBS_SUCCESS\x10\x01\x12\x16\n\x12REQUEST_JOBS_ERROR\x10\x02\x12\x17\n\x13REQUEST_JOBS_DENIED\x10\x03"\xd7\x01\n\x12\x41\x63\x63\x65ptJobsResponse\x12M\n\x06status\x18\x01 \x01(\x0e\x32=.convergedcomputing.org.grpc.v1.AcceptJobsResponse.ResultType"r\n\nResultType\x12\x1b\n\x17RESULT_TYPE_UNSPECIFIED\x10\x00\x12\x17\n\x13RESULT_TYPE_PARTIAL\x10\x01\x12\x17\n\x13RESULT_TYPE_SUCCESS\x10\x02\x12\x15\n\x11RESULT_TYPE_ERROR\x10\x03\x32\xb1\x07\n\x10RainbowScheduler\x12m\n\x08Register\x12/.convergedcomputing.org.grpc.v1.RegisterRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12k\n\x06\x44\x65lete\x12/.convergedcomputing.org.grpc.v1.RegisterRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12v\n\x11RegisterSubsystem\x12/.convergedcomputing.org.grpc.v1.RegisterRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12r\n\x0f\x44\x65leteSubsystem\x12-.convergedcomputing.org.grpc.v1.DeleteRequest\x1a\x30.convergedcomputing.org.grpc.v1.RegisterResponse\x12p\n\tSubmitJob\x12\x30.convergedcomputing.org.grpc.v1.SubmitJobRequest\x1a\x31.convergedcomputing.org.grpc.v1.SubmitJobResponse\x12v\n\x0bUpdateState\x12\x32.convergedcomputing.org.grpc.v1.UpdateStateRequest\x1a\x33.convergedcomputing.org.grpc.v1.UpdateStateResponse\x12v\n\x0bReceiveJobs\x12\x32.convergedcomputing.org.grpc.v1.ReceiveJobsRequest\x1a\x33.convergedcomputing.org.grpc.v1.ReceiveJobsResponse\x12s\n\nAcceptJobs\x12\x31.convergedcomputing.org.grpc.v1.AcceptJobsRequest\x1a\x32.convergedcomputing.org.grpc.v1.AcceptJobsResponseB3Z1github.com/converged-computing/rainbow/pkg/api/v1b\x06proto3' +) _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'rainbow_pb2', _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "rainbow_pb2", _globals) if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None - _globals['DESCRIPTOR']._serialized_options = b'Z1github.com/converged-computing/rainbow/pkg/api/v1' - _globals['_SUBMITJOBREQUEST_SELECTOPTIONSENTRY']._options = None - _globals['_SUBMITJOBREQUEST_SELECTOPTIONSENTRY']._serialized_options = b'8\001' - _globals['_RECEIVEJOBSRESPONSE_JOBSENTRY']._options = None - _globals['_RECEIVEJOBSRESPONSE_JOBSENTRY']._serialized_options = b'8\001' - _globals['_REGISTERREQUEST']._serialized_start=82 - _globals['_REGISTERREQUEST']._serialized_end=205 - _globals['_DELETEREQUEST']._serialized_start=207 - _globals['_DELETEREQUEST']._serialized_end=270 - _globals['_DELETERESPONSE']._serialized_start=273 - _globals['_DELETERESPONSE']._serialized_end=457 - _globals['_DELETERESPONSE_RESULTTYPE']._serialized_start=366 - _globals['_DELETERESPONSE_RESULTTYPE']._serialized_end=457 - _globals['_UPDATESTATEREQUEST']._serialized_start=459 - _globals['_UPDATESTATEREQUEST']._serialized_end=529 - _globals['_UPDATESTATERESPONSE']._serialized_start=532 - _globals['_UPDATESTATERESPONSE']._serialized_end=753 - _globals['_UPDATESTATERESPONSE_RESULTTYPE']._serialized_start=635 - _globals['_UPDATESTATERESPONSE_RESULTTYPE']._serialized_end=753 - _globals['_SUBMITJOBREQUEST']._serialized_start=756 - _globals['_SUBMITJOBREQUEST']._serialized_end=1158 - _globals['_SUBMITJOBREQUEST_SELECTOPTIONSENTRY']._serialized_start=1066 - _globals['_SUBMITJOBREQUEST_SELECTOPTIONSENTRY']._serialized_end=1118 - _globals['_SUBMITJOBREQUEST_CLUSTER']._serialized_start=1120 - _globals['_SUBMITJOBREQUEST_CLUSTER']._serialized_end=1158 - _globals['_RECEIVEJOBSREQUEST']._serialized_start=1160 - _globals['_RECEIVEJOBSREQUEST']._serialized_end=1272 - _globals['_ACCEPTJOBSREQUEST']._serialized_start=1274 - _globals['_ACCEPTJOBSREQUEST']._serialized_end=1384 - _globals['_REGISTERRESPONSE']._serialized_start=1387 - _globals['_REGISTERRESPONSE']._serialized_end=1657 - _globals['_REGISTERRESPONSE_RESULTTYPE']._serialized_start=1535 - _globals['_REGISTERRESPONSE_RESULTTYPE']._serialized_end=1657 - _globals['_SUBMITJOBRESPONSE']._serialized_start=1660 - _globals['_SUBMITJOBRESPONSE']._serialized_end=1922 - _globals['_SUBMITJOBRESPONSE_RESULTTYPE']._serialized_start=1829 - _globals['_SUBMITJOBRESPONSE_RESULTTYPE']._serialized_end=1922 - _globals['_RECEIVEJOBSRESPONSE']._serialized_start=1925 - _globals['_RECEIVEJOBSRESPONSE']._serialized_end=2285 - _globals['_RECEIVEJOBSRESPONSE_JOBSENTRY']._serialized_start=2125 - _globals['_RECEIVEJOBSRESPONSE_JOBSENTRY']._serialized_end=2168 - _globals['_RECEIVEJOBSRESPONSE_RESULTTYPE']._serialized_start=2170 - _globals['_RECEIVEJOBSRESPONSE_RESULTTYPE']._serialized_end=2285 - _globals['_ACCEPTJOBSRESPONSE']._serialized_start=2288 - _globals['_ACCEPTJOBSRESPONSE']._serialized_end=2503 - _globals['_ACCEPTJOBSRESPONSE_RESULTTYPE']._serialized_start=2389 - _globals['_ACCEPTJOBSRESPONSE_RESULTTYPE']._serialized_end=2503 - _globals['_RAINBOWSCHEDULER']._serialized_start=2506 - _globals['_RAINBOWSCHEDULER']._serialized_end=3451 + _globals["DESCRIPTOR"]._options = None + _globals[ + "DESCRIPTOR" + ]._serialized_options = b"Z1github.com/converged-computing/rainbow/pkg/api/v1" + _globals["_SUBMITJOBREQUEST_SELECTOPTIONSENTRY"]._options = None + _globals["_SUBMITJOBREQUEST_SELECTOPTIONSENTRY"]._serialized_options = b"8\001" + _globals["_RECEIVEJOBSRESPONSE_JOBSENTRY"]._options = None + _globals["_RECEIVEJOBSRESPONSE_JOBSENTRY"]._serialized_options = b"8\001" + _globals["_REGISTERREQUEST"]._serialized_start = 82 + _globals["_REGISTERREQUEST"]._serialized_end = 205 + _globals["_DELETEREQUEST"]._serialized_start = 207 + _globals["_DELETEREQUEST"]._serialized_end = 270 + _globals["_DELETERESPONSE"]._serialized_start = 273 + _globals["_DELETERESPONSE"]._serialized_end = 457 + _globals["_DELETERESPONSE_RESULTTYPE"]._serialized_start = 366 + _globals["_DELETERESPONSE_RESULTTYPE"]._serialized_end = 457 + _globals["_UPDATESTATEREQUEST"]._serialized_start = 459 + _globals["_UPDATESTATEREQUEST"]._serialized_end = 529 + _globals["_UPDATESTATERESPONSE"]._serialized_start = 532 + _globals["_UPDATESTATERESPONSE"]._serialized_end = 753 + _globals["_UPDATESTATERESPONSE_RESULTTYPE"]._serialized_start = 635 + _globals["_UPDATESTATERESPONSE_RESULTTYPE"]._serialized_end = 753 + _globals["_SUBMITJOBREQUEST"]._serialized_start = 756 + _globals["_SUBMITJOBREQUEST"]._serialized_end = 1158 + _globals["_SUBMITJOBREQUEST_SELECTOPTIONSENTRY"]._serialized_start = 1066 + _globals["_SUBMITJOBREQUEST_SELECTOPTIONSENTRY"]._serialized_end = 1118 + _globals["_SUBMITJOBREQUEST_CLUSTER"]._serialized_start = 1120 + _globals["_SUBMITJOBREQUEST_CLUSTER"]._serialized_end = 1158 + _globals["_RECEIVEJOBSREQUEST"]._serialized_start = 1160 + _globals["_RECEIVEJOBSREQUEST"]._serialized_end = 1272 + _globals["_ACCEPTJOBSREQUEST"]._serialized_start = 1274 + _globals["_ACCEPTJOBSREQUEST"]._serialized_end = 1384 + _globals["_REGISTERRESPONSE"]._serialized_start = 1387 + _globals["_REGISTERRESPONSE"]._serialized_end = 1657 + _globals["_REGISTERRESPONSE_RESULTTYPE"]._serialized_start = 1535 + _globals["_REGISTERRESPONSE_RESULTTYPE"]._serialized_end = 1657 + _globals["_SUBMITJOBRESPONSE"]._serialized_start = 1660 + _globals["_SUBMITJOBRESPONSE"]._serialized_end = 1922 + _globals["_SUBMITJOBRESPONSE_RESULTTYPE"]._serialized_start = 1829 + _globals["_SUBMITJOBRESPONSE_RESULTTYPE"]._serialized_end = 1922 + _globals["_RECEIVEJOBSRESPONSE"]._serialized_start = 1925 + _globals["_RECEIVEJOBSRESPONSE"]._serialized_end = 2285 + _globals["_RECEIVEJOBSRESPONSE_JOBSENTRY"]._serialized_start = 2125 + _globals["_RECEIVEJOBSRESPONSE_JOBSENTRY"]._serialized_end = 2168 + _globals["_RECEIVEJOBSRESPONSE_RESULTTYPE"]._serialized_start = 2170 + _globals["_RECEIVEJOBSRESPONSE_RESULTTYPE"]._serialized_end = 2285 + _globals["_ACCEPTJOBSRESPONSE"]._serialized_start = 2288 + _globals["_ACCEPTJOBSRESPONSE"]._serialized_end = 2503 + _globals["_ACCEPTJOBSRESPONSE_RESULTTYPE"]._serialized_start = 2389 + _globals["_ACCEPTJOBSRESPONSE_RESULTTYPE"]._serialized_end = 2503 + _globals["_RAINBOWSCHEDULER"]._serialized_start = 2506 + _globals["_RAINBOWSCHEDULER"]._serialized_end = 3451 # @@protoc_insertion_point(module_scope) diff --git a/python/v1/rainbow/protos/rainbow_pb2_grpc.py b/python/v1/rainbow/protos/rainbow_pb2_grpc.py index bdee06b..1b8fb49 100644 --- a/python/v1/rainbow/protos/rainbow_pb2_grpc.py +++ b/python/v1/rainbow/protos/rainbow_pb2_grpc.py @@ -6,8 +6,7 @@ class RainbowSchedulerStub(object): - """RainbowSchedulerService provides API endpoints for interacting with the central scheduler service - """ + """RainbowSchedulerService provides API endpoints for interacting with the central scheduler service""" def __init__(self, channel): """Constructor. @@ -16,294 +15,382 @@ def __init__(self, channel): channel: A grpc.Channel. """ self.Register = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/Register', - request_serializer=rainbow__pb2.RegisterRequest.SerializeToString, - response_deserializer=rainbow__pb2.RegisterResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/Register", + request_serializer=rainbow__pb2.RegisterRequest.SerializeToString, + response_deserializer=rainbow__pb2.RegisterResponse.FromString, + ) self.Delete = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/Delete', - request_serializer=rainbow__pb2.RegisterRequest.SerializeToString, - response_deserializer=rainbow__pb2.RegisterResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/Delete", + request_serializer=rainbow__pb2.RegisterRequest.SerializeToString, + response_deserializer=rainbow__pb2.RegisterResponse.FromString, + ) self.RegisterSubsystem = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/RegisterSubsystem', - request_serializer=rainbow__pb2.RegisterRequest.SerializeToString, - response_deserializer=rainbow__pb2.RegisterResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/RegisterSubsystem", + request_serializer=rainbow__pb2.RegisterRequest.SerializeToString, + response_deserializer=rainbow__pb2.RegisterResponse.FromString, + ) self.DeleteSubsystem = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/DeleteSubsystem', - request_serializer=rainbow__pb2.DeleteRequest.SerializeToString, - response_deserializer=rainbow__pb2.RegisterResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/DeleteSubsystem", + request_serializer=rainbow__pb2.DeleteRequest.SerializeToString, + response_deserializer=rainbow__pb2.RegisterResponse.FromString, + ) self.SubmitJob = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/SubmitJob', - request_serializer=rainbow__pb2.SubmitJobRequest.SerializeToString, - response_deserializer=rainbow__pb2.SubmitJobResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/SubmitJob", + request_serializer=rainbow__pb2.SubmitJobRequest.SerializeToString, + response_deserializer=rainbow__pb2.SubmitJobResponse.FromString, + ) self.UpdateState = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/UpdateState', - request_serializer=rainbow__pb2.UpdateStateRequest.SerializeToString, - response_deserializer=rainbow__pb2.UpdateStateResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/UpdateState", + request_serializer=rainbow__pb2.UpdateStateRequest.SerializeToString, + response_deserializer=rainbow__pb2.UpdateStateResponse.FromString, + ) self.ReceiveJobs = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/ReceiveJobs', - request_serializer=rainbow__pb2.ReceiveJobsRequest.SerializeToString, - response_deserializer=rainbow__pb2.ReceiveJobsResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/ReceiveJobs", + request_serializer=rainbow__pb2.ReceiveJobsRequest.SerializeToString, + response_deserializer=rainbow__pb2.ReceiveJobsResponse.FromString, + ) self.AcceptJobs = channel.unary_unary( - '/convergedcomputing.org.grpc.v1.RainbowScheduler/AcceptJobs', - request_serializer=rainbow__pb2.AcceptJobsRequest.SerializeToString, - response_deserializer=rainbow__pb2.AcceptJobsResponse.FromString, - ) + "/convergedcomputing.org.grpc.v1.RainbowScheduler/AcceptJobs", + request_serializer=rainbow__pb2.AcceptJobsRequest.SerializeToString, + response_deserializer=rainbow__pb2.AcceptJobsResponse.FromString, + ) class RainbowSchedulerServicer(object): - """RainbowSchedulerService provides API endpoints for interacting with the central scheduler service - """ + """RainbowSchedulerService provides API endpoints for interacting with the central scheduler service""" def Register(self, request, context): - """Register cluster - request to register a new cluster - """ + """Register cluster - request to register a new cluster""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def Delete(self, request, context): - """Delete cluster - request to delete a cluster - """ + """Delete cluster - request to delete a cluster""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def RegisterSubsystem(self, request, context): - """Register subsystem - request to register a new cluster - """ + """Register subsystem - request to register a new cluster""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def DeleteSubsystem(self, request, context): - """Delete Subsystems - request to delete subsystems - """ + """Delete Subsystems - request to delete subsystems""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def SubmitJob(self, request, context): - """Job Submission - request for submitting a job to a named cluster - """ + """Job Submission - request for submitting a job to a named cluster""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def UpdateState(self, request, context): """Update State - allow a cluster to provide state metadata This is intended for use by a selection algorithm """ context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def ReceiveJobs(self, request, context): - """Request Job - ask the rainbow scheduler for up to max jobs - """ + """Request Job - ask the rainbow scheduler for up to max jobs""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def AcceptJobs(self, request, context): - """Accept Jobs - accept some number of jobs - """ + """Accept Jobs - accept some number of jobs""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def add_RainbowSchedulerServicer_to_server(servicer, server): rpc_method_handlers = { - 'Register': grpc.unary_unary_rpc_method_handler( - servicer.Register, - request_deserializer=rainbow__pb2.RegisterRequest.FromString, - response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, - ), - 'Delete': grpc.unary_unary_rpc_method_handler( - servicer.Delete, - request_deserializer=rainbow__pb2.RegisterRequest.FromString, - response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, - ), - 'RegisterSubsystem': grpc.unary_unary_rpc_method_handler( - servicer.RegisterSubsystem, - request_deserializer=rainbow__pb2.RegisterRequest.FromString, - response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, - ), - 'DeleteSubsystem': grpc.unary_unary_rpc_method_handler( - servicer.DeleteSubsystem, - request_deserializer=rainbow__pb2.DeleteRequest.FromString, - response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, - ), - 'SubmitJob': grpc.unary_unary_rpc_method_handler( - servicer.SubmitJob, - request_deserializer=rainbow__pb2.SubmitJobRequest.FromString, - response_serializer=rainbow__pb2.SubmitJobResponse.SerializeToString, - ), - 'UpdateState': grpc.unary_unary_rpc_method_handler( - servicer.UpdateState, - request_deserializer=rainbow__pb2.UpdateStateRequest.FromString, - response_serializer=rainbow__pb2.UpdateStateResponse.SerializeToString, - ), - 'ReceiveJobs': grpc.unary_unary_rpc_method_handler( - servicer.ReceiveJobs, - request_deserializer=rainbow__pb2.ReceiveJobsRequest.FromString, - response_serializer=rainbow__pb2.ReceiveJobsResponse.SerializeToString, - ), - 'AcceptJobs': grpc.unary_unary_rpc_method_handler( - servicer.AcceptJobs, - request_deserializer=rainbow__pb2.AcceptJobsRequest.FromString, - response_serializer=rainbow__pb2.AcceptJobsResponse.SerializeToString, - ), + "Register": grpc.unary_unary_rpc_method_handler( + servicer.Register, + request_deserializer=rainbow__pb2.RegisterRequest.FromString, + response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, + ), + "Delete": grpc.unary_unary_rpc_method_handler( + servicer.Delete, + request_deserializer=rainbow__pb2.RegisterRequest.FromString, + response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, + ), + "RegisterSubsystem": grpc.unary_unary_rpc_method_handler( + servicer.RegisterSubsystem, + request_deserializer=rainbow__pb2.RegisterRequest.FromString, + response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, + ), + "DeleteSubsystem": grpc.unary_unary_rpc_method_handler( + servicer.DeleteSubsystem, + request_deserializer=rainbow__pb2.DeleteRequest.FromString, + response_serializer=rainbow__pb2.RegisterResponse.SerializeToString, + ), + "SubmitJob": grpc.unary_unary_rpc_method_handler( + servicer.SubmitJob, + request_deserializer=rainbow__pb2.SubmitJobRequest.FromString, + response_serializer=rainbow__pb2.SubmitJobResponse.SerializeToString, + ), + "UpdateState": grpc.unary_unary_rpc_method_handler( + servicer.UpdateState, + request_deserializer=rainbow__pb2.UpdateStateRequest.FromString, + response_serializer=rainbow__pb2.UpdateStateResponse.SerializeToString, + ), + "ReceiveJobs": grpc.unary_unary_rpc_method_handler( + servicer.ReceiveJobs, + request_deserializer=rainbow__pb2.ReceiveJobsRequest.FromString, + response_serializer=rainbow__pb2.ReceiveJobsResponse.SerializeToString, + ), + "AcceptJobs": grpc.unary_unary_rpc_method_handler( + servicer.AcceptJobs, + request_deserializer=rainbow__pb2.AcceptJobsRequest.FromString, + response_serializer=rainbow__pb2.AcceptJobsResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( - 'convergedcomputing.org.grpc.v1.RainbowScheduler', rpc_method_handlers) + "convergedcomputing.org.grpc.v1.RainbowScheduler", rpc_method_handlers + ) server.add_generic_rpc_handlers((generic_handler,)) - # This class is part of an EXPERIMENTAL API. +# This class is part of an EXPERIMENTAL API. class RainbowScheduler(object): - """RainbowSchedulerService provides API endpoints for interacting with the central scheduler service - """ + """RainbowSchedulerService provides API endpoints for interacting with the central scheduler service""" @staticmethod - def Register(request, + def Register( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/Register', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/Register", rainbow__pb2.RegisterRequest.SerializeToString, rainbow__pb2.RegisterResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def Delete(request, + def Delete( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/Delete', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/Delete", rainbow__pb2.RegisterRequest.SerializeToString, rainbow__pb2.RegisterResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def RegisterSubsystem(request, + def RegisterSubsystem( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/RegisterSubsystem', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/RegisterSubsystem", rainbow__pb2.RegisterRequest.SerializeToString, rainbow__pb2.RegisterResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def DeleteSubsystem(request, + def DeleteSubsystem( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/DeleteSubsystem', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/DeleteSubsystem", rainbow__pb2.DeleteRequest.SerializeToString, rainbow__pb2.RegisterResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def SubmitJob(request, + def SubmitJob( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/SubmitJob', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/SubmitJob", rainbow__pb2.SubmitJobRequest.SerializeToString, rainbow__pb2.SubmitJobResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def UpdateState(request, + def UpdateState( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/UpdateState', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/UpdateState", rainbow__pb2.UpdateStateRequest.SerializeToString, rainbow__pb2.UpdateStateResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def ReceiveJobs(request, + def ReceiveJobs( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/ReceiveJobs', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/ReceiveJobs", rainbow__pb2.ReceiveJobsRequest.SerializeToString, rainbow__pb2.ReceiveJobsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def AcceptJobs(request, + def AcceptJobs( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/convergedcomputing.org.grpc.v1.RainbowScheduler/AcceptJobs', + "/convergedcomputing.org.grpc.v1.RainbowScheduler/AcceptJobs", rainbow__pb2.AcceptJobsRequest.SerializeToString, rainbow__pb2.AcceptJobsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + )