Skip to content
GitLab
Commit 28e2587c authored by Wei Shoulin's avatar Wei Shoulin
Browse files

➕ FindByPrcStatus

parent 677bd945
Hide whitespace changes
Inline Side-by-side
csst_dfs_proto/sls/level1/level1_pb2.py
View file @ 28e2587c
...@@ -19,7 +19,7 @@ DESCRIPTOR = _descriptor.FileDescriptor( ...@@ -19,7 +19,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='dfs.sls.level1', package='dfs.sls.level1',
syntax='proto3', syntax='proto3',
serialized_options=b'Z\037cnlab.net/csst/proto/sls/level1', serialized_options=b'Z\037cnlab.net/csst/proto/sls/level1',
serialized_pb=b'\n\x17sls/level1/level1.proto\x12\x0e\x64\x66s.sls.level1\x1a\x12\x63ommon/error.proto\"\xe2\x02\n\x0cLevel1Record\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel0_id\x18\x02 \x01(\t\x12\x11\n\tdata_type\x18\x03 \x01(\t\x12\x12\n\nprc_params\x18\x04 \x01(\t\x12\x0e\n\x06\x66ilter\x18\x05 \x01(\t\x12\x10\n\x08\x66ilename\x18\x06 \x01(\t\x12\x11\n\tfile_path\x18\x07 \x01(\t\x12\x12\n\nqc1_status\x18\x08 \x01(\x05\x12\x10\n\x08qc1_time\x18\t \x01(\t\x12\x12\n\nprc_status\x18\n \x01(\x05\x12\x10\n\x08prc_time\x18\x0b \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x0c \x01(\t\x12\x13\n\x0bpipeline_id\x18\r \x01(\t\x12\x34\n\x04refs\x18\x0e \x03(\x0b\x32&.dfs.sls.level1.Level1Record.RefsEntry\x1a+\n\tRefsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\"\xb8\x02\n\rFindLevel1Req\x12\x11\n\tlevel0_id\x18\x01 \x01(\t\x12\x11\n\tdata_type\x18\x02 \x01(\t\x12\x19\n\x11\x63reate_time_start\x18\x03 \x01(\t\x12\x17\n\x0f\x63reate_time_end\x18\x04 \x01(\t\x12\x12\n\nqc1_status\x18\x05 \x01(\x05\x12\x12\n\nprc_status\x18\x06 \x01(\x05\x12\x10\n\x08\x66ilename\x18\x07 \x01(\t\x12\r\n\x05limit\x18\x08 \x01(\x05\x12L\n\x10other_conditions\x18\t \x03(\x0b\x32\x32.dfs.sls.level1.FindLevel1Req.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x82\x01\n\x0e\x46indLevel1Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12-\n\x07records\x18\x04 \x03(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"&\n\x11\x46indByBrickIdsReq\x12\x11\n\tbrick_ids\x18\x01 \x03(\x05\"r\n\x12\x46indByBrickIdsResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12-\n\x07records\x18\x03 \x03(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"@\n\x0cGetLevel1Req\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel0_id\x18\x02 \x01(\t\x12\x11\n\tdata_type\x18\x03 \x01(\t\"=\n\rGetLevel1Resp\x12,\n\x06record\x18\x01 \x01(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"L\n\x0eWriteLevel1Req\x12,\n\x06record\x18\x01 \x01(\x0b\x32\x1c.dfs.sls.level1.Level1Record\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"n\n\x0fWriteLevel1Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12,\n\x06record\x18\x03 \x01(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"0\n\x12UpdateQc1StatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"D\n\x13UpdateQc1StatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\"1\n\x13UpdateProcStatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\x82\x04\n\tLevel1Srv\x12G\n\x04\x46ind\x12\x1d.dfs.sls.level1.FindLevel1Req\x1a\x1e.dfs.sls.level1.FindLevel1Resp\"\x00\x12Y\n\x0e\x46indByBrickIds\x12!.dfs.sls.level1.FindByBrickIdsReq\x1a\".dfs.sls.level1.FindByBrickIdsResp\"\x00\x12\x44\n\x03Get\x12\x1c.dfs.sls.level1.GetLevel1Req\x1a\x1d.dfs.sls.level1.GetLevel1Resp\"\x00\x12L\n\x05Write\x12\x1e.dfs.sls.level1.WriteLevel1Req\x1a\x1f.dfs.sls.level1.WriteLevel1Resp\"\x00(\x01\x12\\\n\x0fUpdateQc1Status\x12\".dfs.sls.level1.UpdateQc1StatusReq\x1a#.dfs.sls.level1.UpdateQc1StatusResp\"\x00\x12_\n\x10UpdateProcStatus\x12#.dfs.sls.level1.UpdateProcStatusReq\x1a$.dfs.sls.level1.UpdateProcStatusResp\"\x00\x42!Z\x1f\x63nlab.net/csst/proto/sls/level1b\x06proto3' serialized_pb=b'\n\x17sls/level1/level1.proto\x12\x0e\x64\x66s.sls.level1\x1a\x12\x63ommon/error.proto\"\xe2\x02\n\x0cLevel1Record\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel0_id\x18\x02 \x01(\t\x12\x11\n\tdata_type\x18\x03 \x01(\t\x12\x12\n\nprc_params\x18\x04 \x01(\t\x12\x0e\n\x06\x66ilter\x18\x05 \x01(\t\x12\x10\n\x08\x66ilename\x18\x06 \x01(\t\x12\x11\n\tfile_path\x18\x07 \x01(\t\x12\x12\n\nqc1_status\x18\x08 \x01(\x05\x12\x10\n\x08qc1_time\x18\t \x01(\t\x12\x12\n\nprc_status\x18\n \x01(\x05\x12\x10\n\x08prc_time\x18\x0b \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x0c \x01(\t\x12\x13\n\x0bpipeline_id\x18\r \x01(\t\x12\x34\n\x04refs\x18\x0e \x03(\x0b\x32&.dfs.sls.level1.Level1Record.RefsEntry\x1a+\n\tRefsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03:\x02\x38\x01\"\xb8\x02\n\rFindLevel1Req\x12\x11\n\tlevel0_id\x18\x01 \x01(\t\x12\x11\n\tdata_type\x18\x02 \x01(\t\x12\x19\n\x11\x63reate_time_start\x18\x03 \x01(\t\x12\x17\n\x0f\x63reate_time_end\x18\x04 \x01(\t\x12\x12\n\nqc1_status\x18\x05 \x01(\x05\x12\x12\n\nprc_status\x18\x06 \x01(\x05\x12\x10\n\x08\x66ilename\x18\x07 \x01(\t\x12\r\n\x05limit\x18\x08 \x01(\x05\x12L\n\x10other_conditions\x18\t \x03(\x0b\x32\x32.dfs.sls.level1.FindLevel1Req.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x82\x01\n\x0e\x46indLevel1Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12-\n\x07records\x18\x04 \x03(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"&\n\x11\x46indByBrickIdsReq\x12\x11\n\tbrick_ids\x18\x01 \x03(\x05\"r\n\x12\x46indByBrickIdsResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12-\n\x07records\x18\x03 \x03(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"@\n\x0cGetLevel1Req\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel0_id\x18\x02 \x01(\t\x12\x11\n\tdata_type\x18\x03 \x01(\t\"=\n\rGetLevel1Resp\x12,\n\x06record\x18\x01 \x01(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"L\n\x0eWriteLevel1Req\x12,\n\x06record\x18\x01 \x01(\x0b\x32\x1c.dfs.sls.level1.Level1Record\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\"n\n\x0fWriteLevel1Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12,\n\x06record\x18\x03 \x01(\x0b\x32\x1c.dfs.sls.level1.Level1Record\"0\n\x12UpdateQc1StatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"D\n\x13UpdateQc1StatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\"1\n\x13UpdateProcStatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xd6\x04\n\tLevel1Srv\x12G\n\x04\x46ind\x12\x1d.dfs.sls.level1.FindLevel1Req\x1a\x1e.dfs.sls.level1.FindLevel1Resp\"\x00\x12R\n\x0f\x46indByPrcStatus\x12\x1d.dfs.sls.level1.FindLevel1Req\x1a\x1e.dfs.sls.level1.FindLevel1Resp\"\x00\x12Y\n\x0e\x46indByBrickIds\x12!.dfs.sls.level1.FindByBrickIdsReq\x1a\".dfs.sls.level1.FindByBrickIdsResp\"\x00\x12\x44\n\x03Get\x12\x1c.dfs.sls.level1.GetLevel1Req\x1a\x1d.dfs.sls.level1.GetLevel1Resp\"\x00\x12L\n\x05Write\x12\x1e.dfs.sls.level1.WriteLevel1Req\x1a\x1f.dfs.sls.level1.WriteLevel1Resp\"\x00(\x01\x12\\\n\x0fUpdateQc1Status\x12\".dfs.sls.level1.UpdateQc1StatusReq\x1a#.dfs.sls.level1.UpdateQc1StatusResp\"\x00\x12_\n\x10UpdateProcStatus\x12#.dfs.sls.level1.UpdateProcStatusReq\x1a$.dfs.sls.level1.UpdateProcStatusResp\"\x00\x42!Z\x1f\x63nlab.net/csst/proto/sls/level1b\x06proto3'
, ,
dependencies=[common_dot_error__pb2.DESCRIPTOR,]) dependencies=[common_dot_error__pb2.DESCRIPTOR,])
...@@ -895,7 +895,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor( ...@@ -895,7 +895,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor(
index=0, index=0,
serialized_options=None, serialized_options=None,
serialized_start=1586, serialized_start=1586,
serialized_end=2100, serialized_end=2184,
methods=[ methods=[
_descriptor.MethodDescriptor( _descriptor.MethodDescriptor(
name='Find', name='Find',
...@@ -906,10 +906,19 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor( ...@@ -906,10 +906,19 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor(
output_type=_FINDLEVEL1RESP, output_type=_FINDLEVEL1RESP,
serialized_options=None, serialized_options=None,
), ),
_descriptor.MethodDescriptor(
name='FindByPrcStatus',
full_name='dfs.sls.level1.Level1Srv.FindByPrcStatus',
index=1,
containing_service=None,
input_type=_FINDLEVEL1REQ,
output_type=_FINDLEVEL1RESP,
serialized_options=None,
),
_descriptor.MethodDescriptor( _descriptor.MethodDescriptor(
name='FindByBrickIds', name='FindByBrickIds',
full_name='dfs.sls.level1.Level1Srv.FindByBrickIds', full_name='dfs.sls.level1.Level1Srv.FindByBrickIds',
index=1, index=2,
containing_service=None, containing_service=None,
input_type=_FINDBYBRICKIDSREQ, input_type=_FINDBYBRICKIDSREQ,
output_type=_FINDBYBRICKIDSRESP, output_type=_FINDBYBRICKIDSRESP,
...@@ -918,7 +927,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor( ...@@ -918,7 +927,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor(
_descriptor.MethodDescriptor( _descriptor.MethodDescriptor(
name='Get', name='Get',
full_name='dfs.sls.level1.Level1Srv.Get', full_name='dfs.sls.level1.Level1Srv.Get',
index=2, index=3,
containing_service=None, containing_service=None,
input_type=_GETLEVEL1REQ, input_type=_GETLEVEL1REQ,
output_type=_GETLEVEL1RESP, output_type=_GETLEVEL1RESP,
...@@ -927,7 +936,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor( ...@@ -927,7 +936,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor(
_descriptor.MethodDescriptor( _descriptor.MethodDescriptor(
name='Write', name='Write',
full_name='dfs.sls.level1.Level1Srv.Write', full_name='dfs.sls.level1.Level1Srv.Write',
index=3, index=4,
containing_service=None, containing_service=None,
input_type=_WRITELEVEL1REQ, input_type=_WRITELEVEL1REQ,
output_type=_WRITELEVEL1RESP, output_type=_WRITELEVEL1RESP,
...@@ -936,7 +945,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor( ...@@ -936,7 +945,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor(
_descriptor.MethodDescriptor( _descriptor.MethodDescriptor(
name='UpdateQc1Status', name='UpdateQc1Status',
full_name='dfs.sls.level1.Level1Srv.UpdateQc1Status', full_name='dfs.sls.level1.Level1Srv.UpdateQc1Status',
index=4, index=5,
containing_service=None, containing_service=None,
input_type=_UPDATEQC1STATUSREQ, input_type=_UPDATEQC1STATUSREQ,
output_type=_UPDATEQC1STATUSRESP, output_type=_UPDATEQC1STATUSRESP,
...@@ -945,7 +954,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor( ...@@ -945,7 +954,7 @@ _LEVEL1SRV = _descriptor.ServiceDescriptor(
_descriptor.MethodDescriptor( _descriptor.MethodDescriptor(
name='UpdateProcStatus', name='UpdateProcStatus',
full_name='dfs.sls.level1.Level1Srv.UpdateProcStatus', full_name='dfs.sls.level1.Level1Srv.UpdateProcStatus',
index=5, index=6,
containing_service=None, containing_service=None,
input_type=_UPDATEPROCSTATUSREQ, input_type=_UPDATEPROCSTATUSREQ,
output_type=_UPDATEPROCSTATUSRESP, output_type=_UPDATEPROCSTATUSRESP,
......
csst_dfs_proto/sls/level1/level1_pb2_grpc.py
View file @ 28e2587c
...@@ -18,6 +18,11 @@ class Level1SrvStub(object): ...@@ -18,6 +18,11 @@ class Level1SrvStub(object):
request_serializer=sls_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString, request_serializer=sls_dot_level1_dot_level1__pb2.FindLevel1Req.SerializeToString,
response_deserializer=sls_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString, response_deserializer=sls_dot_level1_dot_level1__pb2.FindLevel1Resp.FromString,
) )
self.FindByPrcStatus = channel.unary_unary(
'/dfs.sls.level1.Level1Srv/FindByPrcStatus',
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( self.FindByBrickIds = channel.unary_unary(
'/dfs.sls.level1.Level1Srv/FindByBrickIds', '/dfs.sls.level1.Level1Srv/FindByBrickIds',
request_serializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString, request_serializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.SerializeToString,
...@@ -54,6 +59,12 @@ class Level1SrvServicer(object): ...@@ -54,6 +59,12 @@ class Level1SrvServicer(object):
context.set_details('Method not implemented!') context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!') raise NotImplementedError('Method not implemented!')
def FindByPrcStatus(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 FindByBrickIds(self, request, context): def FindByBrickIds(self, request, context):
"""Missing associated documentation comment in .proto file""" """Missing associated documentation comment in .proto file"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED) context.set_code(grpc.StatusCode.UNIMPLEMENTED)
...@@ -92,6 +103,11 @@ def add_Level1SrvServicer_to_server(servicer, server): ...@@ -92,6 +103,11 @@ def add_Level1SrvServicer_to_server(servicer, server):
request_deserializer=sls_dot_level1_dot_level1__pb2.FindLevel1Req.FromString, request_deserializer=sls_dot_level1_dot_level1__pb2.FindLevel1Req.FromString,
response_serializer=sls_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString, response_serializer=sls_dot_level1_dot_level1__pb2.FindLevel1Resp.SerializeToString,
), ),
'FindByPrcStatus': grpc.unary_unary_rpc_method_handler(
servicer.FindByPrcStatus,
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( 'FindByBrickIds': grpc.unary_unary_rpc_method_handler(
servicer.FindByBrickIds, servicer.FindByBrickIds,
request_deserializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.FromString, request_deserializer=sls_dot_level1_dot_level1__pb2.FindByBrickIdsReq.FromString,
...@@ -143,6 +159,22 @@ class Level1Srv(object): ...@@ -143,6 +159,22 @@ class Level1Srv(object):
options, channel_credentials, options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata) call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindByPrcStatus(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/FindByPrcStatus',
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 @staticmethod
def FindByBrickIds(request, def FindByBrickIds(request,
target, target,
......
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