+++ /dev/null
-# Generated by the protocol buffer compiler. DO NOT EDIT!
-# source: kv.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
-from google.protobuf import descriptor_pb2
-# @@protoc_insertion_point(imports)
-
-_sym_db = _symbol_database.Default()
-
-
-
-
-DESCRIPTOR = _descriptor.FileDescriptor(
- name='kv.proto',
- package='proto',
- syntax='proto3',
- serialized_pb=_b('\n\x08kv.proto\x12\x05proto\"\x19\n\nGetRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\"\x1c\n\x0bGetResponse\x12\r\n\x05value\x18\x01 \x01(\x0c\"(\n\nPutRequest\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c\"\x07\n\x05\x45mpty2Z\n\x02KV\x12,\n\x03Get\x12\x11.proto.GetRequest\x1a\x12.proto.GetResponse\x12&\n\x03Put\x12\x11.proto.PutRequest\x1a\x0c.proto.Emptyb\x06proto3')
-)
-_sym_db.RegisterFileDescriptor(DESCRIPTOR)
-
-
-
-
-_GETREQUEST = _descriptor.Descriptor(
- name='GetRequest',
- full_name='proto.GetRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='proto.GetRequest.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,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto3',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=19,
- serialized_end=44,
-)
-
-
-_GETRESPONSE = _descriptor.Descriptor(
- name='GetResponse',
- full_name='proto.GetResponse',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='value', full_name='proto.GetResponse.value', index=0,
- number=1, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto3',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=46,
- serialized_end=74,
-)
-
-
-_PUTREQUEST = _descriptor.Descriptor(
- name='PutRequest',
- full_name='proto.PutRequest',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- _descriptor.FieldDescriptor(
- name='key', full_name='proto.PutRequest.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,
- options=None),
- _descriptor.FieldDescriptor(
- name='value', full_name='proto.PutRequest.value', index=1,
- number=2, type=12, cpp_type=9, label=1,
- has_default_value=False, default_value=_b(""),
- message_type=None, enum_type=None, containing_type=None,
- is_extension=False, extension_scope=None,
- options=None),
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto3',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=76,
- serialized_end=116,
-)
-
-
-_EMPTY = _descriptor.Descriptor(
- name='Empty',
- full_name='proto.Empty',
- filename=None,
- file=DESCRIPTOR,
- containing_type=None,
- fields=[
- ],
- extensions=[
- ],
- nested_types=[],
- enum_types=[
- ],
- options=None,
- is_extendable=False,
- syntax='proto3',
- extension_ranges=[],
- oneofs=[
- ],
- serialized_start=118,
- serialized_end=125,
-)
-
-DESCRIPTOR.message_types_by_name['GetRequest'] = _GETREQUEST
-DESCRIPTOR.message_types_by_name['GetResponse'] = _GETRESPONSE
-DESCRIPTOR.message_types_by_name['PutRequest'] = _PUTREQUEST
-DESCRIPTOR.message_types_by_name['Empty'] = _EMPTY
-
-GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), dict(
- DESCRIPTOR = _GETREQUEST,
- __module__ = 'kv_pb2'
- # @@protoc_insertion_point(class_scope:proto.GetRequest)
- ))
-_sym_db.RegisterMessage(GetRequest)
-
-GetResponse = _reflection.GeneratedProtocolMessageType('GetResponse', (_message.Message,), dict(
- DESCRIPTOR = _GETRESPONSE,
- __module__ = 'kv_pb2'
- # @@protoc_insertion_point(class_scope:proto.GetResponse)
- ))
-_sym_db.RegisterMessage(GetResponse)
-
-PutRequest = _reflection.GeneratedProtocolMessageType('PutRequest', (_message.Message,), dict(
- DESCRIPTOR = _PUTREQUEST,
- __module__ = 'kv_pb2'
- # @@protoc_insertion_point(class_scope:proto.PutRequest)
- ))
-_sym_db.RegisterMessage(PutRequest)
-
-Empty = _reflection.GeneratedProtocolMessageType('Empty', (_message.Message,), dict(
- DESCRIPTOR = _EMPTY,
- __module__ = 'kv_pb2'
- # @@protoc_insertion_point(class_scope:proto.Empty)
- ))
-_sym_db.RegisterMessage(Empty)
-
-
-try:
- # THESE ELEMENTS WILL BE DEPRECATED.
- # Please use the generated *_pb2_grpc.py files instead.
- import grpc
- from grpc.beta import implementations as beta_implementations
- from grpc.beta import interfaces as beta_interfaces
- from grpc.framework.common import cardinality
- from grpc.framework.interfaces.face import utilities as face_utilities
-
-
- class KVStub(object):
-
- def __init__(self, channel):
- """Constructor.
-
- Args:
- channel: A grpc.Channel.
- """
- self.Get = channel.unary_unary(
- '/proto.KV/Get',
- request_serializer=GetRequest.SerializeToString,
- response_deserializer=GetResponse.FromString,
- )
- self.Put = channel.unary_unary(
- '/proto.KV/Put',
- request_serializer=PutRequest.SerializeToString,
- response_deserializer=Empty.FromString,
- )
-
-
- class KVServicer(object):
-
- def Get(self, request, context):
- context.set_code(grpc.StatusCode.UNIMPLEMENTED)
- context.set_details('Method not implemented!')
- raise NotImplementedError('Method not implemented!')
-
- def Put(self, request, context):
- context.set_code(grpc.StatusCode.UNIMPLEMENTED)
- context.set_details('Method not implemented!')
- raise NotImplementedError('Method not implemented!')
-
-
- def add_KVServicer_to_server(servicer, server):
- rpc_method_handlers = {
- 'Get': grpc.unary_unary_rpc_method_handler(
- servicer.Get,
- request_deserializer=GetRequest.FromString,
- response_serializer=GetResponse.SerializeToString,
- ),
- 'Put': grpc.unary_unary_rpc_method_handler(
- servicer.Put,
- request_deserializer=PutRequest.FromString,
- response_serializer=Empty.SerializeToString,
- ),
- }
- generic_handler = grpc.method_handlers_generic_handler(
- 'proto.KV', rpc_method_handlers)
- server.add_generic_rpc_handlers((generic_handler,))
-
-
- class BetaKVServicer(object):
- """The Beta API is deprecated for 0.15.0 and later.
-
- It is recommended to use the GA API (classes and functions in this
- file not marked beta) for all further purposes. This class was generated
- only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
- def Get(self, request, context):
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
- def Put(self, request, context):
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
-
-
- class BetaKVStub(object):
- """The Beta API is deprecated for 0.15.0 and later.
-
- It is recommended to use the GA API (classes and functions in this
- file not marked beta) for all further purposes. This class was generated
- only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
- def Get(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- raise NotImplementedError()
- Get.future = None
- def Put(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
- raise NotImplementedError()
- Put.future = None
-
-
- def beta_create_KV_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
- """The Beta API is deprecated for 0.15.0 and later.
-
- It is recommended to use the GA API (classes and functions in this
- file not marked beta) for all further purposes. This function was
- generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
- request_deserializers = {
- ('proto.KV', 'Get'): GetRequest.FromString,
- ('proto.KV', 'Put'): PutRequest.FromString,
- }
- response_serializers = {
- ('proto.KV', 'Get'): GetResponse.SerializeToString,
- ('proto.KV', 'Put'): Empty.SerializeToString,
- }
- method_implementations = {
- ('proto.KV', 'Get'): face_utilities.unary_unary_inline(servicer.Get),
- ('proto.KV', 'Put'): face_utilities.unary_unary_inline(servicer.Put),
- }
- server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout)
- return beta_implementations.server(method_implementations, options=server_options)
-
-
- def beta_create_KV_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
- """The Beta API is deprecated for 0.15.0 and later.
-
- It is recommended to use the GA API (classes and functions in this
- file not marked beta) for all further purposes. This function was
- generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
- request_serializers = {
- ('proto.KV', 'Get'): GetRequest.SerializeToString,
- ('proto.KV', 'Put'): PutRequest.SerializeToString,
- }
- response_deserializers = {
- ('proto.KV', 'Get'): GetResponse.FromString,
- ('proto.KV', 'Put'): Empty.FromString,
- }
- cardinalities = {
- 'Get': cardinality.Cardinality.UNARY_UNARY,
- 'Put': cardinality.Cardinality.UNARY_UNARY,
- }
- stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size)
- return beta_implementations.dynamic_stub(channel, 'proto.KV', cardinalities, options=stub_options)
-except ImportError:
- pass
-# @@protoc_insertion_point(module_scope)
OSDN Git Service
