leve0

csst_dfs_proto/facility/detector_pb2_grpc.py → csst_dfs_proto/facility/detector/detector_pb2_grpc.py

 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 import grpc
 
-from . import detector_pb2 as facility_dot_detector__pb2
+from . import detector_pb2 as facility_dot_detector_dot_detector__pb2
 
 
 class DetectorSrvStub(object):
@@ -15,39 +15,44 @@ class DetectorSrvStub(object):
       channel: A grpc.Channel.
     """
     self.Find = channel.unary_unary(
-        '/facility.DetectorSrv/Find',
-        request_serializer=facility_dot_detector__pb2.FindDetectorReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.FindDetectorResp.FromString,
+        '/detector.DetectorSrv/Find',
+        request_serializer=facility_dot_detector_dot_detector__pb2.FindDetectorReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.FindDetectorResp.FromString,
         )
     self.Get = channel.unary_unary(
-        '/facility.DetectorSrv/Get',
-        request_serializer=facility_dot_detector__pb2.GetDetectorReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.GetDetectorResp.FromString,
+        '/detector.DetectorSrv/Get',
+        request_serializer=facility_dot_detector_dot_detector__pb2.GetDetectorReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.GetDetectorResp.FromString,
         )
     self.Write = channel.unary_unary(
-        '/facility.DetectorSrv/Write',
-        request_serializer=facility_dot_detector__pb2.WriteDetectorReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.WriteDetectorResp.FromString,
+        '/detector.DetectorSrv/Write',
+        request_serializer=facility_dot_detector_dot_detector__pb2.WriteDetectorReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.WriteDetectorResp.FromString,
         )
     self.Update = channel.unary_unary(
-        '/facility.DetectorSrv/Update',
-        request_serializer=facility_dot_detector__pb2.UpdateDetectorReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.UpdateDetectorResp.FromString,
+        '/detector.DetectorSrv/Update',
+        request_serializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorResp.FromString,
+        )
+    self.Delete = channel.unary_unary(
+        '/detector.DetectorSrv/Delete',
+        request_serializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorResp.FromString,
         )
     self.FindStatus = channel.unary_unary(
-        '/facility.DetectorSrv/FindStatus',
-        request_serializer=facility_dot_detector__pb2.FindStatusReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.FindStatusResp.FromString,
+        '/detector.DetectorSrv/FindStatus',
+        request_serializer=facility_dot_detector_dot_detector__pb2.FindStatusReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.FindStatusResp.FromString,
         )
     self.GetStatus = channel.unary_unary(
-        '/facility.DetectorSrv/GetStatus',
-        request_serializer=facility_dot_detector__pb2.GetStatusReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.GetStatusResp.FromString,
+        '/detector.DetectorSrv/GetStatus',
+        request_serializer=facility_dot_detector_dot_detector__pb2.GetStatusReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.GetStatusResp.FromString,
         )
     self.WriteStatus = channel.unary_unary(
-        '/facility.DetectorSrv/WriteStatus',
-        request_serializer=facility_dot_detector__pb2.WriteStatusReq.SerializeToString,
-        response_deserializer=facility_dot_detector__pb2.WriteStatusResp.FromString,
+        '/detector.DetectorSrv/WriteStatus',
+        request_serializer=facility_dot_detector_dot_detector__pb2.WriteStatusReq.SerializeToString,
+        response_deserializer=facility_dot_detector_dot_detector__pb2.WriteStatusResp.FromString,
         )
 
 
@@ -83,6 +88,13 @@ class DetectorSrvServicer(object):
     context.set_details('Method not implemented!')
     raise NotImplementedError('Method not implemented!')
 
+  def Delete(self, request, context):
+    # missing associated documentation comment in .proto file
+    pass
+    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+    context.set_details('Method not implemented!')
+    raise NotImplementedError('Method not implemented!')
+
   def FindStatus(self, request, context):
     # missing associated documentation comment in .proto file
     pass
@@ -109,40 +121,45 @@ def add_DetectorSrvServicer_to_server(servicer, server):
   rpc_method_handlers = {
       'Find': grpc.unary_unary_rpc_method_handler(
           servicer.Find,
-          request_deserializer=facility_dot_detector__pb2.FindDetectorReq.FromString,
-          response_serializer=facility_dot_detector__pb2.FindDetectorResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.FindDetectorReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.FindDetectorResp.SerializeToString,
       ),
       'Get': grpc.unary_unary_rpc_method_handler(
           servicer.Get,
-          request_deserializer=facility_dot_detector__pb2.GetDetectorReq.FromString,
-          response_serializer=facility_dot_detector__pb2.GetDetectorResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.GetDetectorReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.GetDetectorResp.SerializeToString,
       ),
       'Write': grpc.unary_unary_rpc_method_handler(
           servicer.Write,
-          request_deserializer=facility_dot_detector__pb2.WriteDetectorReq.FromString,
-          response_serializer=facility_dot_detector__pb2.WriteDetectorResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.WriteDetectorReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.WriteDetectorResp.SerializeToString,
       ),
       'Update': grpc.unary_unary_rpc_method_handler(
           servicer.Update,
-          request_deserializer=facility_dot_detector__pb2.UpdateDetectorReq.FromString,
-          response_serializer=facility_dot_detector__pb2.UpdateDetectorResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorResp.SerializeToString,
+      ),
+      'Delete': grpc.unary_unary_rpc_method_handler(
+          servicer.Delete,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorResp.SerializeToString,
       ),
       'FindStatus': grpc.unary_unary_rpc_method_handler(
           servicer.FindStatus,
-          request_deserializer=facility_dot_detector__pb2.FindStatusReq.FromString,
-          response_serializer=facility_dot_detector__pb2.FindStatusResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.FindStatusReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.FindStatusResp.SerializeToString,
       ),
       'GetStatus': grpc.unary_unary_rpc_method_handler(
           servicer.GetStatus,
-          request_deserializer=facility_dot_detector__pb2.GetStatusReq.FromString,
-          response_serializer=facility_dot_detector__pb2.GetStatusResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.GetStatusReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.GetStatusResp.SerializeToString,
       ),
       'WriteStatus': grpc.unary_unary_rpc_method_handler(
           servicer.WriteStatus,
-          request_deserializer=facility_dot_detector__pb2.WriteStatusReq.FromString,
-          response_serializer=facility_dot_detector__pb2.WriteStatusResp.SerializeToString,
+          request_deserializer=facility_dot_detector_dot_detector__pb2.WriteStatusReq.FromString,
+          response_serializer=facility_dot_detector_dot_detector__pb2.WriteStatusResp.SerializeToString,
       ),
   }
   generic_handler = grpc.method_handlers_generic_handler(
-      'facility.DetectorSrv', rpc_method_handlers)
+      'detector.DetectorSrv', rpc_method_handlers)
   server.add_generic_rpc_handlers((generic_handler,))

csst_dfs_proto/facility/level0/level0_pb2_grpc.py

+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+import grpc
+
+from . import level0_pb2 as facility_dot_level0_dot_level0__pb2
+
+
+class Level0SrvStub(object):
+  # missing associated documentation comment in .proto file
+  pass
+
+  def __init__(self, channel):
+    """Constructor.
+
+    Args:
+      channel: A grpc.Channel.
+    """
+    self.Find = channel.unary_unary(
+        '/level0.Level0Srv/Find',
+        request_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
+        response_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString,
+        )
+    self.Get = channel.unary_unary(
+        '/level0.Level0Srv/Get',
+        request_serializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
+        response_deserializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString,
+        )
+    self.UpdateQc0Status = channel.unary_unary(
+        '/level0.Level0Srv/UpdateQc0Status',
+        request_serializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString,
+        response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.FromString,
+        )
+    self.UpdateProcStatus = channel.unary_unary(
+        '/level0.Level0Srv/UpdateProcStatus',
+        request_serializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString,
+        response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString,
+        )
+
+
+class Level0SrvServicer(object):
+  # missing associated documentation comment in .proto file
+  pass
+
+  def Find(self, request, context):
+    # missing associated documentation comment in .proto file
+    pass
+    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
+    pass
+    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+    context.set_details('Method not implemented!')
+    raise NotImplementedError('Method not implemented!')
+
+  def UpdateQc0Status(self, request, context):
+    # missing associated documentation comment in .proto file
+    pass
+    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
+    pass
+    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+    context.set_details('Method not implemented!')
+    raise NotImplementedError('Method not implemented!')
+
+
+def add_Level0SrvServicer_to_server(servicer, server):
+  rpc_method_handlers = {
+      'Find': grpc.unary_unary_rpc_method_handler(
+          servicer.Find,
+          request_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.FromString,
+          response_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.SerializeToString,
+      ),
+      'Get': grpc.unary_unary_rpc_method_handler(
+          servicer.Get,
+          request_deserializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.FromString,
+          response_serializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.SerializeToString,
+      ),
+      'UpdateQc0Status': grpc.unary_unary_rpc_method_handler(
+          servicer.UpdateQc0Status,
+          request_deserializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.FromString,
+          response_serializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.SerializeToString,
+      ),
+      'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
+          servicer.UpdateProcStatus,
+          request_deserializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.FromString,
+          response_serializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.SerializeToString,
+      ),
+  }
+  generic_handler = grpc.method_handlers_generic_handler(
+      'level0.Level0Srv', rpc_method_handlers)
+  server.add_generic_rpc_handlers((generic_handler,))

csst_dfs_proto/facility/level0prc/level0prc_pb2_grpc.py

+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+import grpc
+
+from . import level0prc_pb2 as facility_dot_level0prc_dot_level0prc__pb2
+
+
+class Level0PrcSrvStub(object):
+  # missing associated documentation comment in .proto file
+  pass
+
+  def __init__(self, channel):
+    """Constructor.
+
+    Args:
+      channel: A grpc.Channel.
+    """
+    self.Find = channel.unary_unary(
+        '/level0prc.Level0PrcSrv/Find',
+        request_serializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString,
+        response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString,
+        )
+    self.Write = channel.unary_unary(
+        '/level0prc.Level0PrcSrv/Write',
+        request_serializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString,
+        response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.FromString,
+        )
+    self.UpdateProcStatus = channel.unary_unary(
+        '/level0prc.Level0PrcSrv/UpdateProcStatus',
+        request_serializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
+        response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString,
+        )
+
+
+class Level0PrcSrvServicer(object):
+  # missing associated documentation comment in .proto file
+  pass
+
+  def Find(self, request, context):
+    # missing associated documentation comment in .proto file
+    pass
+    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+    context.set_details('Method not implemented!')
+    raise NotImplementedError('Method not implemented!')
+
+  def Write(self, request, context):
+    # missing associated documentation comment in .proto file
+    pass
+    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
+    pass
+    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+    context.set_details('Method not implemented!')
+    raise NotImplementedError('Method not implemented!')
+
+
+def add_Level0PrcSrvServicer_to_server(servicer, server):
+  rpc_method_handlers = {
+      'Find': grpc.unary_unary_rpc_method_handler(
+          servicer.Find,
+          request_deserializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.FromString,
+          response_serializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.SerializeToString,
+      ),
+      'Write': grpc.unary_unary_rpc_method_handler(
+          servicer.Write,
+          request_deserializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.FromString,
+          response_serializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.SerializeToString,
+      ),
+      'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
+          servicer.UpdateProcStatus,
+          request_deserializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.FromString,
+          response_serializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.SerializeToString,
+      ),
+  }
+  generic_handler = grpc.method_handlers_generic_handler(
+      'level0prc.Level0PrcSrv', rpc_method_handlers)
+  server.add_generic_rpc_handlers((generic_handler,))

csst_dfs_proto/facility/exposure_pb2_grpc.py → csst_dfs_proto/facility/observation/observation_pb2_grpc.py

 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 import grpc
 
-from . import exposure_pb2 as facility_dot_exposure__pb2
+from . import observation_pb2 as facility_dot_observation_dot_observation__pb2
 
 
-class ExposureSrvStub(object):
+class ObservationSrvStub(object):
   # missing associated documentation comment in .proto file
   pass
 
@@ -15,33 +15,33 @@ class ExposureSrvStub(object):
       channel: A grpc.Channel.
     """
     self.Find = channel.unary_unary(
-        '/facility.ExposureSrv/Find',
-        request_serializer=facility_dot_exposure__pb2.FindExposureReq.SerializeToString,
-        response_deserializer=facility_dot_exposure__pb2.FindExposureResp.FromString,
+        '/observation.ObservationSrv/Find',
+        request_serializer=facility_dot_observation_dot_observation__pb2.FindObservationReq.SerializeToString,
+        response_deserializer=facility_dot_observation_dot_observation__pb2.FindObservationResp.FromString,
         )
     self.Get = channel.unary_unary(
-        '/facility.ExposureSrv/Get',
-        request_serializer=facility_dot_exposure__pb2.GetExposureReq.SerializeToString,
-        response_deserializer=facility_dot_exposure__pb2.GetExposureResp.FromString,
+        '/observation.ObservationSrv/Get',
+        request_serializer=facility_dot_observation_dot_observation__pb2.GetObservationReq.SerializeToString,
+        response_deserializer=facility_dot_observation_dot_observation__pb2.GetObservationResp.FromString,
         )
     self.Write = channel.stream_unary(
-        '/facility.ExposureSrv/Write',
-        request_serializer=facility_dot_exposure__pb2.WriteExposureReq.SerializeToString,
-        response_deserializer=facility_dot_exposure__pb2.WriteExposureResp.FromString,
+        '/observation.ObservationSrv/Write',
+        request_serializer=facility_dot_observation_dot_observation__pb2.WriteObservationReq.SerializeToString,
+        response_deserializer=facility_dot_observation_dot_observation__pb2.WriteObservationResp.FromString,
         )
     self.UpdateQc0Status = channel.unary_unary(
-        '/facility.ExposureSrv/UpdateQc0Status',
-        request_serializer=facility_dot_exposure__pb2.UpdateQc0StatusReq.SerializeToString,
-        response_deserializer=facility_dot_exposure__pb2.UpdateQc0StatusResp.FromString,
+        '/observation.ObservationSrv/UpdateQc0Status',
+        request_serializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusReq.SerializeToString,
+        response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusResp.FromString,
         )
     self.UpdateProcStatus = channel.unary_unary(
-        '/facility.ExposureSrv/UpdateProcStatus',
-        request_serializer=facility_dot_exposure__pb2.UpdateProcStatusReq.SerializeToString,
-        response_deserializer=facility_dot_exposure__pb2.UpdateProcStatusResp.FromString,
+        '/observation.ObservationSrv/UpdateProcStatus',
+        request_serializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusReq.SerializeToString,
+        response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusResp.FromString,
         )
 
 
-class ExposureSrvServicer(object):
+class ObservationSrvServicer(object):
   # missing associated documentation comment in .proto file
   pass
 
@@ -81,34 +81,34 @@ class ExposureSrvServicer(object):
     raise NotImplementedError('Method not implemented!')
 
 
-def add_ExposureSrvServicer_to_server(servicer, server):
+def add_ObservationSrvServicer_to_server(servicer, server):
   rpc_method_handlers = {
       'Find': grpc.unary_unary_rpc_method_handler(
           servicer.Find,
-          request_deserializer=facility_dot_exposure__pb2.FindExposureReq.FromString,
-          response_serializer=facility_dot_exposure__pb2.FindExposureResp.SerializeToString,
+          request_deserializer=facility_dot_observation_dot_observation__pb2.FindObservationReq.FromString,
+          response_serializer=facility_dot_observation_dot_observation__pb2.FindObservationResp.SerializeToString,
       ),
       'Get': grpc.unary_unary_rpc_method_handler(
           servicer.Get,
-          request_deserializer=facility_dot_exposure__pb2.GetExposureReq.FromString,
-          response_serializer=facility_dot_exposure__pb2.GetExposureResp.SerializeToString,
+          request_deserializer=facility_dot_observation_dot_observation__pb2.GetObservationReq.FromString,
+          response_serializer=facility_dot_observation_dot_observation__pb2.GetObservationResp.SerializeToString,
       ),
       'Write': grpc.stream_unary_rpc_method_handler(
           servicer.Write,
-          request_deserializer=facility_dot_exposure__pb2.WriteExposureReq.FromString,
-          response_serializer=facility_dot_exposure__pb2.WriteExposureResp.SerializeToString,
+          request_deserializer=facility_dot_observation_dot_observation__pb2.WriteObservationReq.FromString,
+          response_serializer=facility_dot_observation_dot_observation__pb2.WriteObservationResp.SerializeToString,
       ),
       'UpdateQc0Status': grpc.unary_unary_rpc_method_handler(
           servicer.UpdateQc0Status,
-          request_deserializer=facility_dot_exposure__pb2.UpdateQc0StatusReq.FromString,
-          response_serializer=facility_dot_exposure__pb2.UpdateQc0StatusResp.SerializeToString,
+          request_deserializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusReq.FromString,
+          response_serializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusResp.SerializeToString,
       ),
       'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
           servicer.UpdateProcStatus,
-          request_deserializer=facility_dot_exposure__pb2.UpdateProcStatusReq.FromString,
-          response_serializer=facility_dot_exposure__pb2.UpdateProcStatusResp.SerializeToString,
+          request_deserializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusReq.FromString,
+          response_serializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusResp.SerializeToString,
       ),
   }
   generic_handler = grpc.method_handlers_generic_handler(
-      'facility.ExposureSrv', rpc_method_handlers)
+      'observation.ObservationSrv', rpc_method_handlers)
   server.add_generic_rpc_handlers((generic_handler,))