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

upt

parent 13674342
Hide whitespace changes
Inline Side-by-side
csst_dfs_proto/ifs/fits/fits_pb2.py
View file @ bb745f30
......@@ -13,7 +13,7 @@ from google.protobuf import symbol_database as _symbol_database
_sym_db = _symbol_database.Default()
from common import error_pb2 as common_dot_error__pb2
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor.FileDescriptor(
......@@ -21,7 +21,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='ifs.fits',
syntax='proto3',
serialized_options=_b('Z\035cnlab.net/csst/proto/ifs/fits'),
serialized_pb=_b('\n\x13ifs/fits/fits.proto\x12\x08ifs.fits\x1a\x12\x63ommon/error.proto\"\xd1\x01\n\x07RawFits\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x10\n\x08obs_time\x18\x03 \x01(\r\x12\x10\n\x08\x65xp_time\x18\x04 \x01(\x03\x12\x11\n\tfile_path\x18\x05 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x06 \x01(\r\x12\x12\n\nqc0_status\x18\x07 \x01(\r\x12\x10\n\x08qc0_time\x18\x08 \x01(\x03\x12\x12\n\nprc_status\x18\t \x01(\r\x12\x10\n\x08prc_time\x18\n \x01(\x03\x12\x13\n\x0b\x63reate_time\x18\x0b \x01(\x03\"\x9d\x02\n\x0e\x46indRawFitsReq\x12\x10\n\x08obs_time\x18\x01 \x01(\r\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x16\n\x0e\x65xp_time_start\x18\x03 \x01(\t\x12\x14\n\x0c\x65xp_time_end\x18\x04 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x05 \x01(\r\x12\x12\n\nqc0_status\x18\x06 \x01(\r\x12\x12\n\nprc_status\x18\x07 \x01(\r\x12G\n\x10other_conditions\x18\x08 \x03(\x0b\x32-.ifs.fits.FindRawFitsReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"x\n\x0f\x46indRawFitsResp\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\x07rawFits\x18\x04 \x03(\x0b\x32\x11.ifs.fits.RawFits\" \n\rGetRawFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"4\n\x0eGetRawFitsResp\x12\"\n\x07rawFits\x18\x01 \x01(\x0b\x32\x11.ifs.fits.RawFits\"H\n\x0eReadRawFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadRawFitsResp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"6\n\x0fWriteRawFitsReq\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\x10\n\x08\x66itsData\x18\x02 \x01(\x0c\"e\n\x10WriteRawFitsResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\"\n\x07rawFits\x18\x03 \x01(\x0b\x32\x11.ifs.fits.RawFits\"5\n\x12UpdateQc0StatusReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\r\"D\n\x13UpdateQc0StatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\"6\n\x13UpdateProcStatusReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\r\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xb4\x03\n\x07\x46itsSrv\x12=\n\x04\x66ind\x12\x18.ifs.fits.FindRawFitsReq\x1a\x19.ifs.fits.FindRawFitsResp\"\x00\x12:\n\x03get\x12\x17.ifs.fits.GetRawFitsReq\x1a\x18.ifs.fits.GetRawFitsResp\"\x00\x12?\n\x04read\x12\x18.ifs.fits.ReadRawFitsReq\x1a\x19.ifs.fits.ReadRawFitsResp\"\x00\x30\x01\x12\x42\n\x05write\x12\x19.ifs.fits.WriteRawFitsReq\x1a\x1a.ifs.fits.WriteRawFitsResp\"\x00(\x01\x12R\n\x11update_qc0_status\x12\x1c.ifs.fits.UpdateQc0StatusReq\x1a\x1d.ifs.fits.UpdateQc0StatusResp\"\x00\x12U\n\x12update_proc_status\x12\x1d.ifs.fits.UpdateProcStatusReq\x1a\x1e.ifs.fits.UpdateProcStatusResp\"\x00\x42\x1fZ\x1d\x63nlab.net/csst/proto/ifs/fitsb\x06proto3')
serialized_pb=_b('\n\x13ifs/fits/fits.proto\x12\x08ifs.fits\x1a\x12\x63ommon/error.proto\"\xd1\x01\n\x07RawFits\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x10\n\x08obs_time\x18\x03 \x01(\r\x12\x10\n\x08\x65xp_time\x18\x04 \x01(\x03\x12\x11\n\tfile_path\x18\x05 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x06 \x01(\r\x12\x12\n\nqc0_status\x18\x07 \x01(\r\x12\x10\n\x08qc0_time\x18\x08 \x01(\x03\x12\x12\n\nprc_status\x18\t \x01(\r\x12\x10\n\x08prc_time\x18\n \x01(\x03\x12\x13\n\x0b\x63reate_time\x18\x0b \x01(\x03\"\x9d\x02\n\x0e\x46indRawFitsReq\x12\x10\n\x08obs_time\x18\x01 \x01(\r\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x16\n\x0e\x65xp_time_start\x18\x03 \x01(\t\x12\x14\n\x0c\x65xp_time_end\x18\x04 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x05 \x01(\r\x12\x12\n\nqc0_status\x18\x06 \x01(\r\x12\x12\n\nprc_status\x18\x07 \x01(\r\x12G\n\x10other_conditions\x18\x08 \x03(\x0b\x32-.ifs.fits.FindRawFitsReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"x\n\x0f\x46indRawFitsResp\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\x07rawFits\x18\x04 \x03(\x0b\x32\x11.ifs.fits.RawFits\" \n\rGetRawFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"4\n\x0eGetRawFitsResp\x12\"\n\x07rawFits\x18\x01 \x01(\x0b\x32\x11.ifs.fits.RawFits\"H\n\x0eReadRawFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadRawFitsResp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"6\n\x0fWriteRawFitsReq\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\x10\n\x08\x66itsData\x18\x02 \x01(\x0c\"e\n\x10WriteRawFitsResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\"\n\x07rawFits\x18\x03 \x01(\x0b\x32\x11.ifs.fits.RawFits\"5\n\x12UpdateQc0StatusReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\r\"D\n\x13UpdateQc0StatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\"6\n\x13UpdateProcStatusReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\r\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xb0\x03\n\x07\x46itsSrv\x12=\n\x04\x46ind\x12\x18.ifs.fits.FindRawFitsReq\x1a\x19.ifs.fits.FindRawFitsResp\"\x00\x12:\n\x03Get\x12\x17.ifs.fits.GetRawFitsReq\x1a\x18.ifs.fits.GetRawFitsResp\"\x00\x12?\n\x04Read\x12\x18.ifs.fits.ReadRawFitsReq\x1a\x19.ifs.fits.ReadRawFitsResp\"\x00\x30\x01\x12\x42\n\x05Write\x12\x19.ifs.fits.WriteRawFitsReq\x1a\x1a.ifs.fits.WriteRawFitsResp\"\x00(\x01\x12P\n\x0fUpdateQc0Status\x12\x1c.ifs.fits.UpdateQc0StatusReq\x1a\x1d.ifs.fits.UpdateQc0StatusResp\"\x00\x12S\n\x10UpdateProcStatus\x12\x1d.ifs.fits.UpdateProcStatusReq\x1a\x1e.ifs.fits.UpdateProcStatusResp\"\x00\x42\x1fZ\x1d\x63nlab.net/csst/proto/ifs/fitsb\x06proto3')
,
dependencies=[common_dot_error__pb2.DESCRIPTOR,])
......@@ -804,11 +804,11 @@ _FITSSRV = _descriptor.ServiceDescriptor(
index=0,
serialized_options=None,
serialized_start=1282,
serialized_end=1718,
serialized_end=1714,
methods=[
_descriptor.MethodDescriptor(
name='find',
full_name='ifs.fits.FitsSrv.find',
name='Find',
full_name='ifs.fits.FitsSrv.Find',
index=0,
containing_service=None,
input_type=_FINDRAWFITSREQ,
......@@ -816,8 +816,8 @@ _FITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='get',
full_name='ifs.fits.FitsSrv.get',
name='Get',
full_name='ifs.fits.FitsSrv.Get',
index=1,
containing_service=None,
input_type=_GETRAWFITSREQ,
......@@ -825,8 +825,8 @@ _FITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='read',
full_name='ifs.fits.FitsSrv.read',
name='Read',
full_name='ifs.fits.FitsSrv.Read',
index=2,
containing_service=None,
input_type=_READRAWFITSREQ,
......@@ -834,8 +834,8 @@ _FITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='write',
full_name='ifs.fits.FitsSrv.write',
name='Write',
full_name='ifs.fits.FitsSrv.Write',
index=3,
containing_service=None,
input_type=_WRITERAWFITSREQ,
......@@ -843,8 +843,8 @@ _FITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='update_qc0_status',
full_name='ifs.fits.FitsSrv.update_qc0_status',
name='UpdateQc0Status',
full_name='ifs.fits.FitsSrv.UpdateQc0Status',
index=4,
containing_service=None,
input_type=_UPDATEQC0STATUSREQ,
......@@ -852,8 +852,8 @@ _FITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='update_proc_status',
full_name='ifs.fits.FitsSrv.update_proc_status',
name='UpdateProcStatus',
full_name='ifs.fits.FitsSrv.UpdateProcStatus',
index=5,
containing_service=None,
input_type=_UPDATEPROCSTATUSREQ,
......
csst_dfs_proto/ifs/fits/fits_pb2_grpc.py
View file @ bb745f30
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from ifs.fits import fits_pb2 as ifs_dot_fits_dot_fits__pb2
from . import fits_pb2 as ifs_dot_fits_dot_fits__pb2
class FitsSrvStub(object):
......@@ -14,33 +14,33 @@ class FitsSrvStub(object):
Args:
channel: A grpc.Channel.
"""
self.find = channel.unary_unary(
'/ifs.fits.FitsSrv/find',
self.Find = channel.unary_unary(
'/ifs.fits.FitsSrv/Find',
request_serializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsResp.FromString,
)
self.get = channel.unary_unary(
'/ifs.fits.FitsSrv/get',
self.Get = channel.unary_unary(
'/ifs.fits.FitsSrv/Get',
request_serializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsResp.FromString,
)
self.read = channel.unary_stream(
'/ifs.fits.FitsSrv/read',
self.Read = channel.unary_stream(
'/ifs.fits.FitsSrv/Read',
request_serializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsResp.FromString,
)
self.write = channel.stream_unary(
'/ifs.fits.FitsSrv/write',
self.Write = channel.stream_unary(
'/ifs.fits.FitsSrv/Write',
request_serializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsResp.FromString,
)
self.update_qc0_status = channel.unary_unary(
'/ifs.fits.FitsSrv/update_qc0_status',
self.UpdateQc0Status = channel.unary_unary(
'/ifs.fits.FitsSrv/UpdateQc0Status',
request_serializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusResp.FromString,
)
self.update_proc_status = channel.unary_unary(
'/ifs.fits.FitsSrv/update_proc_status',
self.UpdateProcStatus = channel.unary_unary(
'/ifs.fits.FitsSrv/UpdateProcStatus',
request_serializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusReq.SerializeToString,
response_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusResp.FromString,
)
......@@ -50,42 +50,42 @@ class FitsSrvServicer(object):
# missing associated documentation comment in .proto file
pass
def find(self, request, context):
def Find(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def get(self, request, context):
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 read(self, request, context):
def Read(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_iterator, context):
def Write(self, request_iterator, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def update_qc0_status(self, request, context):
def UpdateQc0Status(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def update_proc_status(self, request, context):
def UpdateProcStatus(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
......@@ -95,33 +95,33 @@ class FitsSrvServicer(object):
def add_FitsSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'find': grpc.unary_unary_rpc_method_handler(
servicer.find,
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.FindRawFitsResp.SerializeToString,
),
'get': grpc.unary_unary_rpc_method_handler(
servicer.get,
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.GetRawFitsResp.SerializeToString,
),
'read': grpc.unary_stream_rpc_method_handler(
servicer.read,
'Read': grpc.unary_stream_rpc_method_handler(
servicer.Read,
request_deserializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.ReadRawFitsResp.SerializeToString,
),
'write': grpc.stream_unary_rpc_method_handler(
servicer.write,
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.WriteRawFitsResp.SerializeToString,
),
'update_qc0_status': grpc.unary_unary_rpc_method_handler(
servicer.update_qc0_status,
'UpdateQc0Status': grpc.unary_unary_rpc_method_handler(
servicer.UpdateQc0Status,
request_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.UpdateQc0StatusResp.SerializeToString,
),
'update_proc_status': grpc.unary_unary_rpc_method_handler(
servicer.update_proc_status,
'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateProcStatus,
request_deserializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusReq.FromString,
response_serializer=ifs_dot_fits_dot_fits__pb2.UpdateProcStatusResp.SerializeToString,
),
......
csst_dfs_proto/ifs/reffits/reffits_pb2.py
View file @ bb745f30
......@@ -13,7 +13,7 @@ from google.protobuf import symbol_database as _symbol_database
_sym_db = _symbol_database.Default()
from common import error_pb2 as common_dot_error__pb2
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor.FileDescriptor(
......@@ -21,7 +21,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='ifs.reffits',
syntax='proto3',
serialized_options=_b('Z cnlab.net/csst/proto/ifs/reffits'),
serialized_pb=_b('\n\x19ifs/reffits/reffits.proto\x12\x0bifs.reffits\x1a\x12\x63ommon/error.proto\"\xa7\x01\n\x07RefFits\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x10\n\x08obs_time\x18\x03 \x01(\r\x12\x10\n\x08\x65xp_time\x18\x04 \x01(\x03\x12\x11\n\tfile_path\x18\x05 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x06 \x01(\r\x12\x10\n\x08ref_type\x18\x07 \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x08 \x01(\x03\x12\x0e\n\x06status\x18\t \x01(\r\"\x9a\x02\n\x0e\x46indRefFitsReq\x12\x10\n\x08obs_time\x18\x01 \x01(\r\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x16\n\x0e\x65xp_time_start\x18\x03 \x01(\t\x12\x14\n\x0c\x65xp_time_end\x18\x04 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x05 \x01(\r\x12\x0e\n\x06status\x18\x06 \x01(\r\x12\x10\n\x08ref_type\x18\x07 \x01(\t\x12J\n\x10other_conditions\x18\x08 \x03(\x0b\x32\x30.ifs.reffits.FindRefFitsReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"{\n\x0f\x46indRefFitsResp\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\x07refFits\x18\x04 \x03(\x0b\x32\x14.ifs.reffits.RefFits\" \n\rGetRefFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"7\n\x0eGetRefFitsResp\x12%\n\x07refFits\x18\x01 \x01(\x0b\x32\x14.ifs.reffits.RefFits\"H\n\x0eReadRefFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadRefFitsResp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"6\n\x0fWriteRefFitsReq\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\x10\n\x08\x66itsData\x18\x02 \x01(\x0c\"h\n\x10WriteRefFitsResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12%\n\x07refFits\x18\x03 \x01(\x0b\x32\x14.ifs.reffits.RefFits\"2\n\x0fUpdateStatusReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\r\"A\n\x10UpdateStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xf4\x02\n\nRefFitsSrv\x12\x43\n\x04\x66ind\x12\x1b.ifs.reffits.FindRefFitsReq\x1a\x1c.ifs.reffits.FindRefFitsResp\"\x00\x12@\n\x03get\x12\x1a.ifs.reffits.GetRefFitsReq\x1a\x1b.ifs.reffits.GetRefFitsResp\"\x00\x12\x45\n\x04read\x12\x1b.ifs.reffits.ReadRefFitsReq\x1a\x1c.ifs.reffits.ReadRefFitsResp\"\x00\x30\x01\x12H\n\x05write\x12\x1c.ifs.reffits.WriteRefFitsReq\x1a\x1d.ifs.reffits.WriteRefFitsResp\"\x00(\x01\x12N\n\rupdate_status\x12\x1c.ifs.reffits.UpdateStatusReq\x1a\x1d.ifs.reffits.UpdateStatusResp\"\x00\x42\"Z cnlab.net/csst/proto/ifs/reffitsb\x06proto3')
serialized_pb=_b('\n\x19ifs/reffits/reffits.proto\x12\x0bifs.reffits\x1a\x12\x63ommon/error.proto\"\xa7\x01\n\x07RefFits\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x10\n\x08obs_time\x18\x03 \x01(\r\x12\x10\n\x08\x65xp_time\x18\x04 \x01(\x03\x12\x11\n\tfile_path\x18\x05 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x06 \x01(\r\x12\x10\n\x08ref_type\x18\x07 \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x08 \x01(\x03\x12\x0e\n\x06status\x18\t \x01(\r\"\x9a\x02\n\x0e\x46indRefFitsReq\x12\x10\n\x08obs_time\x18\x01 \x01(\r\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x16\n\x0e\x65xp_time_start\x18\x03 \x01(\t\x12\x14\n\x0c\x65xp_time_end\x18\x04 \x01(\t\x12\x0f\n\x07\x63\x63\x64_num\x18\x05 \x01(\r\x12\x0e\n\x06status\x18\x06 \x01(\r\x12\x10\n\x08ref_type\x18\x07 \x01(\t\x12J\n\x10other_conditions\x18\x08 \x03(\x0b\x32\x30.ifs.reffits.FindRefFitsReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"{\n\x0f\x46indRefFitsResp\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\x07refFits\x18\x04 \x03(\x0b\x32\x14.ifs.reffits.RefFits\" \n\rGetRefFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"7\n\x0eGetRefFitsResp\x12%\n\x07refFits\x18\x01 \x01(\x0b\x32\x14.ifs.reffits.RefFits\"H\n\x0eReadRefFitsReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadRefFitsResp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"6\n\x0fWriteRefFitsReq\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\x10\n\x08\x66itsData\x18\x02 \x01(\x0c\"h\n\x10WriteRefFitsResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12%\n\x07refFits\x18\x03 \x01(\x0b\x32\x14.ifs.reffits.RefFits\"2\n\x0fUpdateStatusReq\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\r\"A\n\x10UpdateStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xf3\x02\n\nRefFitsSrv\x12\x43\n\x04\x46ind\x12\x1b.ifs.reffits.FindRefFitsReq\x1a\x1c.ifs.reffits.FindRefFitsResp\"\x00\x12@\n\x03Get\x12\x1a.ifs.reffits.GetRefFitsReq\x1a\x1b.ifs.reffits.GetRefFitsResp\"\x00\x12\x45\n\x04Read\x12\x1b.ifs.reffits.ReadRefFitsReq\x1a\x1c.ifs.reffits.ReadRefFitsResp\"\x00\x30\x01\x12H\n\x05Write\x12\x1c.ifs.reffits.WriteRefFitsReq\x1a\x1d.ifs.reffits.WriteRefFitsResp\"\x00(\x01\x12M\n\x0cUpdateStatus\x12\x1c.ifs.reffits.UpdateStatusReq\x1a\x1d.ifs.reffits.UpdateStatusResp\"\x00\x42\"Z cnlab.net/csst/proto/ifs/reffitsb\x06proto3')
,
dependencies=[common_dot_error__pb2.DESCRIPTOR,])
......@@ -697,11 +697,11 @@ _REFFITSSRV = _descriptor.ServiceDescriptor(
index=0,
serialized_options=None,
serialized_start=1122,
serialized_end=1494,
serialized_end=1493,
methods=[
_descriptor.MethodDescriptor(
name='find',
full_name='ifs.reffits.RefFitsSrv.find',
name='Find',
full_name='ifs.reffits.RefFitsSrv.Find',
index=0,
containing_service=None,
input_type=_FINDREFFITSREQ,
......@@ -709,8 +709,8 @@ _REFFITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='get',
full_name='ifs.reffits.RefFitsSrv.get',
name='Get',
full_name='ifs.reffits.RefFitsSrv.Get',
index=1,
containing_service=None,
input_type=_GETREFFITSREQ,
......@@ -718,8 +718,8 @@ _REFFITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='read',
full_name='ifs.reffits.RefFitsSrv.read',
name='Read',
full_name='ifs.reffits.RefFitsSrv.Read',
index=2,
containing_service=None,
input_type=_READREFFITSREQ,
......@@ -727,8 +727,8 @@ _REFFITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='write',
full_name='ifs.reffits.RefFitsSrv.write',
name='Write',
full_name='ifs.reffits.RefFitsSrv.Write',
index=3,
containing_service=None,
input_type=_WRITEREFFITSREQ,
......@@ -736,8 +736,8 @@ _REFFITSSRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='update_status',
full_name='ifs.reffits.RefFitsSrv.update_status',
name='UpdateStatus',
full_name='ifs.reffits.RefFitsSrv.UpdateStatus',
index=4,
containing_service=None,
input_type=_UPDATESTATUSREQ,
......
csst_dfs_proto/ifs/reffits/reffits_pb2_grpc.py
View file @ bb745f30
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from ifs.reffits import reffits_pb2 as ifs_dot_reffits_dot_reffits__pb2
from . import reffits_pb2 as ifs_dot_reffits_dot_reffits__pb2
class RefFitsSrvStub(object):
......@@ -14,28 +14,28 @@ class RefFitsSrvStub(object):
Args:
channel: A grpc.Channel.
"""
self.find = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/find',
self.Find = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/Find',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsResp.FromString,
)
self.get = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/get',
self.Get = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/Get',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsResp.FromString,
)
self.read = channel.unary_stream(
'/ifs.reffits.RefFitsSrv/read',
self.Read = channel.unary_stream(
'/ifs.reffits.RefFitsSrv/Read',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsResp.FromString,
)
self.write = channel.stream_unary(
'/ifs.reffits.RefFitsSrv/write',
self.Write = channel.stream_unary(
'/ifs.reffits.RefFitsSrv/Write',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsResp.FromString,
)
self.update_status = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/update_status',
self.UpdateStatus = channel.unary_unary(
'/ifs.reffits.RefFitsSrv/UpdateStatus',
request_serializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusReq.SerializeToString,
response_deserializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusResp.FromString,
)
......@@ -45,35 +45,35 @@ class RefFitsSrvServicer(object):
# missing associated documentation comment in .proto file
pass
def find(self, request, context):
def Find(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def get(self, request, context):
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 read(self, request, context):
def Read(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_iterator, context):
def Write(self, request_iterator, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def update_status(self, request, context):
def UpdateStatus(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
......@@ -83,28 +83,28 @@ class RefFitsSrvServicer(object):
def add_RefFitsSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'find': grpc.unary_unary_rpc_method_handler(
servicer.find,
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.FindRefFitsResp.SerializeToString,
),
'get': grpc.unary_unary_rpc_method_handler(
servicer.get,
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.GetRefFitsResp.SerializeToString,
),
'read': grpc.unary_stream_rpc_method_handler(
servicer.read,
'Read': grpc.unary_stream_rpc_method_handler(
servicer.Read,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.ReadRefFitsResp.SerializeToString,
),
'write': grpc.stream_unary_rpc_method_handler(
servicer.write,
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.WriteRefFitsResp.SerializeToString,
),
'update_status': grpc.unary_unary_rpc_method_handler(
servicer.update_status,
'UpdateStatus': grpc.unary_unary_rpc_method_handler(
servicer.UpdateStatus,
request_deserializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusReq.FromString,
response_serializer=ifs_dot_reffits_dot_reffits__pb2.UpdateStatusResp.SerializeToString,
),
......
csst_dfs_proto/ifs/result0/result0_pb2.py
View file @ bb745f30
......@@ -13,7 +13,7 @@ from google.protobuf import symbol_database as _symbol_database
_sym_db = _symbol_database.Default()
from common import error_pb2 as common_dot_error__pb2
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor.FileDescriptor(
......@@ -21,7 +21,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='ifs.result0',
syntax='proto3',
serialized_options=_b('Z cnlab.net/csst/proto/ifs/result0'),
serialized_pb=_b('\n\x19ifs/result0/result0.proto\x12\x0bifs.result0\x1a\x12\x63ommon/error.proto\"s\n\x07Result0\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x0e\n\x06raw_id\x18\x03 \x01(\x03\x12\x11\n\tfile_path\x18\x04 \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x05 \x01(\x03\x12\x11\n\tproc_type\x18\x06 \x01(\t\"\xca\x01\n\x0e\x46indResult0Req\x12\x0e\n\x06raw_id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x11\n\tproc_type\x18\x03 \x01(\t\x12J\n\x10other_conditions\x18\x04 \x03(\x0b\x32\x30.ifs.result0.FindResult0Req.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"{\n\x0f\x46indResult0Resp\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\x07result0\x18\x04 \x03(\x0b\x32\x14.ifs.result0.Result0\" \n\rGetResult0Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"7\n\x0eGetResult0Resp\x12%\n\x07result0\x18\x01 \x01(\x0b\x32\x14.ifs.result0.Result0\"H\n\x0eReadResult0Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadResult0Resp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"Y\n\x0fWriteResult0Req\x12\x0e\n\x06raw_id\x18\x01 \x01(\x03\x12\x11\n\tproc_type\x18\x02 \x01(\t\x12\x11\n\tfile_name\x18\x03 \x01(\t\x12\x10\n\x08\x66itsData\x18\x04 \x01(\x0c\"h\n\x10WriteResult0Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12%\n\x07result0\x18\x03 \x01(\x0b\x32\x14.ifs.result0.Result02\xa4\x02\n\nResult0Srv\x12\x43\n\x04\x66ind\x12\x1b.ifs.result0.FindResult0Req\x1a\x1c.ifs.result0.FindResult0Resp\"\x00\x12@\n\x03get\x12\x1a.ifs.result0.GetResult0Req\x1a\x1b.ifs.result0.GetResult0Resp\"\x00\x12\x45\n\x04read\x12\x1b.ifs.result0.ReadResult0Req\x1a\x1c.ifs.result0.ReadResult0Resp\"\x00\x30\x01\x12H\n\x05write\x12\x1c.ifs.result0.WriteResult0Req\x1a\x1d.ifs.result0.WriteResult0Resp\"\x00(\x01\x42\"Z cnlab.net/csst/proto/ifs/result0b\x06proto3')
serialized_pb=_b('\n\x19ifs/result0/result0.proto\x12\x0bifs.result0\x1a\x12\x63ommon/error.proto\"s\n\x07Result0\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x0e\n\x06raw_id\x18\x03 \x01(\x03\x12\x11\n\tfile_path\x18\x04 \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x05 \x01(\x03\x12\x11\n\tproc_type\x18\x06 \x01(\t\"\xca\x01\n\x0e\x46indResult0Req\x12\x0e\n\x06raw_id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x11\n\tproc_type\x18\x03 \x01(\t\x12J\n\x10other_conditions\x18\x04 \x03(\x0b\x32\x30.ifs.result0.FindResult0Req.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"{\n\x0f\x46indResult0Resp\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\x07result0\x18\x04 \x03(\x0b\x32\x14.ifs.result0.Result0\" \n\rGetResult0Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"7\n\x0eGetResult0Resp\x12%\n\x07result0\x18\x01 \x01(\x0b\x32\x14.ifs.result0.Result0\"H\n\x0eReadResult0Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadResult0Resp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"Y\n\x0fWriteResult0Req\x12\x0e\n\x06raw_id\x18\x01 \x01(\x03\x12\x11\n\tproc_type\x18\x02 \x01(\t\x12\x11\n\tfile_name\x18\x03 \x01(\t\x12\x10\n\x08\x66itsData\x18\x04 \x01(\x0c\"h\n\x10WriteResult0Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12%\n\x07result0\x18\x03 \x01(\x0b\x32\x14.ifs.result0.Result02\xa4\x02\n\nResult0Srv\x12\x43\n\x04\x46ind\x12\x1b.ifs.result0.FindResult0Req\x1a\x1c.ifs.result0.FindResult0Resp\"\x00\x12@\n\x03Get\x12\x1a.ifs.result0.GetResult0Req\x1a\x1b.ifs.result0.GetResult0Resp\"\x00\x12\x45\n\x04Read\x12\x1b.ifs.result0.ReadResult0Req\x1a\x1c.ifs.result0.ReadResult0Resp\"\x00\x30\x01\x12H\n\x05Write\x12\x1c.ifs.result0.WriteResult0Req\x1a\x1d.ifs.result0.WriteResult0Resp\"\x00(\x01\x42\"Z cnlab.net/csst/proto/ifs/result0b\x06proto3')
,
dependencies=[common_dot_error__pb2.DESCRIPTOR,])
......@@ -572,8 +572,8 @@ _RESULT0SRV = _descriptor.ServiceDescriptor(
serialized_end=1197,
methods=[
_descriptor.MethodDescriptor(
name='find',
full_name='ifs.result0.Result0Srv.find',
name='Find',
full_name='ifs.result0.Result0Srv.Find',
index=0,
containing_service=None,
input_type=_FINDRESULT0REQ,
......@@ -581,8 +581,8 @@ _RESULT0SRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='get',
full_name='ifs.result0.Result0Srv.get',
name='Get',
full_name='ifs.result0.Result0Srv.Get',
index=1,
containing_service=None,
input_type=_GETRESULT0REQ,
......@@ -590,8 +590,8 @@ _RESULT0SRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='read',
full_name='ifs.result0.Result0Srv.read',
name='Read',
full_name='ifs.result0.Result0Srv.Read',
index=2,
containing_service=None,
input_type=_READRESULT0REQ,
......@@ -599,8 +599,8 @@ _RESULT0SRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='write',
full_name='ifs.result0.Result0Srv.write',
name='Write',
full_name='ifs.result0.Result0Srv.Write',
index=3,
containing_service=None,
input_type=_WRITERESULT0REQ,
......
csst_dfs_proto/ifs/result0/result0_pb2_grpc.py
View file @ bb745f30
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from ifs.result0 import result0_pb2 as ifs_dot_result0_dot_result0__pb2
from . import result0_pb2 as ifs_dot_result0_dot_result0__pb2
class Result0SrvStub(object):
......@@ -14,23 +14,23 @@ class Result0SrvStub(object):
Args:
channel: A grpc.Channel.
"""
self.find = channel.unary_unary(
'/ifs.result0.Result0Srv/find',
self.Find = channel.unary_unary(
'/ifs.result0.Result0Srv/Find',
request_serializer=ifs_dot_result0_dot_result0__pb2.FindResult0Req.SerializeToString,
response_deserializer=ifs_dot_result0_dot_result0__pb2.FindResult0Resp.FromString,
)
self.get = channel.unary_unary(
'/ifs.result0.Result0Srv/get',
self.Get = channel.unary_unary(
'/ifs.result0.Result0Srv/Get',
request_serializer=ifs_dot_result0_dot_result0__pb2.GetResult0Req.SerializeToString,
response_deserializer=ifs_dot_result0_dot_result0__pb2.GetResult0Resp.FromString,
)
self.read = channel.unary_stream(
'/ifs.result0.Result0Srv/read',
self.Read = channel.unary_stream(
'/ifs.result0.Result0Srv/Read',
request_serializer=ifs_dot_result0_dot_result0__pb2.ReadResult0Req.SerializeToString,
response_deserializer=ifs_dot_result0_dot_result0__pb2.ReadResult0Resp.FromString,
)
self.write = channel.stream_unary(
'/ifs.result0.Result0Srv/write',
self.Write = channel.stream_unary(
'/ifs.result0.Result0Srv/Write',
request_serializer=ifs_dot_result0_dot_result0__pb2.WriteResult0Req.SerializeToString,
response_deserializer=ifs_dot_result0_dot_result0__pb2.WriteResult0Resp.FromString,
)
......@@ -40,28 +40,28 @@ class Result0SrvServicer(object):
# missing associated documentation comment in .proto file
pass
def find(self, request, context):
def Find(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def get(self, request, context):
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 read(self, request, context):
def Read(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_iterator, context):
def Write(self, request_iterator, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
......@@ -71,23 +71,23 @@ class Result0SrvServicer(object):
def add_Result0SrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'find': grpc.unary_unary_rpc_method_handler(
servicer.find,
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=ifs_dot_result0_dot_result0__pb2.FindResult0Req.FromString,
response_serializer=ifs_dot_result0_dot_result0__pb2.FindResult0Resp.SerializeToString,
),
'get': grpc.unary_unary_rpc_method_handler(
servicer.get,
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ifs_dot_result0_dot_result0__pb2.GetResult0Req.FromString,
response_serializer=ifs_dot_result0_dot_result0__pb2.GetResult0Resp.SerializeToString,
),
'read': grpc.unary_stream_rpc_method_handler(
servicer.read,
'Read': grpc.unary_stream_rpc_method_handler(
servicer.Read,
request_deserializer=ifs_dot_result0_dot_result0__pb2.ReadResult0Req.FromString,
response_serializer=ifs_dot_result0_dot_result0__pb2.ReadResult0Resp.SerializeToString,
),
'write': grpc.stream_unary_rpc_method_handler(
servicer.write,
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=ifs_dot_result0_dot_result0__pb2.WriteResult0Req.FromString,
response_serializer=ifs_dot_result0_dot_result0__pb2.WriteResult0Resp.SerializeToString,
),
......
csst_dfs_proto/ifs/result1/result1_pb2.py
View file @ bb745f30
......@@ -13,7 +13,7 @@ from google.protobuf import symbol_database as _symbol_database
_sym_db = _symbol_database.Default()
from common import error_pb2 as common_dot_error__pb2
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor.FileDescriptor(
......@@ -21,7 +21,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='ifs.result1',
syntax='proto3',
serialized_options=_b('Z cnlab.net/csst/proto/ifs/result1'),
serialized_pb=_b('\n\x19ifs/result1/result1.proto\x12\x0bifs.result1\x1a\x12\x63ommon/error.proto\"c\n\x07Result1\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x11\n\tfile_path\x18\x03 \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x04 \x01(\x03\x12\x11\n\tproc_type\x18\x05 \x01(\t\"\xba\x01\n\x0e\x46indResult1Req\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\x11\n\tproc_type\x18\x02 \x01(\t\x12J\n\x10other_conditions\x18\x03 \x03(\x0b\x32\x30.ifs.result1.FindResult1Req.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"{\n\x0f\x46indResult1Resp\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\x07result1\x18\x04 \x03(\x0b\x32\x14.ifs.result1.Result1\" \n\rGetResult1Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"7\n\x0eGetResult1Resp\x12%\n\x07result1\x18\x01 \x01(\x0b\x32\x14.ifs.result1.Result1\"H\n\x0eReadResult1Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadResult1Resp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"^\n\x0fWriteResult1Req\x12\x11\n\tproc_type\x18\x01 \x01(\t\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x10\n\x08\x66itsData\x18\x03 \x01(\x0c\x12\x13\n\x0bresult0_ids\x18\x04 \x03(\x03\"h\n\x10WriteResult1Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12%\n\x07result1\x18\x03 \x01(\x0b\x32\x14.ifs.result1.Result12\xa4\x02\n\nResult1Srv\x12\x43\n\x04\x66ind\x12\x1b.ifs.result1.FindResult1Req\x1a\x1c.ifs.result1.FindResult1Resp\"\x00\x12@\n\x03get\x12\x1a.ifs.result1.GetResult1Req\x1a\x1b.ifs.result1.GetResult1Resp\"\x00\x12\x45\n\x04read\x12\x1b.ifs.result1.ReadResult1Req\x1a\x1c.ifs.result1.ReadResult1Resp\"\x00\x30\x01\x12H\n\x05write\x12\x1c.ifs.result1.WriteResult1Req\x1a\x1d.ifs.result1.WriteResult1Resp\"\x00(\x01\x42\"Z cnlab.net/csst/proto/ifs/result1b\x06proto3')
serialized_pb=_b('\n\x19ifs/result1/result1.proto\x12\x0bifs.result1\x1a\x12\x63ommon/error.proto\"x\n\x07Result1\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x11\n\tfile_path\x18\x03 \x01(\t\x12\x13\n\x0b\x63reate_time\x18\x04 \x01(\x03\x12\x11\n\tproc_type\x18\x05 \x01(\t\x12\x13\n\x0bresult0_ids\x18\x06 \x03(\x03\"\xba\x01\n\x0e\x46indResult1Req\x12\x11\n\tfile_name\x18\x01 \x01(\t\x12\x11\n\tproc_type\x18\x02 \x01(\t\x12J\n\x10other_conditions\x18\x03 \x03(\x0b\x32\x30.ifs.result1.FindResult1Req.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"{\n\x0f\x46indResult1Resp\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\x07result1\x18\x04 \x03(\x0b\x32\x14.ifs.result1.Result1\" \n\rGetResult1Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\"7\n\x0eGetResult1Resp\x12%\n\x07result1\x18\x01 \x01(\x0b\x32\x14.ifs.result1.Result1\"H\n\x0eReadResult1Req\x12\x0f\n\x07\x66its_id\x18\x01 \x01(\x03\x12\x11\n\tfile_path\x18\x02 \x01(\t\x12\x12\n\nchunk_size\x18\x03 \x01(\r\"\x1f\n\x0fReadResult1Resp\x12\x0c\n\x04\x64\x61ta\x18\x01 \x01(\x0c\"^\n\x0fWriteResult1Req\x12\x11\n\tproc_type\x18\x01 \x01(\t\x12\x11\n\tfile_name\x18\x02 \x01(\t\x12\x10\n\x08\x66itsData\x18\x03 \x01(\x0c\x12\x13\n\x0bresult0_ids\x18\x04 \x03(\x03\"h\n\x10WriteResult1Resp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12%\n\x07result1\x18\x03 \x01(\x0b\x32\x14.ifs.result1.Result12\xa4\x02\n\nResult1Srv\x12\x43\n\x04\x46ind\x12\x1b.ifs.result1.FindResult1Req\x1a\x1c.ifs.result1.FindResult1Resp\"\x00\x12@\n\x03Get\x12\x1a.ifs.result1.GetResult1Req\x1a\x1b.ifs.result1.GetResult1Resp\"\x00\x12\x45\n\x04Read\x12\x1b.ifs.result1.ReadResult1Req\x1a\x1c.ifs.result1.ReadResult1Resp\"\x00\x30\x01\x12H\n\x05Write\x12\x1c.ifs.result1.WriteResult1Req\x1a\x1d.ifs.result1.WriteResult1Resp\"\x00(\x01\x42\"Z cnlab.net/csst/proto/ifs/result1b\x06proto3')
,
dependencies=[common_dot_error__pb2.DESCRIPTOR,])
......@@ -70,6 +70,13 @@ _RESULT1 = _descriptor.Descriptor(
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='result0_ids', full_name='ifs.result1.Result1.result0_ids', index=5,
number=6, type=3, cpp_type=2, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
......@@ -83,7 +90,7 @@ _RESULT1 = _descriptor.Descriptor(
oneofs=[
],
serialized_start=62,
serialized_end=161,
serialized_end=182,
)
......@@ -120,8 +127,8 @@ _FINDRESULT1REQ_OTHERCONDITIONSENTRY = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=296,
serialized_end=350,
serialized_start=317,
serialized_end=371,
)
_FINDRESULT1REQ = _descriptor.Descriptor(
......@@ -164,8 +171,8 @@ _FINDRESULT1REQ = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=164,
serialized_end=350,
serialized_start=185,
serialized_end=371,
)
......@@ -216,8 +223,8 @@ _FINDRESULT1RESP = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=352,
serialized_end=475,
serialized_start=373,
serialized_end=496,
)
......@@ -247,8 +254,8 @@ _GETRESULT1REQ = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=477,
serialized_end=509,
serialized_start=498,
serialized_end=530,
)
......@@ -278,8 +285,8 @@ _GETRESULT1RESP = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=511,
serialized_end=566,
serialized_start=532,
serialized_end=587,
)
......@@ -323,8 +330,8 @@ _READRESULT1REQ = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=568,
serialized_end=640,
serialized_start=589,
serialized_end=661,
)
......@@ -354,8 +361,8 @@ _READRESULT1RESP = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=642,
serialized_end=673,
serialized_start=663,
serialized_end=694,
)
......@@ -406,8 +413,8 @@ _WRITERESULT1REQ = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=675,
serialized_end=769,
serialized_start=696,
serialized_end=790,
)
......@@ -451,8 +458,8 @@ _WRITERESULT1RESP = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=771,
serialized_end=875,
serialized_start=792,
serialized_end=896,
)
_FINDRESULT1REQ_OTHERCONDITIONSENTRY.containing_type = _FINDRESULT1REQ
......@@ -554,12 +561,12 @@ _RESULT1SRV = _descriptor.ServiceDescriptor(
file=DESCRIPTOR,
index=0,
serialized_options=None,
serialized_start=878,
serialized_end=1170,
serialized_start=899,
serialized_end=1191,
methods=[
_descriptor.MethodDescriptor(
name='find',
full_name='ifs.result1.Result1Srv.find',
name='Find',
full_name='ifs.result1.Result1Srv.Find',
index=0,
containing_service=None,
input_type=_FINDRESULT1REQ,
......@@ -567,8 +574,8 @@ _RESULT1SRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='get',
full_name='ifs.result1.Result1Srv.get',
name='Get',
full_name='ifs.result1.Result1Srv.Get',
index=1,
containing_service=None,
input_type=_GETRESULT1REQ,
......@@ -576,8 +583,8 @@ _RESULT1SRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='read',
full_name='ifs.result1.Result1Srv.read',
name='Read',
full_name='ifs.result1.Result1Srv.Read',
index=2,
containing_service=None,
input_type=_READRESULT1REQ,
......@@ -585,8 +592,8 @@ _RESULT1SRV = _descriptor.ServiceDescriptor(
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='write',
full_name='ifs.result1.Result1Srv.write',
name='Write',
full_name='ifs.result1.Result1Srv.Write',
index=3,
containing_service=None,
input_type=_WRITERESULT1REQ,
......
csst_dfs_proto/ifs/result1/result1_pb2_grpc.py
View file @ bb745f30
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from ifs.result1 import result1_pb2 as ifs_dot_result1_dot_result1__pb2
from . import result1_pb2 as ifs_dot_result1_dot_result1__pb2
class Result1SrvStub(object):
......@@ -14,23 +14,23 @@ class Result1SrvStub(object):
Args:
channel: A grpc.Channel.
"""
self.find = channel.unary_unary(
'/ifs.result1.Result1Srv/find',
self.Find = channel.unary_unary(
'/ifs.result1.Result1Srv/Find',
request_serializer=ifs_dot_result1_dot_result1__pb2.FindResult1Req.SerializeToString,
response_deserializer=ifs_dot_result1_dot_result1__pb2.FindResult1Resp.FromString,
)
self.get = channel.unary_unary(
'/ifs.result1.Result1Srv/get',
self.Get = channel.unary_unary(
'/ifs.result1.Result1Srv/Get',
request_serializer=ifs_dot_result1_dot_result1__pb2.GetResult1Req.SerializeToString,
response_deserializer=ifs_dot_result1_dot_result1__pb2.GetResult1Resp.FromString,
)
self.read = channel.unary_stream(
'/ifs.result1.Result1Srv/read',
self.Read = channel.unary_stream(
'/ifs.result1.Result1Srv/Read',
request_serializer=ifs_dot_result1_dot_result1__pb2.ReadResult1Req.SerializeToString,
response_deserializer=ifs_dot_result1_dot_result1__pb2.ReadResult1Resp.FromString,
)
self.write = channel.stream_unary(
'/ifs.result1.Result1Srv/write',
self.Write = channel.stream_unary(
'/ifs.result1.Result1Srv/Write',
request_serializer=ifs_dot_result1_dot_result1__pb2.WriteResult1Req.SerializeToString,
response_deserializer=ifs_dot_result1_dot_result1__pb2.WriteResult1Resp.FromString,
)
......@@ -40,28 +40,28 @@ class Result1SrvServicer(object):
# missing associated documentation comment in .proto file
pass
def find(self, request, context):
def Find(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def get(self, request, context):
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 read(self, request, context):
def Read(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_iterator, context):
def Write(self, request_iterator, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
......@@ -71,23 +71,23 @@ class Result1SrvServicer(object):
def add_Result1SrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'find': grpc.unary_unary_rpc_method_handler(
servicer.find,
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=ifs_dot_result1_dot_result1__pb2.FindResult1Req.FromString,
response_serializer=ifs_dot_result1_dot_result1__pb2.FindResult1Resp.SerializeToString,
),
'get': grpc.unary_unary_rpc_method_handler(
servicer.get,
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ifs_dot_result1_dot_result1__pb2.GetResult1Req.FromString,
response_serializer=ifs_dot_result1_dot_result1__pb2.GetResult1Resp.SerializeToString,
),
'read': grpc.unary_stream_rpc_method_handler(
servicer.read,
'Read': grpc.unary_stream_rpc_method_handler(
servicer.Read,
request_deserializer=ifs_dot_result1_dot_result1__pb2.ReadResult1Req.FromString,
response_serializer=ifs_dot_result1_dot_result1__pb2.ReadResult1Resp.SerializeToString,
),
'write': grpc.stream_unary_rpc_method_handler(
servicer.write,
'Write': grpc.stream_unary_rpc_method_handler(
servicer.Write,
request_deserializer=ifs_dot_result1_dot_result1__pb2.WriteResult1Req.FromString,
response_serializer=ifs_dot_result1_dot_result1__pb2.WriteResult1Resp.SerializeToString,
),
......
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