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

new level2

parent 5a8842a3
Expand all Show whitespace changes
Inline Side-by-side
csst_dfs_proto/common/misc/misc_pb2.py 0 → 100644
View file @ 8b47ad2a
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: common/misc/misc.proto
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
DESCRIPTOR = _descriptor.FileDescriptor(
name='common/misc/misc.proto',
package='dfs.common.misc',
syntax='proto3',
serialized_options=b'Z cnlab.net/csst/proto/common/misc',
serialized_pb=b'\n\x16\x63ommon/misc/misc.proto\x12\x0f\x64\x66s.common.misc\"\x1d\n\x0bGetSeqIdReq\x12\x0e\n\x06prefix\x18\x01 \x01(\t\"\x1e\n\x0cGetSeqIdResp\x12\x0e\n\x06nextId\x18\x01 \x01(\x03\x32T\n\x07MiscSrv\x12I\n\x08GetSeqId\x12\x1c.dfs.common.misc.GetSeqIdReq\x1a\x1d.dfs.common.misc.GetSeqIdResp\"\x00\x42\"Z cnlab.net/csst/proto/common/miscb\x06proto3'
)
_GETSEQIDREQ = _descriptor.Descriptor(
name='GetSeqIdReq',
full_name='dfs.common.misc.GetSeqIdReq',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='prefix', full_name='dfs.common.misc.GetSeqIdReq.prefix', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=b"".decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=43,
serialized_end=72,
)
_GETSEQIDRESP = _descriptor.Descriptor(
name='GetSeqIdResp',
full_name='dfs.common.misc.GetSeqIdResp',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='nextId', full_name='dfs.common.misc.GetSeqIdResp.nextId', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=74,
serialized_end=104,
)
DESCRIPTOR.message_types_by_name['GetSeqIdReq'] = _GETSEQIDREQ
DESCRIPTOR.message_types_by_name['GetSeqIdResp'] = _GETSEQIDRESP
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
GetSeqIdReq = _reflection.GeneratedProtocolMessageType('GetSeqIdReq', (_message.Message,), {
'DESCRIPTOR' : _GETSEQIDREQ,
'__module__' : 'common.misc.misc_pb2'
# @@protoc_insertion_point(class_scope:dfs.common.misc.GetSeqIdReq)
})
_sym_db.RegisterMessage(GetSeqIdReq)
GetSeqIdResp = _reflection.GeneratedProtocolMessageType('GetSeqIdResp', (_message.Message,), {
'DESCRIPTOR' : _GETSEQIDRESP,
'__module__' : 'common.misc.misc_pb2'
# @@protoc_insertion_point(class_scope:dfs.common.misc.GetSeqIdResp)
})
_sym_db.RegisterMessage(GetSeqIdResp)
DESCRIPTOR._options = None
_MISCSRV = _descriptor.ServiceDescriptor(
name='MiscSrv',
full_name='dfs.common.misc.MiscSrv',
file=DESCRIPTOR,
index=0,
serialized_options=None,
serialized_start=106,
serialized_end=190,
methods=[
_descriptor.MethodDescriptor(
name='GetSeqId',
full_name='dfs.common.misc.MiscSrv.GetSeqId',
index=0,
containing_service=None,
input_type=_GETSEQIDREQ,
output_type=_GETSEQIDRESP,
serialized_options=None,
),
])
_sym_db.RegisterServiceDescriptor(_MISCSRV)
DESCRIPTOR.services_by_name['MiscSrv'] = _MISCSRV
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/common/misc/misc_pb2_grpc.py 0 → 100644
View file @ 8b47ad2a
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import misc_pb2 as common_dot_misc_dot_misc__pb2
class MiscSrvStub(object):
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetSeqId = channel.unary_unary(
'/dfs.common.misc.MiscSrv/GetSeqId',
request_serializer=common_dot_misc_dot_misc__pb2.GetSeqIdReq.SerializeToString,
response_deserializer=common_dot_misc_dot_misc__pb2.GetSeqIdResp.FromString,
)
class MiscSrvServicer(object):
"""Missing associated documentation comment in .proto file"""
def GetSeqId(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_MiscSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetSeqId': grpc.unary_unary_rpc_method_handler(
servicer.GetSeqId,
request_deserializer=common_dot_misc_dot_misc__pb2.GetSeqIdReq.FromString,
response_serializer=common_dot_misc_dot_misc__pb2.GetSeqIdResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.common.misc.MiscSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class MiscSrv(object):
"""Missing associated documentation comment in .proto file"""
@staticmethod
def GetSeqId(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.common.misc.MiscSrv/GetSeqId',
common_dot_misc_dot_misc__pb2.GetSeqIdReq.SerializeToString,
common_dot_misc_dot_misc__pb2.GetSeqIdResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/msc/level2/level2_pb2.py
View file @ 8b47ad2a
This diff is collapsed.
csst_dfs_proto/msc/level2/level2_pb2_grpc.py
View file @ 8b47ad2a
......@@ -5,8 +5,7 @@ from . import level2_pb2 as msc_dot_level2_dot_level2__pb2
class Level2SrvStub(object):
# missing associated documentation comment in .proto file
pass
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
......@@ -57,61 +56,52 @@ class Level2SrvStub(object):
class Level2SrvServicer(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 FindCatalog(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 FindCatalogFile(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 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 UpdateQc2Status(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!')
def DeleteCatalogByLevel2Id(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!')
......@@ -163,3 +153,136 @@ def add_Level2SrvServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'dfs.msc.level2.Level2Srv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class Level2Srv(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.level2.Level2Srv/Find',
msc_dot_level2_dot_level2__pb2.FindLevel2Req.SerializeToString,
msc_dot_level2_dot_level2__pb2.FindLevel2Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindCatalog(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.level2.Level2Srv/FindCatalog',
msc_dot_level2_dot_level2__pb2.FindLevel2CatalogReq.SerializeToString,
msc_dot_level2_dot_level2__pb2.FindLevel2CatalogResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindCatalogFile(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.level2.Level2Srv/FindCatalogFile',
msc_dot_level2_dot_level2__pb2.FindLevel2CatalogReq.SerializeToString,
msc_dot_level2_dot_level2__pb2.FindCatalogFileResp.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.level2.Level2Srv/Get',
msc_dot_level2_dot_level2__pb2.GetLevel2Req.SerializeToString,
msc_dot_level2_dot_level2__pb2.GetLevel2Resp.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.level2.Level2Srv/Write',
msc_dot_level2_dot_level2__pb2.WriteLevel2Req.SerializeToString,
msc_dot_level2_dot_level2__pb2.WriteLevel2Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc2Status(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.level2.Level2Srv/UpdateQc2Status',
msc_dot_level2_dot_level2__pb2.UpdateQc2StatusReq.SerializeToString,
msc_dot_level2_dot_level2__pb2.UpdateQc2StatusResp.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.level2.Level2Srv/UpdateProcStatus',
msc_dot_level2_dot_level2__pb2.UpdateProcStatusReq.SerializeToString,
msc_dot_level2_dot_level2__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def DeleteCatalogByLevel2Id(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.level2.Level2Srv/DeleteCatalogByLevel2Id',
msc_dot_level2_dot_level2__pb2.DeleteCatalogByLevel2IdReq.SerializeToString,
msc_dot_level2_dot_level2__pb2.DeleteCatalogByLevel2IdResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/msc/level2co/level2co_pb2.py
View file @ 8b47ad2a
This diff is collapsed.
csst_dfs_proto/msc/level2co/level2co_pb2_grpc.py
View file @ 8b47ad2a
......@@ -5,8 +5,7 @@ from . import level2co_pb2 as msc_dot_level2co_dot_level2co__pb2
class Level2CoSrvStub(object):
# missing associated documentation comment in .proto file
pass
"""Missing associated documentation comment in .proto file"""
def __init__(self, channel):
"""Constructor.
......@@ -52,54 +51,46 @@ class Level2CoSrvStub(object):
class Level2CoSrvServicer(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 FindCatalog(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 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 UpdateQc2Status(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!')
def DeleteCatalogByLevel2CoId(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!')
......@@ -146,3 +137,120 @@ def add_Level2CoSrvServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'dfs.msc.level2co.Level2CoSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class Level2CoSrv(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.level2co.Level2CoSrv/Find',
msc_dot_level2co_dot_level2co__pb2.FindLevel2CoReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.FindLevel2CoResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindCatalog(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.level2co.Level2CoSrv/FindCatalog',
msc_dot_level2co_dot_level2co__pb2.FindLevel2CoCatalogReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.FindLevel2CoCatalogResp.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.level2co.Level2CoSrv/Get',
msc_dot_level2co_dot_level2co__pb2.GetLevel2CoReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.GetLevel2CoResp.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.level2co.Level2CoSrv/Write',
msc_dot_level2co_dot_level2co__pb2.WriteLevel2CoReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.WriteLevel2CoResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc2Status(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.level2co.Level2CoSrv/UpdateQc2Status',
msc_dot_level2co_dot_level2co__pb2.UpdateQc2StatusReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.UpdateQc2StatusResp.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.level2co.Level2CoSrv/UpdateProcStatus',
msc_dot_level2co_dot_level2co__pb2.UpdateProcStatusReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def DeleteCatalogByLevel2CoId(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.level2co.Level2CoSrv/DeleteCatalogByLevel2CoId',
msc_dot_level2co_dot_level2co__pb2.DeleteCatalogByLevel2CoIdReq.SerializeToString,
msc_dot_level2co_dot_level2co__pb2.DeleteCatalogByLevel2CoIdResp.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