Commit 66d96545 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

rm module level1

parent 5c953105
This diff is collapsed.
# 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)
This diff is collapsed.
# 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 level1_pb2 as msc_dot_level1_dot_level1__pb2
from . import level1_pb2 as facility_dot_level1_dot_level1__pb2
class Level1SrvStub(object):
......@@ -14,34 +14,34 @@ class Level1SrvStub(object):
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.msc.level1.Level1Srv/Find',
request_serializer=msc_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=msc_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
'/dfs.facility.level1.Level1Srv/Find',
request_serializer=facility_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=facility_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
)
self.FindByBrickIds = channel.unary_unary(
'/dfs.msc.level1.Level1Srv/FindByBrickIds',
request_serializer=msc_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
response_deserializer=msc_dot_level1_dot_level1__pb2.FindByBrickIdsResp.FromString,
'/dfs.facility.level1.Level1Srv/FindByBrickIds',
request_serializer=facility_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
response_deserializer=facility_dot_level1_dot_level1__pb2.FindByBrickIdsResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.msc.level1.Level1Srv/Get',
request_serializer=msc_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
response_deserializer=msc_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
'/dfs.facility.level1.Level1Srv/Get',
request_serializer=facility_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
response_deserializer=facility_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
)
self.Write = channel.stream_unary(
'/dfs.msc.level1.Level1Srv/Write',
request_serializer=msc_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
response_deserializer=msc_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
'/dfs.facility.level1.Level1Srv/Write',
request_serializer=facility_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
response_deserializer=facility_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
)
self.UpdateQc1Status = channel.unary_unary(
'/dfs.msc.level1.Level1Srv/UpdateQc1Status',
request_serializer=msc_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=msc_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
'/dfs.facility.level1.Level1Srv/UpdateQc1Status',
request_serializer=facility_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=facility_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.msc.level1.Level1Srv/UpdateProcStatus',
request_serializer=msc_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=msc_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
'/dfs.facility.level1.Level1Srv/UpdateProcStatus',
request_serializer=facility_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=facility_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
)
......@@ -89,37 +89,37 @@ def add_Level1SrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=msc_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=msc_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString,
request_deserializer=facility_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=facility_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString,
),
'FindByBrickIds': grpc.unary_unary_rpc_method_handler(
servicer.FindByBrickIds,
request_deserializer=msc_dot_level1_dot_level1__pb2.FindByBrickIdsReq.FromString,
response_serializer=msc_dot_level1_dot_level1__pb2.FindByBrickIdsResp.SerializeToString,
request_deserializer=facility_dot_level1_dot_level1__pb2.FindByBrickIdsReq.FromString,
response_serializer=facility_dot_level1_dot_level1__pb2.FindByBrickIdsResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=msc_dot_level1_dot_level1__pb2.GetLevel1Req.FromString,
response_serializer=msc_dot_level1_dot_level1__pb2.GetLevel1Resp.SerializeToString,
request_deserializer=facility_dot_level1_dot_level1__pb2.GetLevel1Req.FromString,
response_serializer=facility_dot_level1_dot_level1__pb2.GetLevel1Resp.SerializeToString,
),
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=msc_dot_level1_dot_level1__pb2.WriteLevel1Req.FromString,
response_serializer=msc_dot_level1_dot_level1__pb2.WriteLevel1Resp.SerializeToString,
request_deserializer=facility_dot_level1_dot_level1__pb2.WriteLevel1Req.FromString,
response_serializer=facility_dot_level1_dot_level1__pb2.WriteLevel1Resp.SerializeToString,
),
'UpdateQc1Status': grpc.unary_unary_rpc_method_handler(
servicer.UpdateQc1Status,
request_deserializer=msc_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.FromString,
response_serializer=msc_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.SerializeToString,
request_deserializer=facility_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.FromString,
response_serializer=facility_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=msc_dot_level1_dot_level1__pb2.UpdateProcStatusReq.FromString,
response_serializer=msc_dot_level1_dot_level1__pb2.UpdateProcStatusResp.SerializeToString,
request_deserializer=facility_dot_level1_dot_level1__pb2.UpdateProcStatusReq.FromString,
response_serializer=facility_dot_level1_dot_level1__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.msc.level1.Level1Srv', rpc_method_handlers)
'dfs.facility.level1.Level1Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
......@@ -137,9 +137,9 @@ class Level1Srv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.msc.level1.Level1Srv/Find',
msc_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
msc_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1.Level1Srv/Find',
facility_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
facility_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -153,9 +153,9 @@ class Level1Srv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.msc.level1.Level1Srv/FindByBrickIds',
msc_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
msc_dot_level1_dot_level1__pb2.FindByBrickIdsResp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1.Level1Srv/FindByBrickIds',
facility_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
facility_dot_level1_dot_level1__pb2.FindByBrickIdsResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -169,9 +169,9 @@ class Level1Srv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.msc.level1.Level1Srv/Get',
msc_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
msc_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1.Level1Srv/Get',
facility_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
facility_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -185,9 +185,9 @@ class Level1Srv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.stream_unary(request_iterator, target, '/dfs.msc.level1.Level1Srv/Write',
msc_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
msc_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
return grpc.experimental.stream_unary(request_iterator, target, '/dfs.facility.level1.Level1Srv/Write',
facility_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
facility_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -201,9 +201,9 @@ class Level1Srv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.msc.level1.Level1Srv/UpdateQc1Status',
msc_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
msc_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1.Level1Srv/UpdateQc1Status',
facility_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
facility_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -217,8 +217,8 @@ class Level1Srv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.msc.level1.Level1Srv/UpdateProcStatus',
msc_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
msc_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1.Level1Srv/UpdateProcStatus',
facility_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
facility_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 mci_dot_level1prc_dot_level1prc__pb2
from . import level1prc_pb2 as facility_dot_level1prc_dot_level1prc__pb2
class Level1PrcSrvStub(object):
......@@ -14,19 +14,19 @@ class Level1PrcSrvStub(object):
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.mci.level1prc.Level1PrcSrv/Find',
request_serializer=mci_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
response_deserializer=mci_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
'/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,
)
self.Write = channel.unary_unary(
'/dfs.mci.level1prc.Level1PrcSrv/Write',
request_serializer=mci_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
response_deserializer=mci_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
'/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,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.mci.level1prc.Level1PrcSrv/UpdateProcStatus',
request_serializer=mci_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=mci_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
'/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,
)
......@@ -56,22 +56,22 @@ def add_Level1PrcSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=mci_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.FromString,
response_serializer=mci_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.SerializeToString,
request_deserializer=facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.FromString,
response_serializer=facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=mci_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.FromString,
response_serializer=mci_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.SerializeToString,
request_deserializer=facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.FromString,
response_serializer=facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=mci_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=mci_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.SerializeToString,
request_deserializer=facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.mci.level1prc.Level1PrcSrv', rpc_method_handlers)
'dfs.facility.level1prc.Level1PrcSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
......@@ -89,9 +89,9 @@ class Level1PrcSrv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.mci.level1prc.Level1PrcSrv/Find',
mci_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
mci_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1prc.Level1PrcSrv/Find',
facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
facility_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -105,9 +105,9 @@ class Level1PrcSrv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.mci.level1prc.Level1PrcSrv/Write',
mci_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
mci_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1prc.Level1PrcSrv/Write',
facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
facility_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
......@@ -121,8 +121,8 @@ class Level1PrcSrv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.mci.level1prc.Level1PrcSrv/UpdateProcStatus',
mci_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
mci_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
return grpc.experimental.unary_unary(request, target, '/dfs.facility.level1prc.Level1PrcSrv/UpdateProcStatus',
facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
This diff is collapsed.
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import level1_pb2 as hstdm_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.hstdm.level1.Level1Srv/Find',
request_serializer=hstdm_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=hstdm_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.hstdm.level1.Level1Srv/Get',
request_serializer=hstdm_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
response_deserializer=hstdm_dot_level1_dot_level1__pb2.GetLevel1Resp.FromString,
)
self.Write = channel.stream_unary(
'/dfs.hstdm.level1.Level1Srv/Write',
request_serializer=hstdm_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
response_deserializer=hstdm_dot_level1_dot_level1__pb2.WriteLevel1Resp.FromString,
)
self.UpdateQc1Status = channel.unary_unary(
'/dfs.hstdm.level1.Level1Srv/UpdateQc1Status',
request_serializer=hstdm_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
response_deserializer=hstdm_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.hstdm.level1.Level1Srv/UpdateProcStatus',
request_serializer=hstdm_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=hstdm_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=hstdm_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=hstdm_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=hstdm_dot_level1_dot_level1__pb2.GetLevel1Req.FromString,
response_serializer=hstdm_dot_level1_dot_level1__pb2.GetLevel1Resp.SerializeToString,
),
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=hstdm_dot_level1_dot_level1__pb2.WriteLevel1Req.FromString,
response_serializer=hstdm_dot_level1_dot_level1__pb2.WriteLevel1Resp.SerializeToString,
),
'UpdateQc1Status': grpc.unary_unary_rpc_method_handler(
servicer.UpdateQc1Status,
request_deserializer=hstdm_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.FromString,
response_serializer=hstdm_dot_level1_dot_level1__pb2.UpdateQc1StatusResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=hstdm_dot_level1_dot_level1__pb2.UpdateProcStatusReq.FromString,
response_serializer=hstdm_dot_level1_dot_level1__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.hstdm.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.hstdm.level1.Level1Srv/Find',
hstdm_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
hstdm_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.hstdm.level1.Level1Srv/Get',
hstdm_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
hstdm_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.hstdm.level1.Level1Srv/Write',
hstdm_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
hstdm_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.hstdm.level1.Level1Srv/UpdateQc1Status',
hstdm_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
hstdm_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.hstdm.level1.Level1Srv/UpdateProcStatus',
hstdm_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
hstdm_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 hstdm_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.hstdm.level1prc.Level1PrcSrv/Find',
request_serializer=hstdm_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
response_deserializer=hstdm_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.hstdm.level1prc.Level1PrcSrv/Write',
request_serializer=hstdm_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
response_deserializer=hstdm_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.FromString,
)
self.UpdateProcStatus = channel.unary_unary(
'/dfs.hstdm.level1prc.Level1PrcSrv/UpdateProcStatus',
request_serializer=hstdm_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=hstdm_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=hstdm_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.FromString,
response_serializer=hstdm_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=hstdm_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.FromString,
response_serializer=hstdm_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcResp.SerializeToString,
),
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=hstdm_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.FromString,
response_serializer=hstdm_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.hstdm.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.hstdm.level1prc.Level1PrcSrv/Find',
hstdm_dot_level1prc_dot_level1prc__pb2.FindLevel1PrcReq.SerializeToString,
hstdm_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.hstdm.level1prc.Level1PrcSrv/Write',
hstdm_dot_level1prc_dot_level1prc__pb2.WriteLevel1PrcReq.SerializeToString,
hstdm_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.hstdm.level1prc.Level1PrcSrv/UpdateProcStatus',
hstdm_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusReq.SerializeToString,
hstdm_dot_level1prc_dot_level1prc__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
This diff is collapsed.
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