@@ -26,6 +26,11 @@ def __init__(self, channel):
2626 request_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .UnregisterRequest .SerializeToString ,
2727 response_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .UnregisterResponse .FromString ,
2828 _registered_method = True )
29+ self .ReportStatus = channel .unary_unary (
30+ '/jumpstarter.v1.ControllerService/ReportStatus' ,
31+ request_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ReportStatusRequest .SerializeToString ,
32+ response_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ReportStatusResponse .FromString ,
33+ _registered_method = True )
2934 self .Listen = channel .unary_stream (
3035 '/jumpstarter.v1.ControllerService/Listen' ,
3136 request_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ListenRequest .SerializeToString ,
@@ -89,6 +94,14 @@ def Unregister(self, request, context):
8994 context .set_details ('Method not implemented!' )
9095 raise NotImplementedError ('Method not implemented!' )
9196
97+ def ReportStatus (self , request , context ):
98+ """Exporter status report
99+ Allows exporters to report their own status to the controller
100+ """
101+ context .set_code (grpc .StatusCode .UNIMPLEMENTED )
102+ context .set_details ('Method not implemented!' )
103+ raise NotImplementedError ('Method not implemented!' )
104+
92105 def Listen (self , request , context ):
93106 """Exporter listening
94107 Returns stream tokens for accepting incoming client connections
@@ -163,6 +176,11 @@ def add_ControllerServiceServicer_to_server(servicer, server):
163176 request_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .UnregisterRequest .FromString ,
164177 response_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .UnregisterResponse .SerializeToString ,
165178 ),
179+ 'ReportStatus' : grpc .unary_unary_rpc_method_handler (
180+ servicer .ReportStatus ,
181+ request_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ReportStatusRequest .FromString ,
182+ response_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ReportStatusResponse .SerializeToString ,
183+ ),
166184 'Listen' : grpc .unary_stream_rpc_method_handler (
167185 servicer .Listen ,
168186 request_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ListenRequest .FromString ,
@@ -269,6 +287,33 @@ def Unregister(request,
269287 metadata ,
270288 _registered_method = True )
271289
290+ @staticmethod
291+ def ReportStatus (request ,
292+ target ,
293+ options = (),
294+ channel_credentials = None ,
295+ call_credentials = None ,
296+ insecure = False ,
297+ compression = None ,
298+ wait_for_ready = None ,
299+ timeout = None ,
300+ metadata = None ):
301+ return grpc .experimental .unary_unary (
302+ request ,
303+ target ,
304+ '/jumpstarter.v1.ControllerService/ReportStatus' ,
305+ jumpstarter_dot_v1_dot_jumpstarter__pb2 .ReportStatusRequest .SerializeToString ,
306+ jumpstarter_dot_v1_dot_jumpstarter__pb2 .ReportStatusResponse .FromString ,
307+ options ,
308+ channel_credentials ,
309+ insecure ,
310+ call_credentials ,
311+ compression ,
312+ wait_for_ready ,
313+ timeout ,
314+ metadata ,
315+ _registered_method = True )
316+
272317 @staticmethod
273318 def Listen (request ,
274319 target ,
@@ -522,6 +567,11 @@ def __init__(self, channel):
522567 request_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ResetRequest .SerializeToString ,
523568 response_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ResetResponse .FromString ,
524569 _registered_method = True )
570+ self .GetStatus = channel .unary_unary (
571+ '/jumpstarter.v1.ExporterService/GetStatus' ,
572+ request_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .GetStatusRequest .SerializeToString ,
573+ response_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .GetStatusResponse .FromString ,
574+ _registered_method = True )
525575
526576
527577class ExporterServiceServicer (object ):
@@ -560,6 +610,12 @@ def Reset(self, request, context):
560610 context .set_details ('Method not implemented!' )
561611 raise NotImplementedError ('Method not implemented!' )
562612
613+ def GetStatus (self , request , context ):
614+ """Missing associated documentation comment in .proto file."""
615+ context .set_code (grpc .StatusCode .UNIMPLEMENTED )
616+ context .set_details ('Method not implemented!' )
617+ raise NotImplementedError ('Method not implemented!' )
618+
563619
564620def add_ExporterServiceServicer_to_server (servicer , server ):
565621 rpc_method_handlers = {
@@ -588,6 +644,11 @@ def add_ExporterServiceServicer_to_server(servicer, server):
588644 request_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ResetRequest .FromString ,
589645 response_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .ResetResponse .SerializeToString ,
590646 ),
647+ 'GetStatus' : grpc .unary_unary_rpc_method_handler (
648+ servicer .GetStatus ,
649+ request_deserializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .GetStatusRequest .FromString ,
650+ response_serializer = jumpstarter_dot_v1_dot_jumpstarter__pb2 .GetStatusResponse .SerializeToString ,
651+ ),
591652 }
592653 generic_handler = grpc .method_handlers_generic_handler (
593654 'jumpstarter.v1.ExporterService' , rpc_method_handlers )
@@ -735,3 +796,30 @@ def Reset(request,
735796 timeout ,
736797 metadata ,
737798 _registered_method = True )
799+
800+ @staticmethod
801+ def GetStatus (request ,
802+ target ,
803+ options = (),
804+ channel_credentials = None ,
805+ call_credentials = None ,
806+ insecure = False ,
807+ compression = None ,
808+ wait_for_ready = None ,
809+ timeout = None ,
810+ metadata = None ):
811+ return grpc .experimental .unary_unary (
812+ request ,
813+ target ,
814+ '/jumpstarter.v1.ExporterService/GetStatus' ,
815+ jumpstarter_dot_v1_dot_jumpstarter__pb2 .GetStatusRequest .SerializeToString ,
816+ jumpstarter_dot_v1_dot_jumpstarter__pb2 .GetStatusResponse .FromString ,
817+ options ,
818+ channel_credentials ,
819+ insecure ,
820+ call_credentials ,
821+ compression ,
822+ wait_for_ready ,
823+ timeout ,
824+ metadata ,
825+ _registered_method = True )
0 commit comments