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

upgrade protobuf

parent 085a9a24
Expand all Hide whitespace changes
Inline Side-by-side
csst_dfs_proto/common/ephem/ephem_pb2.py
View file @ b73e0fcc
This diff is collapsed.
csst_dfs_proto/common/ephem/ephem_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import ephem_pb2 as common_dot_ephem_dot_ephem__pb2
class EphemSearchSrvStub(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
......@@ -21,10 +22,10 @@ class EphemSearchSrvStub(object):
class EphemSearchSrvServicer(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def Gaia3Search(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -45,7 +46,7 @@ def add_EphemSearchSrvServicer_to_server(servicer, server):
# This class is part of an EXPERIMENTAL API.
class EphemSearchSrv(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Gaia3Search(request,
......@@ -53,6 +54,7 @@ class EphemSearchSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -61,4 +63,4 @@ class EphemSearchSrv(object):
common_dot_ephem_dot_ephem__pb2.EphemSearchRequest.SerializeToString,
common_dot_ephem_dot_ephem__pb2.Gaia3SearchResponse.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/common/error_pb2.py
View file @ b73e0fcc
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: common/error.proto
import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
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 descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
......@@ -15,64 +13,14 @@ _sym_db = _symbol_database.Default()
DESCRIPTOR = _descriptor.FileDescriptor(
name='common/error.proto',
package='common',
syntax='proto3',
serialized_options=_b('Z\033cnlab.net/csst/proto/common'),
serialized_pb=_b('\n\x12\x63ommon/error.proto\x12\x06\x63ommon\"%\n\x05\x45rror\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0e\n\x06\x64\x65tail\x18\x02 \x01(\tB\x1dZ\x1b\x63nlab.net/csst/proto/commonb\x06proto3')
)
_ERROR = _descriptor.Descriptor(
name='Error',
full_name='common.Error',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='code', full_name='common.Error.code', index=0,
number=1, type=5, cpp_type=1, 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),
_descriptor.FieldDescriptor(
name='detail', full_name='common.Error.detail', index=1,
number=2, 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=30,
serialized_end=67,
)
DESCRIPTOR.message_types_by_name['Error'] = _ERROR
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
Error = _reflection.GeneratedProtocolMessageType('Error', (_message.Message,), {
'DESCRIPTOR' : _ERROR,
'__module__' : 'common.error_pb2'
# @@protoc_insertion_point(class_scope:common.Error)
})
_sym_db.RegisterMessage(Error)
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x12\x63ommon/error.proto\x12\x06\x63ommon\"%\n\x05\x45rror\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0e\n\x06\x64\x65tail\x18\x02 \x01(\tB\x1dZ\x1b\x63nlab.net/csst/proto/commonb\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'common.error_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\033cnlab.net/csst/proto/common'
_ERROR._serialized_start=30
_ERROR._serialized_end=67
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/common/error_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
csst_dfs_proto/common/fits_process/fitsProcess_pb2.py deleted 100644 → 0
View file @ 085a9a24
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: common/fits_process/fitsProcess.proto
import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
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/fits_process/fitsProcess.proto',
package='dfs.common.fitsProcess',
syntax='proto3',
serialized_options=_b('Z\'cnlab.net/csst/proto/common/fitsProcess'),
serialized_pb=_b('\n%common/fits_process/fitsProcess.proto\x12\x16\x64\x66s.common.fitsProcess\"0\n\rGetHeadersReq\x12\x11\n\tfile_path\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\r\"\x83\x01\n\x0eGetHeadersResp\x12\x42\n\x06values\x18\x01 \x03(\x0b\x32\x32.dfs.common.fitsProcess.GetHeadersResp.ValuesEntry\x1a-\n\x0bValuesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x32o\n\x0e\x46itsProcessSrv\x12]\n\nGetHeaders\x12%.dfs.common.fitsProcess.GetHeadersReq\x1a&.dfs.common.fitsProcess.GetHeadersResp\"\x00\x42)Z\'cnlab.net/csst/proto/common/fitsProcessb\x06proto3')
)
_GETHEADERSREQ = _descriptor.Descriptor(
name='GetHeadersReq',
full_name='dfs.common.fitsProcess.GetHeadersReq',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='file_path', full_name='dfs.common.fitsProcess.GetHeadersReq.file_path', 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),
_descriptor.FieldDescriptor(
name='type', full_name='dfs.common.fitsProcess.GetHeadersReq.type', index=1,
number=2, type=13, cpp_type=3, 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=65,
serialized_end=113,
)
_GETHEADERSRESP_VALUESENTRY = _descriptor.Descriptor(
name='ValuesEntry',
full_name='dfs.common.fitsProcess.GetHeadersResp.ValuesEntry',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='key', full_name='dfs.common.fitsProcess.GetHeadersResp.ValuesEntry.key', 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),
_descriptor.FieldDescriptor(
name='value', full_name='dfs.common.fitsProcess.GetHeadersResp.ValuesEntry.value', index=1,
number=2, 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=_b('8\001'),
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=202,
serialized_end=247,
)
_GETHEADERSRESP = _descriptor.Descriptor(
name='GetHeadersResp',
full_name='dfs.common.fitsProcess.GetHeadersResp',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='values', full_name='dfs.common.fitsProcess.GetHeadersResp.values', index=0,
number=1, type=11, cpp_type=10, 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=[
],
nested_types=[_GETHEADERSRESP_VALUESENTRY, ],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=116,
serialized_end=247,
)
_GETHEADERSRESP_VALUESENTRY.containing_type = _GETHEADERSRESP
_GETHEADERSRESP.fields_by_name['values'].message_type = _GETHEADERSRESP_VALUESENTRY
DESCRIPTOR.message_types_by_name['GetHeadersReq'] = _GETHEADERSREQ
DESCRIPTOR.message_types_by_name['GetHeadersResp'] = _GETHEADERSRESP
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
GetHeadersReq = _reflection.GeneratedProtocolMessageType('GetHeadersReq', (_message.Message,), {
'DESCRIPTOR' : _GETHEADERSREQ,
'__module__' : 'common.fits_process.fitsProcess_pb2'
# @@protoc_insertion_point(class_scope:dfs.common.fitsProcess.GetHeadersReq)
})
_sym_db.RegisterMessage(GetHeadersReq)
GetHeadersResp = _reflection.GeneratedProtocolMessageType('GetHeadersResp', (_message.Message,), {
'ValuesEntry' : _reflection.GeneratedProtocolMessageType('ValuesEntry', (_message.Message,), {
'DESCRIPTOR' : _GETHEADERSRESP_VALUESENTRY,
'__module__' : 'common.fits_process.fitsProcess_pb2'
# @@protoc_insertion_point(class_scope:dfs.common.fitsProcess.GetHeadersResp.ValuesEntry)
})
,
'DESCRIPTOR' : _GETHEADERSRESP,
'__module__' : 'common.fits_process.fitsProcess_pb2'
# @@protoc_insertion_point(class_scope:dfs.common.fitsProcess.GetHeadersResp)
})
_sym_db.RegisterMessage(GetHeadersResp)
_sym_db.RegisterMessage(GetHeadersResp.ValuesEntry)
DESCRIPTOR._options = None
_GETHEADERSRESP_VALUESENTRY._options = None
_FITSPROCESSSRV = _descriptor.ServiceDescriptor(
name='FitsProcessSrv',
full_name='dfs.common.fitsProcess.FitsProcessSrv',
file=DESCRIPTOR,
index=0,
serialized_options=None,
serialized_start=249,
serialized_end=360,
methods=[
_descriptor.MethodDescriptor(
name='GetHeaders',
full_name='dfs.common.fitsProcess.FitsProcessSrv.GetHeaders',
index=0,
containing_service=None,
input_type=_GETHEADERSREQ,
output_type=_GETHEADERSRESP,
serialized_options=None,
),
])
_sym_db.RegisterServiceDescriptor(_FITSPROCESSSRV)
DESCRIPTOR.services_by_name['FitsProcessSrv'] = _FITSPROCESSSRV
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/common/fits_process/fitsProcess_pb2_grpc.py deleted 100644 → 0
View file @ 085a9a24
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from . import fitsProcess_pb2 as common_dot_fits__process_dot_fitsProcess__pb2
class FitsProcessSrvStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetHeaders = channel.unary_unary(
'/dfs.common.fitsProcess.FitsProcessSrv/GetHeaders',
request_serializer=common_dot_fits__process_dot_fitsProcess__pb2.GetHeadersReq.SerializeToString,
response_deserializer=common_dot_fits__process_dot_fitsProcess__pb2.GetHeadersResp.FromString,
)
class FitsProcessSrvServicer(object):
# missing associated documentation comment in .proto file
pass
def GetHeaders(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 add_FitsProcessSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetHeaders': grpc.unary_unary_rpc_method_handler(
servicer.GetHeaders,
request_deserializer=common_dot_fits__process_dot_fitsProcess__pb2.GetHeadersReq.FromString,
response_serializer=common_dot_fits__process_dot_fitsProcess__pb2.GetHeadersResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.common.fitsProcess.FitsProcessSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
csst_dfs_proto/common/misc/misc_pb2.py
View file @ b73e0fcc
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: common/misc/misc.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
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 descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
......@@ -13,120 +13,18 @@ _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 = _descriptor_pool.Default().AddSerializedFile(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')
DESCRIPTOR.services_by_name['MiscSrv'] = _MISCSRV
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'common.misc.misc_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z cnlab.net/csst/proto/common/misc'
_GETSEQIDREQ._serialized_start=43
_GETSEQIDREQ._serialized_end=72
_GETSEQIDRESP._serialized_start=74
_GETSEQIDRESP._serialized_end=104
_MISCSRV._serialized_start=106
_MISCSRV._serialized_end=190
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/common/misc/misc_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import misc_pb2 as common_dot_misc_dot_misc__pb2
class MiscSrvStub(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
......@@ -21,10 +22,10 @@ class MiscSrvStub(object):
class MiscSrvServicer(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def GetSeqId(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -45,7 +46,7 @@ def add_MiscSrvServicer_to_server(servicer, server):
# This class is part of an EXPERIMENTAL API.
class MiscSrv(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
@staticmethod
def GetSeqId(request,
......@@ -53,6 +54,7 @@ class MiscSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -61,4 +63,4 @@ class MiscSrv(object):
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)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/facility/brick/brick_pb2.py
View file @ b73e0fcc
This diff is collapsed.
csst_dfs_proto/facility/brick/brick_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import brick_pb2 as facility_dot_brick_dot_brick__pb2
class BrickSrvStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Find',
request_serializer=facility_dot_brick_dot_brick__pb2.FindBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindBrickResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Get',
request_serializer=facility_dot_brick_dot_brick__pb2.GetBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.GetBrickResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Write',
request_serializer=facility_dot_brick_dot_brick__pb2.WriteBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.WriteBrickResp.FromString,
)
self.FindObsStatus = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/FindObsStatus',
request_serializer=facility_dot_brick_dot_brick__pb2.FindObsStatusReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindObsStatusResp.FromString,
)
self.FindLevel1 = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/FindLevel1',
request_serializer=facility_dot_brick_dot_brick__pb2.FindLevel1Req.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindLevel1Resp.FromString,
)
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Find',
request_serializer=facility_dot_brick_dot_brick__pb2.FindBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindBrickResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Get',
request_serializer=facility_dot_brick_dot_brick__pb2.GetBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.GetBrickResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/Write',
request_serializer=facility_dot_brick_dot_brick__pb2.WriteBrickReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.WriteBrickResp.FromString,
)
self.FindObsStatus = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/FindObsStatus',
request_serializer=facility_dot_brick_dot_brick__pb2.FindObsStatusReq.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindObsStatusResp.FromString,
)
self.FindLevel1 = channel.unary_unary(
'/dfs.facility.brick.BrickSrv/FindLevel1',
request_serializer=facility_dot_brick_dot_brick__pb2.FindLevel1Req.SerializeToString,
response_deserializer=facility_dot_brick_dot_brick__pb2.FindLevel1Resp.FromString,
)
class BrickSrvServicer(object):
# missing associated documentation comment in .proto file
pass
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):
# 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, 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 FindObsStatus(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 FindLevel1(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!')
"""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, 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 FindObsStatus(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 FindLevel1(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_BrickSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindBrickResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=facility_dot_brick_dot_brick__pb2.GetBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.GetBrickResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=facility_dot_brick_dot_brick__pb2.WriteBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.WriteBrickResp.SerializeToString,
),
'FindObsStatus': grpc.unary_unary_rpc_method_handler(
servicer.FindObsStatus,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindObsStatusReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindObsStatusResp.SerializeToString,
),
'FindLevel1': grpc.unary_unary_rpc_method_handler(
servicer.FindLevel1,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindLevel1Req.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindLevel1Resp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.brick.BrickSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
rpc_method_handlers = {
'Find': grpc.unary_unary_rpc_method_handler(
servicer.Find,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindBrickResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=facility_dot_brick_dot_brick__pb2.GetBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.GetBrickResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=facility_dot_brick_dot_brick__pb2.WriteBrickReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.WriteBrickResp.SerializeToString,
),
'FindObsStatus': grpc.unary_unary_rpc_method_handler(
servicer.FindObsStatus,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindObsStatusReq.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindObsStatusResp.SerializeToString,
),
'FindLevel1': grpc.unary_unary_rpc_method_handler(
servicer.FindLevel1,
request_deserializer=facility_dot_brick_dot_brick__pb2.FindLevel1Req.FromString,
response_serializer=facility_dot_brick_dot_brick__pb2.FindLevel1Resp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.facility.brick.BrickSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class BrickSrv(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Find(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.facility.brick.BrickSrv/Find',
facility_dot_brick_dot_brick__pb2.FindBrickReq.SerializeToString,
facility_dot_brick_dot_brick__pb2.FindBrickResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Get(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.facility.brick.BrickSrv/Get',
facility_dot_brick_dot_brick__pb2.GetBrickReq.SerializeToString,
facility_dot_brick_dot_brick__pb2.GetBrickResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.facility.brick.BrickSrv/Write',
facility_dot_brick_dot_brick__pb2.WriteBrickReq.SerializeToString,
facility_dot_brick_dot_brick__pb2.WriteBrickResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindObsStatus(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.facility.brick.BrickSrv/FindObsStatus',
facility_dot_brick_dot_brick__pb2.FindObsStatusReq.SerializeToString,
facility_dot_brick_dot_brick__pb2.FindObsStatusResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindLevel1(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.facility.brick.BrickSrv/FindLevel1',
facility_dot_brick_dot_brick__pb2.FindLevel1Req.SerializeToString,
facility_dot_brick_dot_brick__pb2.FindLevel1Resp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/facility/calmerge/calmerge_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import calmerge_pb2 as facility_dot_calmerge_dot_calmerge__pb2
class CalMergeSrvStub(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
......@@ -46,40 +47,40 @@ class CalMergeSrvStub(object):
class CalMergeSrvServicer(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def Find(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetLatestByL0(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Get(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Write(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateQc1Status(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateProcStatus(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -125,7 +126,7 @@ def add_CalMergeSrvServicer_to_server(servicer, server):
# This class is part of an EXPERIMENTAL API.
class CalMergeSrv(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Find(request,
......@@ -133,6 +134,7 @@ class CalMergeSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -141,7 +143,7 @@ class CalMergeSrv(object):
facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.FindCalMergeResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def GetLatestByL0(request,
......@@ -149,6 +151,7 @@ class CalMergeSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -157,7 +160,7 @@ class CalMergeSrv(object):
facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Req.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.GetLatestByL0Resp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Get(request,
......@@ -165,6 +168,7 @@ class CalMergeSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -173,7 +177,7 @@ class CalMergeSrv(object):
facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.GetCalMergeResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(request,
......@@ -181,6 +185,7 @@ class CalMergeSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -189,7 +194,7 @@ class CalMergeSrv(object):
facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.WriteCalMergeResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc1Status(request,
......@@ -197,6 +202,7 @@ class CalMergeSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -205,7 +211,7 @@ class CalMergeSrv(object):
facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.UpdateQc1StatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateProcStatus(request,
......@@ -213,6 +219,7 @@ class CalMergeSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -221,4 +228,4 @@ class CalMergeSrv(object):
facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_calmerge_dot_calmerge__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/facility/level0/level0_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import level0_pb2 as facility_dot_level0_dot_level0__pb2
class Level0SrvStub(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
......@@ -46,40 +47,40 @@ class Level0SrvStub(object):
class Level0SrvServicer(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def Find(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Get(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Write(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateQc0Status(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateProcStatus(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -125,7 +126,7 @@ def add_Level0SrvServicer_to_server(servicer, server):
# This class is part of an EXPERIMENTAL API.
class Level0Srv(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Find(request,
......@@ -133,6 +134,7 @@ class Level0Srv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -141,7 +143,7 @@ class Level0Srv(object):
facility_dot_level0_dot_level0__pb2.FindLevel0DataReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.FindLevel0DataResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def FindByBrickIds(request,
......@@ -149,6 +151,7 @@ class Level0Srv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -157,7 +160,7 @@ class Level0Srv(object):
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)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Get(request,
......@@ -165,6 +168,7 @@ class Level0Srv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -173,7 +177,7 @@ class Level0Srv(object):
facility_dot_level0_dot_level0__pb2.GetLevel0DataReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.GetLevel0DataResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(request,
......@@ -181,6 +185,7 @@ class Level0Srv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -189,7 +194,7 @@ class Level0Srv(object):
facility_dot_level0_dot_level0__pb2.WriteLevel0DataReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.WriteLevel0DataResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateQc0Status(request,
......@@ -197,6 +202,7 @@ class Level0Srv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -205,7 +211,7 @@ class Level0Srv(object):
facility_dot_level0_dot_level0__pb2.UpdateQc0StatusReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.UpdateQc0StatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateProcStatus(request,
......@@ -213,6 +219,7 @@ class Level0Srv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -221,4 +228,4 @@ class Level0Srv(object):
facility_dot_level0_dot_level0__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_level0_dot_level0__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/facility/level0prc/level0prc_pb2_grpc.py
View file @ b73e0fcc
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import level0prc_pb2 as facility_dot_level0prc_dot_level0prc__pb2
class Level0PrcSrvStub(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
......@@ -31,22 +32,22 @@ class Level0PrcSrvStub(object):
class Level0PrcSrvServicer(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
def Find(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Write(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateProcStatus(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_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
......@@ -77,7 +78,7 @@ def add_Level0PrcSrvServicer_to_server(servicer, server):
# This class is part of an EXPERIMENTAL API.
class Level0PrcSrv(object):
"""Missing associated documentation comment in .proto file"""
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Find(request,
......@@ -85,6 +86,7 @@ class Level0PrcSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -93,7 +95,7 @@ class Level0PrcSrv(object):
facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcReq.SerializeToString,
facility_dot_level0prc_dot_level0prc__pb2.FindLevel0PrcResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(request,
......@@ -101,6 +103,7 @@ class Level0PrcSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -109,7 +112,7 @@ class Level0PrcSrv(object):
facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcReq.SerializeToString,
facility_dot_level0prc_dot_level0prc__pb2.WriteLevel0PrcResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UpdateProcStatus(request,
......@@ -117,6 +120,7 @@ class Level0PrcSrv(object):
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
......@@ -125,4 +129,4 @@ class Level0PrcSrv(object):
facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusReq.SerializeToString,
facility_dot_level0prc_dot_level0prc__pb2.UpdateProcStatusResp.FromString,
options, channel_credentials,
call_credentials, compression, wait_for_ready, timeout, metadata)
insecure, 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