# 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)