hstdm l2

csst_dfs_proto/hstdm/level2/level2_pb2_grpc.py

+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+import grpc
+
+from . import level2_pb2 as hstdm_dot_level2_dot_level2__pb2
+
+
+class Level2SrvStub(object):
+    """Missing associated documentation comment in .proto file"""
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.Find = channel.unary_unary(
+                '/dfs.hstdm.level2.Level2Srv/Find',
+                request_serializer=hstdm_dot_level2_dot_level2__pb2.FindLevel2Req.SerializeToString,
+                response_deserializer=hstdm_dot_level2_dot_level2__pb2.FindLevel2Resp.FromString,
+                )
+        self.Get = channel.unary_unary(
+                '/dfs.hstdm.level2.Level2Srv/Get',
+                request_serializer=hstdm_dot_level2_dot_level2__pb2.GetLevel2Req.SerializeToString,
+                response_deserializer=hstdm_dot_level2_dot_level2__pb2.GetLevel2Resp.FromString,
+                )
+        self.Write = channel.stream_unary(
+                '/dfs.hstdm.level2.Level2Srv/Write',
+                request_serializer=hstdm_dot_level2_dot_level2__pb2.WriteLevel2Req.SerializeToString,
+                response_deserializer=hstdm_dot_level2_dot_level2__pb2.WriteLevel2Resp.FromString,
+                )
+        self.UpdateQc2Status = channel.unary_unary(
+                '/dfs.hstdm.level2.Level2Srv/UpdateQc2Status',
+                request_serializer=hstdm_dot_level2_dot_level2__pb2.UpdateQc2StatusReq.SerializeToString,
+                response_deserializer=hstdm_dot_level2_dot_level2__pb2.UpdateQc2StatusResp.FromString,
+                )
+        self.UpdateProcStatus = channel.unary_unary(
+                '/dfs.hstdm.level2.Level2Srv/UpdateProcStatus',
+                request_serializer=hstdm_dot_level2_dot_level2__pb2.UpdateProcStatusReq.SerializeToString,
+                response_deserializer=hstdm_dot_level2_dot_level2__pb2.UpdateProcStatusResp.FromString,
+                )
+
+
+class Level2SrvServicer(object):
+    """Missing associated documentation comment in .proto file"""
+
+    def Find(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!')
+
+    def Get(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!')
+
+    def Write(self, request_iterator, 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!')
+
+    def UpdateQc2Status(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!')
+
+    def UpdateProcStatus(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!')
+
+
+def add_Level2SrvServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            'Find': grpc.unary_unary_rpc_method_handler(
+                    servicer.Find,
+                    request_deserializer=hstdm_dot_level2_dot_level2__pb2.FindLevel2Req.FromString,
+                    response_serializer=hstdm_dot_level2_dot_level2__pb2.FindLevel2Resp.SerializeToString,
+            ),
+            'Get': grpc.unary_unary_rpc_method_handler(
+                    servicer.Get,
+                    request_deserializer=hstdm_dot_level2_dot_level2__pb2.GetLevel2Req.FromString,
+                    response_serializer=hstdm_dot_level2_dot_level2__pb2.GetLevel2Resp.SerializeToString,
+            ),
+            'Write': grpc.stream_unary_rpc_method_handler(
+                    servicer.Write,
+                    request_deserializer=hstdm_dot_level2_dot_level2__pb2.WriteLevel2Req.FromString,
+                    response_serializer=hstdm_dot_level2_dot_level2__pb2.WriteLevel2Resp.SerializeToString,
+            ),
+            'UpdateQc2Status': grpc.unary_unary_rpc_method_handler(
+                    servicer.UpdateQc2Status,
+                    request_deserializer=hstdm_dot_level2_dot_level2__pb2.UpdateQc2StatusReq.FromString,
+                    response_serializer=hstdm_dot_level2_dot_level2__pb2.UpdateQc2StatusResp.SerializeToString,
+            ),
+            'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
+                    servicer.UpdateProcStatus,
+                    request_deserializer=hstdm_dot_level2_dot_level2__pb2.UpdateProcStatusReq.FromString,
+                    response_serializer=hstdm_dot_level2_dot_level2__pb2.UpdateProcStatusResp.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'dfs.hstdm.level2.Level2Srv', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class Level2Srv(object):
+    """Missing associated documentation comment in .proto file"""
+
+    @staticmethod
+    def Find(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/dfs.hstdm.level2.Level2Srv/Find',
+            hstdm_dot_level2_dot_level2__pb2.FindLevel2Req.SerializeToString,
+            hstdm_dot_level2_dot_level2__pb2.FindLevel2Resp.FromString,
+            options, channel_credentials,
+            call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def Get(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/dfs.hstdm.level2.Level2Srv/Get',
+            hstdm_dot_level2_dot_level2__pb2.GetLevel2Req.SerializeToString,
+            hstdm_dot_level2_dot_level2__pb2.GetLevel2Resp.FromString,
+            options, channel_credentials,
+            call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def Write(request_iterator,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.stream_unary(request_iterator, target, '/dfs.hstdm.level2.Level2Srv/Write',
+            hstdm_dot_level2_dot_level2__pb2.WriteLevel2Req.SerializeToString,
+            hstdm_dot_level2_dot_level2__pb2.WriteLevel2Resp.FromString,
+            options, channel_credentials,
+            call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def UpdateQc2Status(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/dfs.hstdm.level2.Level2Srv/UpdateQc2Status',
+            hstdm_dot_level2_dot_level2__pb2.UpdateQc2StatusReq.SerializeToString,
+            hstdm_dot_level2_dot_level2__pb2.UpdateQc2StatusResp.FromString,
+            options, channel_credentials,
+            call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def UpdateProcStatus(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/dfs.hstdm.level2.Level2Srv/UpdateProcStatus',
+            hstdm_dot_level2_dot_level2__pb2.UpdateProcStatusReq.SerializeToString,
+            hstdm_dot_level2_dot_level2__pb2.UpdateProcStatusResp.FromString,
+            options, channel_credentials,
+            call_credentials, compression, wait_for_ready, timeout, metadata)