Commit 98005660 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

request path

parent d9e935a3
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc import grpc
from . import calmerge_pb2 as facility_dot_calmerge_dot_calmerge__pb2 from ...facility.calmerge import calmerge_pb2 as facility_dot_calmerge_dot_calmerge__pb2
class CalMergeSrvStub(object): class CalMergeSrvStub(object):
...@@ -15,27 +15,27 @@ class CalMergeSrvStub(object): ...@@ -15,27 +15,27 @@ class CalMergeSrvStub(object):
channel: A grpc.Channel. channel: A grpc.Channel.
""" """
self.Find = channel.unary_unary( self.Find = channel.unary_unary(
'/calmerge.CalMergeSrv/Find', '/dfs.facility.calmerge.CalMergeSrv/Find',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.SerializeToString, request_serializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.FromString, response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.FromString,
) )
self.Get = channel.unary_unary( self.Get = channel.unary_unary(
'/calmerge.CalMergeSrv/Get', '/dfs.facility.calmerge.CalMergeSrv/Get',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.SerializeToString, request_serializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.FromString, response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.FromString,
) )
self.Write = channel.unary_unary( self.Write = channel.unary_unary(
'/calmerge.CalMergeSrv/Write', '/dfs.facility.calmerge.CalMergeSrv/Write',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.SerializeToString, request_serializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.FromString, response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.FromString,
) )
self.UpdateQc1Status = channel.unary_unary( self.UpdateQc1Status = channel.unary_unary(
'/calmerge.CalMergeSrv/UpdateQc1Status', '/dfs.facility.calmerge.CalMergeSrv/UpdateQc1Status',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.SerializeToString, request_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.FromString, response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.FromString,
) )
self.UpdateProcStatus = channel.unary_unary( self.UpdateProcStatus = channel.unary_unary(
'/calmerge.CalMergeSrv/UpdateProcStatus', '/dfs.facility.calmerge.CalMergeSrv/UpdateProcStatus',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString, request_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString, response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString,
) )
...@@ -110,5 +110,5 @@ def add_CalMergeSrvServicer_to_server(servicer, server): ...@@ -110,5 +110,5 @@ def add_CalMergeSrvServicer_to_server(servicer, server):
), ),
} }
generic_handler = grpc.method_handlers_generic_handler( generic_handler = grpc.method_handlers_generic_handler(
'calmerge.CalMergeSrv', rpc_method_handlers) 'dfs.facility.calmerge.CalMergeSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,)) server.add_generic_rpc_handlers((generic_handler,))
...@@ -15,42 +15,42 @@ class DetectorSrvStub(object): ...@@ -15,42 +15,42 @@ class DetectorSrvStub(object):
channel: A grpc.Channel. channel: A grpc.Channel.
""" """
self.Find = channel.unary_unary( self.Find = channel.unary_unary(
'/facility.detector.DetectorSrv/Find', '/dfs.facility.detector.DetectorSrv/Find',
request_serializer=facility_dot_detector_dot_detector__pb2.FindDetectorReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.FindDetectorReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.FindDetectorResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.FindDetectorResp.FromString,
) )
self.Get = channel.unary_unary( self.Get = channel.unary_unary(
'/facility.detector.DetectorSrv/Get', '/dfs.facility.detector.DetectorSrv/Get',
request_serializer=facility_dot_detector_dot_detector__pb2.GetDetectorReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.GetDetectorReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.GetDetectorResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.GetDetectorResp.FromString,
) )
self.Write = channel.unary_unary( self.Write = channel.unary_unary(
'/facility.detector.DetectorSrv/Write', '/dfs.facility.detector.DetectorSrv/Write',
request_serializer=facility_dot_detector_dot_detector__pb2.WriteDetectorReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.WriteDetectorReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.WriteDetectorResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.WriteDetectorResp.FromString,
) )
self.Update = channel.unary_unary( self.Update = channel.unary_unary(
'/facility.detector.DetectorSrv/Update', '/dfs.facility.detector.DetectorSrv/Update',
request_serializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.UpdateDetectorResp.FromString,
) )
self.Delete = channel.unary_unary( self.Delete = channel.unary_unary(
'/facility.detector.DetectorSrv/Delete', '/dfs.facility.detector.DetectorSrv/Delete',
request_serializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.DeleteDetectorResp.FromString,
) )
self.FindStatus = channel.unary_unary( self.FindStatus = channel.unary_unary(
'/facility.detector.DetectorSrv/FindStatus', '/dfs.facility.detector.DetectorSrv/FindStatus',
request_serializer=facility_dot_detector_dot_detector__pb2.FindStatusReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.FindStatusReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.FindStatusResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.FindStatusResp.FromString,
) )
self.GetStatus = channel.unary_unary( self.GetStatus = channel.unary_unary(
'/facility.detector.DetectorSrv/GetStatus', '/dfs.facility.detector.DetectorSrv/GetStatus',
request_serializer=facility_dot_detector_dot_detector__pb2.GetStatusReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.GetStatusReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.GetStatusResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.GetStatusResp.FromString,
) )
self.WriteStatus = channel.unary_unary( self.WriteStatus = channel.unary_unary(
'/facility.detector.DetectorSrv/WriteStatus', '/dfs.facility.detector.DetectorSrv/WriteStatus',
request_serializer=facility_dot_detector_dot_detector__pb2.WriteStatusReq.SerializeToString, request_serializer=facility_dot_detector_dot_detector__pb2.WriteStatusReq.SerializeToString,
response_deserializer=facility_dot_detector_dot_detector__pb2.WriteStatusResp.FromString, response_deserializer=facility_dot_detector_dot_detector__pb2.WriteStatusResp.FromString,
) )
...@@ -161,5 +161,5 @@ def add_DetectorSrvServicer_to_server(servicer, server): ...@@ -161,5 +161,5 @@ def add_DetectorSrvServicer_to_server(servicer, server):
), ),
} }
generic_handler = grpc.method_handlers_generic_handler( generic_handler = grpc.method_handlers_generic_handler(
'facility.detector.DetectorSrv', rpc_method_handlers) 'dfs.facility.detector.DetectorSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,)) server.add_generic_rpc_handlers((generic_handler,))
...@@ -15,27 +15,27 @@ class Level0SrvStub(object): ...@@ -15,27 +15,27 @@ class Level0SrvStub(object):
channel: A grpc.Channel. channel: A grpc.Channel.
""" """
self.Find = channel.unary_unary( self.Find = channel.unary_unary(
'/level0.Level0Srv/Find', '/dfs.facility.level0.Level0Srv/Find',
request_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString, request_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString, response_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString,
) )
self.Get = channel.unary_unary( self.Get = channel.unary_unary(
'/level0.Level0Srv/Get', '/dfs.facility.level0.Level0Srv/Get',
request_serializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString, request_serializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString, response_deserializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString,
) )
self.Write = channel.unary_unary( self.Write = channel.unary_unary(
'/level0.Level0Srv/Write', '/dfs.facility.level0.Level0Srv/Write',
request_serializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataReq.SerializeToString, request_serializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataResp.FromString, response_deserializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataResp.FromString,
) )
self.UpdateQc0Status = channel.unary_unary( self.UpdateQc0Status = channel.unary_unary(
'/level0.Level0Srv/UpdateQc0Status', '/dfs.facility.level0.Level0Srv/UpdateQc0Status',
request_serializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString, request_serializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.FromString, response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.FromString,
) )
self.UpdateProcStatus = channel.unary_unary( self.UpdateProcStatus = channel.unary_unary(
'/level0.Level0Srv/UpdateProcStatus', '/dfs.facility.level0.Level0Srv/UpdateProcStatus',
request_serializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString, request_serializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString, response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString,
) )
...@@ -110,5 +110,5 @@ def add_Level0SrvServicer_to_server(servicer, server): ...@@ -110,5 +110,5 @@ def add_Level0SrvServicer_to_server(servicer, server):
), ),
} }
generic_handler = grpc.method_handlers_generic_handler( generic_handler = grpc.method_handlers_generic_handler(
'level0.Level0Srv', rpc_method_handlers) 'dfs.facility.level0.Level0Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,)) server.add_generic_rpc_handlers((generic_handler,))
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc import grpc
from . import level0prc_pb2 as facility_dot_level0prc_dot_level0prc__pb2 from ...facility.level0prc import level0prc_pb2 as facility_dot_level0prc_dot_level0prc__pb2
class Level0PrcSrvStub(object): class Level0PrcSrvStub(object):
...@@ -15,17 +15,17 @@ class Level0PrcSrvStub(object): ...@@ -15,17 +15,17 @@ class Level0PrcSrvStub(object):
channel: A grpc.Channel. channel: A grpc.Channel.
""" """
self.Find = channel.unary_unary( self.Find = channel.unary_unary(
'/level0prc.Level0PrcSrv/Find', '/dfs.facility.level0prc.Level0PrcSrv/Find',
request_serializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString, request_serializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString,
response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString, response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString,
) )
self.Write = channel.unary_unary( self.Write = channel.unary_unary(
'/level0prc.Level0PrcSrv/Write', '/dfs.facility.level0prc.Level0PrcSrv/Write',
request_serializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString, request_serializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString,
response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.FromString, response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.FromString,
) )
self.UpdateProcStatus = channel.unary_unary( self.UpdateProcStatus = channel.unary_unary(
'/level0prc.Level0PrcSrv/UpdateProcStatus', '/dfs.facility.level0prc.Level0PrcSrv/UpdateProcStatus',
request_serializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString, request_serializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString, response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString,
) )
...@@ -76,5 +76,5 @@ def add_Level0PrcSrvServicer_to_server(servicer, server): ...@@ -76,5 +76,5 @@ def add_Level0PrcSrvServicer_to_server(servicer, server):
), ),
} }
generic_handler = grpc.method_handlers_generic_handler( generic_handler = grpc.method_handlers_generic_handler(
'level0prc.Level0PrcSrv', rpc_method_handlers) 'dfs.facility.level0prc.Level0PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,)) server.add_generic_rpc_handlers((generic_handler,))
...@@ -15,27 +15,27 @@ class ObservationSrvStub(object): ...@@ -15,27 +15,27 @@ class ObservationSrvStub(object):
channel: A grpc.Channel. channel: A grpc.Channel.
""" """
self.Find = channel.unary_unary( self.Find = channel.unary_unary(
'/observation.ObservationSrv/Find', '/dfs.facility.observation.ObservationSrv/Find',
request_serializer=facility_dot_observation_dot_observation__pb2.FindObservationReq.SerializeToString, request_serializer=facility_dot_observation_dot_observation__pb2.FindObservationReq.SerializeToString,
response_deserializer=facility_dot_observation_dot_observation__pb2.FindObservationResp.FromString, response_deserializer=facility_dot_observation_dot_observation__pb2.FindObservationResp.FromString,
) )
self.Get = channel.unary_unary( self.Get = channel.unary_unary(
'/observation.ObservationSrv/Get', '/dfs.facility.observation.ObservationSrv/Get',
request_serializer=facility_dot_observation_dot_observation__pb2.GetObservationReq.SerializeToString, request_serializer=facility_dot_observation_dot_observation__pb2.GetObservationReq.SerializeToString,
response_deserializer=facility_dot_observation_dot_observation__pb2.GetObservationResp.FromString, response_deserializer=facility_dot_observation_dot_observation__pb2.GetObservationResp.FromString,
) )
self.Write = channel.unary_unary( self.Write = channel.unary_unary(
'/observation.ObservationSrv/Write', '/dfs.facility.observation.ObservationSrv/Write',
request_serializer=facility_dot_observation_dot_observation__pb2.WriteObservationReq.SerializeToString, request_serializer=facility_dot_observation_dot_observation__pb2.WriteObservationReq.SerializeToString,
response_deserializer=facility_dot_observation_dot_observation__pb2.WriteObservationResp.FromString, response_deserializer=facility_dot_observation_dot_observation__pb2.WriteObservationResp.FromString,
) )
self.UpdateQc0Status = channel.unary_unary( self.UpdateQc0Status = channel.unary_unary(
'/observation.ObservationSrv/UpdateQc0Status', '/dfs.facility.observation.ObservationSrv/UpdateQc0Status',
request_serializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusReq.SerializeToString, request_serializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusReq.SerializeToString,
response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusResp.FromString, response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusResp.FromString,
) )
self.UpdateProcStatus = channel.unary_unary( self.UpdateProcStatus = channel.unary_unary(
'/observation.ObservationSrv/UpdateProcStatus', '/dfs.facility.observation.ObservationSrv/UpdateProcStatus',
request_serializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusReq.SerializeToString, request_serializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusResp.FromString, response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusResp.FromString,
) )
...@@ -110,5 +110,5 @@ def add_ObservationSrvServicer_to_server(servicer, server): ...@@ -110,5 +110,5 @@ def add_ObservationSrvServicer_to_server(servicer, server):
), ),
} }
generic_handler = grpc.method_handlers_generic_handler( generic_handler = grpc.method_handlers_generic_handler(
'observation.ObservationSrv', rpc_method_handlers) 'dfs.facility.observation.ObservationSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,)) server.add_generic_rpc_handlers((generic_handler,))
This diff is collapsed.
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import fits_pb2 as ifs_dot_fits_dot_fits__pb2
class FitsSrvStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/ifs.fits.FitsSrv/Find',
request_serializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsResp.FromString,
)
self.Get = channel.unary_unary(
'/ifs.fits.FitsSrv/Get',
request_serializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsResp.FromString,
)
self.Read = channel.unary_stream(
'/ifs.fits.FitsSrv/Read',
request_serializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsResp.FromString,
)
self.Write = channel.stream_unary(
'/ifs.fits.FitsSrv/Write',
request_serializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsResp.FromString,
)
self.UpdateQc0Status = channel.unary_unary(
'/ifs.fits.FitsSrv/UpdateQc0Status',
request_serializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/ifs.fits.FitsSrv/UpdateProcStatus',
request_serializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusResp.FromString,
)
class FitsSrvServicer(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 Read(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_iterator, 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_FitsSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsResp.SerializeToString,
),
'Read': grpc.unary_stream_rpc_method_handler(
servicer.Read,
request_deserializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsResp.SerializeToString,
),
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsResp.SerializeToString,
),
'UpdateQc0Status': grpc.unary_unary_rpc_method_handler(
servicer.UpdateQc0Status,
request_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'ifs.fits.FitsSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
This diff is collapsed.
...@@ -15,27 +15,27 @@ class Level1SrvStub(object): ...@@ -15,27 +15,27 @@ class Level1SrvStub(object):
channel: A grpc.Channel. channel: A grpc.Channel.
""" """
self.Find = channel.unary_unary( self.Find = channel.unary_unary(
'/ifs.level1.Level1Srv/Find', '/dfs.ifs.level1.Level1Srv/Find',
request_serializer=ifs_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString, request_serializer=ifs_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=ifs_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString, response_deserializer=ifs_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
) )
self.Get = channel.unary_unary( self.Get = channel.unary_unary(
'/ifs.level1.Level1Srv/Get', '/dfs.ifs.level1.Level1Srv/Get',
request_serializer=ifs_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString, request_serializer=ifs_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
response_deserializer=ifs_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString, response_deserializer=ifs_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
) )
self.Write = channel.unary_unary( self.Write = channel.unary_unary(
'/ifs.level1.Level1Srv/Write', '/dfs.ifs.level1.Level1Srv/Write',
request_serializer=ifs_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString, request_serializer=ifs_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
response_deserializer=ifs_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString, response_deserializer=ifs_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
) )
self.UpdateQc1Status = channel.unary_unary( self.UpdateQc1Status = channel.unary_unary(
'/ifs.level1.Level1Srv/UpdateQc1Status', '/dfs.ifs.level1.Level1Srv/UpdateQc1Status',
request_serializer=ifs_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString, request_serializer=ifs_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=ifs_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString, response_deserializer=ifs_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
) )
self.UpdateProcStatus = channel.unary_unary( self.UpdateProcStatus = channel.unary_unary(
'/ifs.level1.Level1Srv/UpdateProcStatus', '/dfs.ifs.level1.Level1Srv/UpdateProcStatus',
request_serializer=ifs_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString, request_serializer=ifs_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString, response_deserializer=ifs_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
) )
...@@ -110,5 +110,5 @@ def add_Level1SrvServicer_to_server(servicer, server): ...@@ -110,5 +110,5 @@ def add_Level1SrvServicer_to_server(servicer, server):
), ),
} }
generic_handler = grpc.method_handlers_generic_handler( generic_handler = grpc.method_handlers_generic_handler(
'ifs.level1.Level1Srv', rpc_method_handlers) 'dfs.ifs.level1.Level1Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,)) server.add_generic_rpc_handlers((generic_handler,))
This diff is collapsed.
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import reffits_pb2 as ifs_dot_reffits_dot_reffits__pb2
class RefFitsSrvStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/Find',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsResp.FromString,
)
self.Get = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/Get',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsResp.FromString,
)
self.Read = channel.unary_stream(
'/ifs.reffits.RefFitsSrv/Read',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsResp.FromString,
)
self.Write = channel.stream_unary(
'/ifs.reffits.RefFitsSrv/Write',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsResp.FromString,
)
self.UpdateStatus = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/UpdateStatus',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusResp.FromString,
)
class RefFitsSrvServicer(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 Read(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_iterator, 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 UpdateStatus(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_RefFitsSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsResp.SerializeToString,
),
'Read': grpc.unary_stream_rpc_method_handler(
servicer.Read,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsResp.SerializeToString,
),
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsResp.SerializeToString,
),
'UpdateStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateStatus,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'ifs.reffits.RefFitsSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
This diff is collapsed.
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment