Commit 9d8fdc02 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

un level0

parent 5e30dd33
...@@ -11,3 +11,7 @@ This library can be installed with the following command: ...@@ -11,3 +11,7 @@ This library can be installed with the following command:
```bash ```bash
python setup.py install python setup.py install
``` ```
## Delelopment
pip installl grpcio-tools
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level1_pb2 as cpic_dot_level1_dot_level1__pb2
class Level1SrvStub(object):
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.cpic.level1.Level1Srv/Find',
request_serializer=cpic_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=cpic_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.cpic.level1.Level1Srv/Get',
request_serializer=cpic_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
response_deserializer=cpic_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
)
self.Write = channel.stream_unary(
'/dfs.cpic.level1.Level1Srv/Write',
request_serializer=cpic_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
response_deserializer=cpic_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
)
self.UpdateQc1Status = channel.unary_unary(
'/dfs.cpic.level1.Level1Srv/UpdateQc1Status',
request_serializer=cpic_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=cpic_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.cpic.level1.Level1Srv/UpdateProcStatus',
request_serializer=cpic_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=cpic_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
)
class Level1SrvServicer(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 UpdateQc1Status(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_Level1SrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=cpic_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=cpic_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=cpic_dot_level1_dot_level1__pb2.GetLevel1Req.FromString,
response_serializer=cpic_dot_level1_dot_level1__pb2.GetLevel1Resp.SerializeToString,
),
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=cpic_dot_level1_dot_level1__pb2.WriteLevel1Req.FromString,
response_serializer=cpic_dot_level1_dot_level1__pb2.WriteLevel1Resp.SerializeToString,
),
'UpdateQc1Status': grpc.unary_unary_rpc_method_handler(
servicer.UpdateQc1Status,
request_deserializer=cpic_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.FromString,
response_serializer=cpic_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=cpic_dot_level1_dot_level1__pb2.UpdateProcStatusReq.FromString,
response_serializer=cpic_dot_level1_dot_level1__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.cpic.level1.Level1Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class Level1Srv(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.cpic.level1.Level1Srv/Find',
cpic_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
cpic_dot_level1_dot_level1__pb2.FindLevel1Resp.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.cpic.level1.Level1Srv/Get',
cpic_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
cpic_dot_level1_dot_level1__pb2.GetLevel1Resp.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.cpic.level1.Level1Srv/Write',
cpic_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
cpic_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc1Status(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.cpic.level1.Level1Srv/UpdateQc1Status',
cpic_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
cpic_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.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.cpic.level1.Level1Srv/UpdateProcStatus',
cpic_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
cpic_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level1prc_pb2 as cpic_dot_level1prc_dot_level1prc__pb2
class Level1PrcSrvStub(object):
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.cpic.level1prc.Level1PrcSrv/Find',
request_serializer=cpic_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
response_deserializer=cpic_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.cpic.level1prc.Level1PrcSrv/Write',
request_serializer=cpic_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
response_deserializer=cpic_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.cpic.level1prc.Level1PrcSrv/UpdateProcStatus',
request_serializer=cpic_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=cpic_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
)
class Level1PrcSrvServicer(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 Write(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_Level1PrcSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=cpic_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.FromString,
response_serializer=cpic_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=cpic_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.FromString,
response_serializer=cpic_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=cpic_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=cpic_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.cpic.level1prc.Level1PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class Level1PrcSrv(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.cpic.level1prc.Level1PrcSrv/Find',
cpic_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
cpic_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(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.cpic.level1prc.Level1PrcSrv/Write',
cpic_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
cpic_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.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.cpic.level1prc.Level1PrcSrv/UpdateProcStatus',
cpic_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
cpic_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import calmerge_pb2 as facility_dot_calmerge_dot_calmerge__pb2
class CalMergeSrvStub(object):
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
Args:
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,
)
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,
)
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,
)
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,
)
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,
)
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,
)
class CalMergeSrvServicer(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 GetLatestByL0(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, 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 UpdateQc1Status(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_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,
),
'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,
),
'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,
),
'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,
),
'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,
),
'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,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.calmerge.CalMergeSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class CalMergeSrv(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.facility.calmerge.CalMergeSrv/Find',
facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def GetLatestByL0(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.facility.calmerge.CalMergeSrv/GetLatestByL0',
facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Req.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Resp.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.facility.calmerge.CalMergeSrv/Get',
facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(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.facility.calmerge.CalMergeSrv/Write',
facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc1Status(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.facility.calmerge.CalMergeSrv/UpdateQc1Status',
facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.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.facility.calmerge.CalMergeSrv/UpdateProcStatus',
facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
# 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"""
def __init__(self, channel):
"""Constructor.
Args:
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,
)
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,
)
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,
)
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,
)
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,
)
class Level0SrvServicer(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, 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 UpdateQc0Status(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_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,
),
'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,
),
'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(
'dfs.facility.level0.Level0Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class Level0Srv(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.facility.level0.Level0Srv/Find',
facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.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.facility.level0.Level0Srv/Get',
facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(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.facility.level0.Level0Srv/Write',
facility_dot_level0_dot_level0__pb2.WriteLevel0DataReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.WriteLevel0DataResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc0Status(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.facility.level0.Level0Srv/UpdateQc0Status',
facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.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.facility.level0.Level0Srv/UpdateProcStatus',
facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
# 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"""
def __init__(self, channel):
"""Constructor.
Args:
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,
)
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,
)
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,
)
class Level0PrcSrvServicer(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 Write(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_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(
'dfs.facility.level0prc.Level0PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class Level0PrcSrv(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.facility.level0prc.Level0PrcSrv/Find',
facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString,
facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(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.facility.level0prc.Level0PrcSrv/Write',
facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString,
facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.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.facility.level0prc.Level0PrcSrv/UpdateProcStatus',
facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import calmerge_pb2 as ifs_dot_calmerge_dot_calmerge__pb2
class CalMergeSrvStub(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.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.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.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.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.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.ifs.calmerge.CalMergeSrv/UpdateProcStatus',
request_serializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString,
)
class CalMergeSrvServicer(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 GetLatestByL0(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 UpdateQc1Status(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_CalMergeSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
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=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=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=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=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=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.ifs.calmerge.CalMergeSrv', rpc_method_handlers)
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 level0prc_pb2 as ifs_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(
'/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.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.ifs.level0prc.Level0PrcSrv/UpdateProcStatus',
request_serializer=ifs_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_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=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=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=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.ifs.level0prc.Level0PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
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