Skip to content
GitLab
Commit 1cc6a2e1 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

brick

parent 10c0dd8c
Expand all Show whitespace changes
Inline Side-by-side
csst_dfs_proto/facility/brick/brick_pb2.py 0 → 100644
View file @ 1cc6a2e1
This diff is collapsed.
csst_dfs_proto/facility/brick/brick_pb2_grpc.py 0 → 100644
View file @ 1cc6a2e1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import brick_pb2 as facility_dot_brick_dot_brick__pb2
class BrickSrvStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Find',
request_serializer=facility_dot_brick_dot_brick__pb2.FindBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindBrickResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Get',
request_serializer=facility_dot_brick_dot_brick__pb2.GetBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.GetBrickResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Write',
request_serializer=facility_dot_brick_dot_brick__pb2.WriteBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.WriteBrickResp.FromString,
)
self.FindObsStatus = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/FindObsStatus',
request_serializer=facility_dot_brick_dot_brick__pb2.FindObsStatusReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindObsStatusResp.FromString,
)
self.FindLevel1 = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/FindLevel1',
request_serializer=facility_dot_brick_dot_brick__pb2.FindLevel1Req.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindLevel1Resp.FromString,
)
class BrickSrvServicer(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 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 FindObsStatus(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 FindLevel1(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_BrickSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindBrickResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=facility_dot_brick_dot_brick__pb2.GetBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.GetBrickResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=facility_dot_brick_dot_brick__pb2.WriteBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.WriteBrickResp.SerializeToString,
),
'FindObsStatus': grpc.unary_unary_rpc_method_handler(
servicer.FindObsStatus,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindObsStatusReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindObsStatusResp.SerializeToString,
),
'FindLevel1': grpc.unary_unary_rpc_method_handler(
servicer.FindLevel1,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindLevel1Req.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindLevel1Resp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.brick.BrickSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/facility/level2producer/level2producer_pb2.py 0 → 100644
View file @ 1cc6a2e1
This diff is collapsed.
csst_dfs_proto/facility/level2producer/level2producer_pb2_grpc.py 0 → 100644
View file @ 1cc6a2e1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level2producer_pb2 as facility_dot_level2producer_dot_level2producer__pb2
class Level2ProducerSrvStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Register = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/Register',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.RegisterReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.RegisterResp.FromString,
)
self.Find = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/Find',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindResp.FromString,
)
self.FindNexts = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/FindNexts',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindNextsReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindNextsResp.FromString,
)
self.FindStart = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/FindStart',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindStartReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindStartResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/Get',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.GetReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.GetResp.FromString,
)
self.Update = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/Update',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateResp.FromString,
)
self.Delete = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/Delete',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.DeleteReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.DeleteResp.FromString,
)
self.NewJob = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/NewJob',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.NewJobReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.NewJobResp.FromString,
)
self.GetJob = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/GetJob',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.GetJobReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.GetJobResp.FromString,
)
self.UpdateJob = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/UpdateJob',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateJobReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateJobResp.FromString,
)
self.WriteRunning = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/WriteRunning',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.WriteRunningReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.WriteRunningResp.FromString,
)
self.GetRunning = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/GetRunning',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.GetRunningReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.GetRunningResp.FromString,
)
self.UpdateRunning = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/UpdateRunning',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateRunningReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateRunningResp.FromString,
)
self.FindRunning = channel.unary_unary(
'/dfs.facility.level2producer.Level2ProducerSrv/FindRunning',
request_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindRunningReq.SerializeToString,
response_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindRunningResp.FromString,
)
class Level2ProducerSrvServicer(object):
# missing associated documentation comment in .proto file
pass
def Register(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 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 FindNexts(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 FindStart(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 Update(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 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 NewJob(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 GetJob(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 UpdateJob(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 WriteRunning(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 GetRunning(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 UpdateRunning(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 FindRunning(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_Level2ProducerSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Register': grpc.unary_unary_rpc_method_handler(
servicer.Register,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.RegisterReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.RegisterResp.SerializeToString,
),
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindResp.SerializeToString,
),
'FindNexts': grpc.unary_unary_rpc_method_handler(
servicer.FindNexts,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindNextsReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindNextsResp.SerializeToString,
),
'FindStart': grpc.unary_unary_rpc_method_handler(
servicer.FindStart,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindStartReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindStartResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.GetReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.GetResp.SerializeToString,
),
'Update': grpc.unary_unary_rpc_method_handler(
servicer.Update,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateResp.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.DeleteReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.DeleteResp.SerializeToString,
),
'NewJob': grpc.unary_unary_rpc_method_handler(
servicer.NewJob,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.NewJobReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.NewJobResp.SerializeToString,
),
'GetJob': grpc.unary_unary_rpc_method_handler(
servicer.GetJob,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.GetJobReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.GetJobResp.SerializeToString,
),
'UpdateJob': grpc.unary_unary_rpc_method_handler(
servicer.UpdateJob,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateJobReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateJobResp.SerializeToString,
),
'WriteRunning': grpc.unary_unary_rpc_method_handler(
servicer.WriteRunning,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.WriteRunningReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.WriteRunningResp.SerializeToString,
),
'GetRunning': grpc.unary_unary_rpc_method_handler(
servicer.GetRunning,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.GetRunningReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.GetRunningResp.SerializeToString,
),
'UpdateRunning': grpc.unary_unary_rpc_method_handler(
servicer.UpdateRunning,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateRunningReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.UpdateRunningResp.SerializeToString,
),
'FindRunning': grpc.unary_unary_rpc_method_handler(
servicer.FindRunning,
request_deserializer=facility_dot_level2producer_dot_level2producer__pb2.FindRunningReq.FromString,
response_serializer=facility_dot_level2producer_dot_level2producer__pb2.FindRunningResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.level2producer.Level2ProducerSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/facility/calmerge/calmerge_pb2_grpc.py → csst_dfs_proto/ifs/calmerge/calmerge_pb2_grpc.py
View file @ 1cc6a2e1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import calmerge_pb2 as facility_dot_calmerge_dot_calmerge__pb2
from . import calmerge_pb2 as ifs_dot_calmerge_dot_calmerge__pb2
class CalMergeSrvStub(object):
......@@ -15,34 +15,34 @@ class CalMergeSrvStub(object):
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.calmerge.CalMergeSrv/Find',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.FromString,
'/dfs.ifs.calmerge.CalMergeSrv/Find',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.FromString,
)
self.GetLatestByL0 = channel.unary_unary(
'/dfs.facility.calmerge.CalMergeSrv/GetLatestByL0',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Req.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Resp.FromString,
'/dfs.ifs.calmerge.CalMergeSrv/GetLatestByL0',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Req.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Resp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.calmerge.CalMergeSrv/Get',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.FromString,
'/dfs.ifs.calmerge.CalMergeSrv/Get',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.calmerge.CalMergeSrv/Write',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.FromString,
'/dfs.ifs.calmerge.CalMergeSrv/Write',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.FromString,
)
self.UpdateQc1Status = channel.unary_unary(
'/dfs.facility.calmerge.CalMergeSrv/UpdateQc1Status',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.FromString,
'/dfs.ifs.calmerge.CalMergeSrv/UpdateQc1Status',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.facility.calmerge.CalMergeSrv/UpdateProcStatus',
request_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString,
'/dfs.ifs.calmerge.CalMergeSrv/UpdateProcStatus',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString,
)
......@@ -97,35 +97,35 @@ def add_CalMergeSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.FromString,
response_serializer=facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.SerializeToString,
request_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.FromString,
response_serializer=ifs_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.SerializeToString,
),
'GetLatestByL0': grpc.unary_unary_rpc_method_handler(
servicer.GetLatestByL0,
request_deserializer=facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Req.FromString,
response_serializer=facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Resp.SerializeToString,
request_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Req.FromString,
response_serializer=ifs_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Resp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.FromString,
response_serializer=facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.SerializeToString,
request_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.FromString,
response_serializer=ifs_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.FromString,
response_serializer=facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.SerializeToString,
request_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.FromString,
response_serializer=ifs_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.SerializeToString,
),
'UpdateQc1Status': grpc.unary_unary_rpc_method_handler(
servicer.UpdateQc1Status,
request_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.FromString,
response_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.SerializeToString,
request_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.FromString,
response_serializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.FromString,
response_serializer=facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.SerializeToString,
request_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.FromString,
response_serializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.calmerge.CalMergeSrv', rpc_method_handlers)
'dfs.ifs.calmerge.CalMergeSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/ifs/level0/level0_pb2.py 0 → 100644
View file @ 1cc6a2e1
This diff is collapsed.
csst_dfs_proto/facility/level0/level0_pb2_grpc.py → csst_dfs_proto/ifs/level0/level0_pb2_grpc.py
View file @ 1cc6a2e1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level0_pb2 as facility_dot_level0_dot_level0__pb2
from . import level0_pb2 as ifs_dot_level0_dot_level0__pb2
class Level0SrvStub(object):
......@@ -15,29 +15,29 @@ class Level0SrvStub(object):
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/Find',
request_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString,
'/dfs.ifs.level0.Level0Srv/Find',
request_serializer=ifs_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
response_deserializer=ifs_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/Get',
request_serializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString,
'/dfs.ifs.level0.Level0Srv/Get',
request_serializer=ifs_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
response_deserializer=ifs_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/Write',
request_serializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataResp.FromString,
'/dfs.ifs.level0.Level0Srv/Write',
request_serializer=ifs_dot_level0_dot_level0__pb2.WriteLevel0DataReq.SerializeToString,
response_deserializer=ifs_dot_level0_dot_level0__pb2.WriteLevel0DataResp.FromString,
)
self.UpdateQc0Status = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/UpdateQc0Status',
request_serializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.FromString,
'/dfs.ifs.level0.Level0Srv/UpdateQc0Status',
request_serializer=ifs_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString,
response_deserializer=ifs_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/UpdateProcStatus',
request_serializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString,
'/dfs.ifs.level0.Level0Srv/UpdateProcStatus',
request_serializer=ifs_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString,
)
......@@ -85,30 +85,30 @@ 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,
request_deserializer=ifs_dot_level0_dot_level0__pb2.FindLevel0DataReq.FromString,
response_serializer=ifs_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,
request_deserializer=ifs_dot_level0_dot_level0__pb2.GetLevel0DataReq.FromString,
response_serializer=ifs_dot_level0_dot_level0__pb2.GetLevel0DataResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataReq.FromString,
response_serializer=facility_dot_level0_dot_level0__pb2.WriteLevel0DataResp.SerializeToString,
request_deserializer=ifs_dot_level0_dot_level0__pb2.WriteLevel0DataReq.FromString,
response_serializer=ifs_dot_level0_dot_level0__pb2.WriteLevel0DataResp.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,
request_deserializer=ifs_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.FromString,
response_serializer=ifs_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,
request_deserializer=ifs_dot_level0_dot_level0__pb2.UpdateProcStatusReq.FromString,
response_serializer=ifs_dot_level0_dot_level0__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.level0.Level0Srv', rpc_method_handlers)
'dfs.ifs.level0.Level0Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/facility/level0prc/level0prc_pb2_grpc.py → csst_dfs_proto/ifs/level0prc/level0prc_pb2_grpc.py
View file @ 1cc6a2e1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level0prc_pb2 as facility_dot_level0prc_dot_level0prc__pb2
from . import level0prc_pb2 as ifs_dot_level0prc_dot_level0prc__pb2
class Level0PrcSrvStub(object):
......@@ -15,19 +15,19 @@ class Level0PrcSrvStub(object):
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.level0prc.Level0PrcSrv/Find',
request_serializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString,
response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString,
'/dfs.ifs.level0prc.Level0PrcSrv/Find',
request_serializer=ifs_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString,
response_deserializer=ifs_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.level0prc.Level0PrcSrv/Write',
request_serializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString,
response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.FromString,
'/dfs.ifs.level0prc.Level0PrcSrv/Write',
request_serializer=ifs_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString,
response_deserializer=ifs_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.facility.level0prc.Level0PrcSrv/UpdateProcStatus',
request_serializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString,
'/dfs.ifs.level0prc.Level0PrcSrv/UpdateProcStatus',
request_serializer=ifs_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString,
)
......@@ -61,20 +61,20 @@ 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,
request_deserializer=ifs_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.FromString,
response_serializer=ifs_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,
request_deserializer=ifs_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.FromString,
response_serializer=ifs_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,
request_deserializer=ifs_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=ifs_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.level0prc.Level0PrcSrv', rpc_method_handlers)
'dfs.ifs.level0prc.Level0PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/facility/level1prc/level1prc_pb2_grpc.py → csst_dfs_proto/ifs/level1prc/level1prc_pb2_grpc.py
View file @ 1cc6a2e1
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level1prc_pb2 as facility_dot_level1prc_dot_level1prc__pb2
from . import level1prc_pb2 as ifs_dot_level1prc_dot_level1prc__pb2
class Level1PrcSrvStub(object):
......@@ -15,19 +15,19 @@ class Level1PrcSrvStub(object):
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.level1prc.Level1PrcSrv/Find',
request_serializer=facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
response_deserializer=facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
'/dfs.ifs.level1prc.Level1PrcSrv/Find',
request_serializer=ifs_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
response_deserializer=ifs_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.level1prc.Level1PrcSrv/Write',
request_serializer=facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
response_deserializer=facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
'/dfs.ifs.level1prc.Level1PrcSrv/Write',
request_serializer=ifs_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
response_deserializer=ifs_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.facility.level1prc.Level1PrcSrv/UpdateProcStatus',
request_serializer=facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
'/dfs.ifs.level1prc.Level1PrcSrv/UpdateProcStatus',
request_serializer=ifs_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
)
......@@ -61,20 +61,20 @@ def add_Level1PrcSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.FromString,
response_serializer=facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.SerializeToString,
request_deserializer=ifs_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.FromString,
response_serializer=ifs_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.FromString,
response_serializer=facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.SerializeToString,
request_deserializer=ifs_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.FromString,
response_serializer=ifs_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.SerializeToString,
request_deserializer=ifs_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=ifs_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.level1prc.Level1PrcSrv', rpc_method_handlers)
'dfs.ifs.level1prc.Level1PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/msc/calmerge/calmerge_pb2.py 0 → 100644
View file @ 1cc6a2e1
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