Skip to content
GitLab
Commit 3c5ee28a authored by Wei Shoulin's avatar Wei Shoulin
Browse files

hstdm

parent 9d8fdc02
Expand all Show whitespace changes
Inline Side-by-side
Showing
with 2677 additions and 396 deletions
+2677 -396
csst_dfs_proto/facility/level0/level0_pb2.py
+ 158
- 48
View file @ 3c5ee28a
This diff is collapsed.
csst_dfs_proto/facility/level0/level0_pb2_grpc.py
+ 32
- 0
View file @ 3c5ee28a
......@@ -18,6 +18,11 @@ class Level0SrvStub(object):
request_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString,
)
self.FindByBrickIds = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/FindByBrickIds',
request_serializer=facility_dot_level0_dot_level0__pb2.FindByBrickIdsReq.SerializeToString,
response_deserializer=facility_dot_level0_dot_level0__pb2.FindByBrickIdsResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.level0.Level0Srv/Get',
request_serializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
......@@ -49,6 +54,12 @@ class Level0SrvServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def FindByBrickIds(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)
......@@ -81,6 +92,11 @@ def add_Level0SrvServicer_to_server(servicer, server):
request_deserializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.FromString,
response_serializer=facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.SerializeToString,
),
'FindByBrickIds': grpc.unary_unary_rpc_method_handler(
servicer.FindByBrickIds,
request_deserializer=facility_dot_level0_dot_level0__pb2.FindByBrickIdsReq.FromString,
response_serializer=facility_dot_level0_dot_level0__pb2.FindByBrickIdsResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.FromString,
......@@ -127,6 +143,22 @@ class Level0Srv(object):
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindByBrickIds(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/FindByBrickIds',
facility_dot_level0_dot_level0__pb2.FindByBrickIdsReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.FindByBrickIdsResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Get(request,
target,
......
csst_dfs_proto/hstdm/level1/__init__.py 0 → 100644
+ 0
- 0
View file @ 3c5ee28a
csst_dfs_proto/hstdm/level1/level1_pb2.py 0 → 100644
+ 856
- 0
View file @ 3c5ee28a
This diff is collapsed.
csst_dfs_proto/hstdm/level1/level1_pb2_grpc.py 0 → 100644
+ 192
- 0
View file @ 3c5ee28a
# 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)
csst_dfs_proto/hstdm/level1prc/__init__.py 0 → 100644
+ 0
- 0
View file @ 3c5ee28a
csst_dfs_proto/hstdm/level1prc/level1prc_pb2.py 0 → 100644
+ 527
- 0
View file @ 3c5ee28a
This diff is collapsed.
csst_dfs_proto/hstdm/level1prc/level1prc_pb2_grpc.py 0 → 100644
+ 128
- 0
View file @ 3c5ee28a
# 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)
csst_dfs_proto/msc/level1/level1_pb2.py
+ 181
- 73
View file @ 3c5ee28a
This diff is collapsed.
csst_dfs_proto/msc/level1/level1_pb2_grpc.py
+ 211
- 101
View file @ 3c5ee28a
......@@ -5,8 +5,7 @@ from . import level1_pb2 as msc_dot_level1_dot_level1__pb2
class Level1SrvStub(object):
# missing associated documentation comment in .proto file
pass
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
......@@ -19,6 +18,11 @@ class Level1SrvStub(object):
request_serializer=msc_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=msc_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,
)
self.Get = channel.unary_unary(
'/dfs.msc.level1.Level1Srv/Get',
request_serializer=msc_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
......@@ -42,40 +46,40 @@ class Level1SrvStub(object):
class Level1SrvServicer(object):
# missing associated documentation comment in .proto file
pass
"""Missing associated documentation comment in .proto file"""
def Find(self, request, context):
# missing associated documentation comment in .proto file
pass
"""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 FindByBrickIds(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
pass
"""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
pass
"""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
pass
"""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
pass
"""Missing associated documentation comment in .proto file"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -88,6 +92,11 @@ def add_Level1SrvServicer_to_server(servicer, server):
request_deserializer=msc_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=msc_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,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=msc_dot_level1_dot_level1__pb2.GetLevel1Req.FromString,
......@@ -112,3 +121,104 @@ def add_Level1SrvServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'dfs.msc.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.msc.level1.Level1Srv/Find',
msc_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
msc_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindByBrickIds(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.msc.level1.Level1Srv/FindByBrickIds',
msc_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
msc_dot_level1_dot_level1__pb2.FindByBrickIdsResp.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.msc.level1.Level1Srv/Get',
msc_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
msc_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.msc.level1.Level1Srv/Write',
msc_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
msc_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.msc.level1.Level1Srv/UpdateQc1Status',
msc_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
msc_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.msc.level1.Level1Srv/UpdateProcStatus',
msc_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
msc_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/sls/level1/level1_pb2.py
+ 181
- 73
View file @ 3c5ee28a
This diff is collapsed.
csst_dfs_proto/sls/level1/level1_pb2_grpc.py
+ 211
- 101
View file @ 3c5ee28a
......@@ -5,8 +5,7 @@ from . import level1_pb2 as sls_dot_level1_dot_level1__pb2
class Level1SrvStub(object):
# missing associated documentation comment in .proto file
pass
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
......@@ -19,6 +18,11 @@ class Level1SrvStub(object):
request_serializer=sls_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=sls_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
)
self.FindByBrickIds = channel.unary_unary(
'/dfs.sls.level1.Level1Srv/FindByBrickIds',
request_serializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
response_deserializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.sls.level1.Level1Srv/Get',
request_serializer=sls_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
......@@ -42,40 +46,40 @@ class Level1SrvStub(object):
class Level1SrvServicer(object):
# missing associated documentation comment in .proto file
pass
"""Missing associated documentation comment in .proto file"""
def Find(self, request, context):
# missing associated documentation comment in .proto file
pass
"""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 FindByBrickIds(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
pass
"""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
pass
"""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
pass
"""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
pass
"""Missing associated documentation comment in .proto file"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -88,6 +92,11 @@ def add_Level1SrvServicer_to_server(servicer, server):
request_deserializer=sls_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=sls_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString,
),
'FindByBrickIds': grpc.unary_unary_rpc_method_handler(
servicer.FindByBrickIds,
request_deserializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.FromString,
response_serializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=sls_dot_level1_dot_level1__pb2.GetLevel1Req.FromString,
......@@ -112,3 +121,104 @@ def add_Level1SrvServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'dfs.sls.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.sls.level1.Level1Srv/Find',
sls_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
sls_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindByBrickIds(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.sls.level1.Level1Srv/FindByBrickIds',
sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
sls_dot_level1_dot_level1__pb2.FindByBrickIdsResp.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.sls.level1.Level1Srv/Get',
sls_dot_level1_dot_level1__pb2.GetLevel1Req.SerializeToString,
sls_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.sls.level1.Level1Srv/Write',
sls_dot_level1_dot_level1__pb2.WriteLevel1Req.SerializeToString,
sls_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.sls.level1.Level1Srv/UpdateQc1Status',
sls_dot_level1_dot_level1__pb2.UpdateQc1StatusReq.SerializeToString,
sls_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.sls.level1.Level1Srv/UpdateProcStatus',
sls_dot_level1_dot_level1__pb2.UpdateProcStatusReq.SerializeToString,
sls_dot_level1_dot_level1__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
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