1 # Generated by the protocol buffer compiler. DO NOT EDIT!
5 _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
6 from google.protobuf import descriptor as _descriptor
7 from google.protobuf import message as _message
8 from google.protobuf import reflection as _reflection
9 from google.protobuf import symbol_database as _symbol_database
10 from google.protobuf import descriptor_pb2
11 # @@protoc_insertion_point(imports)
13 _sym_db = _symbol_database.Default()
18 DESCRIPTOR = _descriptor.FileDescriptor(
22 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')
24 _sym_db.RegisterFileDescriptor(DESCRIPTOR)
29 _GETREQUEST = _descriptor.Descriptor(
31 full_name='proto.GetRequest',
36 _descriptor.FieldDescriptor(
37 name='key', full_name='proto.GetRequest.key', index=0,
38 number=1, type=9, cpp_type=9, label=1,
39 has_default_value=False, default_value=_b("").decode('utf-8'),
40 message_type=None, enum_type=None, containing_type=None,
41 is_extension=False, extension_scope=None,
60 _GETRESPONSE = _descriptor.Descriptor(
62 full_name='proto.GetResponse',
67 _descriptor.FieldDescriptor(
68 name='value', full_name='proto.GetResponse.value', index=0,
69 number=1, type=12, cpp_type=9, label=1,
70 has_default_value=False, default_value=_b(""),
71 message_type=None, enum_type=None, containing_type=None,
72 is_extension=False, extension_scope=None,
91 _PUTREQUEST = _descriptor.Descriptor(
93 full_name='proto.PutRequest',
98 _descriptor.FieldDescriptor(
99 name='key', full_name='proto.PutRequest.key', index=0,
100 number=1, type=9, cpp_type=9, label=1,
101 has_default_value=False, default_value=_b("").decode('utf-8'),
102 message_type=None, enum_type=None, containing_type=None,
103 is_extension=False, extension_scope=None,
105 _descriptor.FieldDescriptor(
106 name='value', full_name='proto.PutRequest.value', index=1,
107 number=2, type=12, cpp_type=9, label=1,
108 has_default_value=False, default_value=_b(""),
109 message_type=None, enum_type=None, containing_type=None,
110 is_extension=False, extension_scope=None,
129 _EMPTY = _descriptor.Descriptor(
131 full_name='proto.Empty',
134 containing_type=None,
148 serialized_start=118,
152 DESCRIPTOR.message_types_by_name['GetRequest'] = _GETREQUEST
153 DESCRIPTOR.message_types_by_name['GetResponse'] = _GETRESPONSE
154 DESCRIPTOR.message_types_by_name['PutRequest'] = _PUTREQUEST
155 DESCRIPTOR.message_types_by_name['Empty'] = _EMPTY
157 GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), dict(
158 DESCRIPTOR = _GETREQUEST,
159 __module__ = 'kv_pb2'
160 # @@protoc_insertion_point(class_scope:proto.GetRequest)
162 _sym_db.RegisterMessage(GetRequest)
164 GetResponse = _reflection.GeneratedProtocolMessageType('GetResponse', (_message.Message,), dict(
165 DESCRIPTOR = _GETRESPONSE,
166 __module__ = 'kv_pb2'
167 # @@protoc_insertion_point(class_scope:proto.GetResponse)
169 _sym_db.RegisterMessage(GetResponse)
171 PutRequest = _reflection.GeneratedProtocolMessageType('PutRequest', (_message.Message,), dict(
172 DESCRIPTOR = _PUTREQUEST,
173 __module__ = 'kv_pb2'
174 # @@protoc_insertion_point(class_scope:proto.PutRequest)
176 _sym_db.RegisterMessage(PutRequest)
178 Empty = _reflection.GeneratedProtocolMessageType('Empty', (_message.Message,), dict(
180 __module__ = 'kv_pb2'
181 # @@protoc_insertion_point(class_scope:proto.Empty)
183 _sym_db.RegisterMessage(Empty)
187 # THESE ELEMENTS WILL BE DEPRECATED.
188 # Please use the generated *_pb2_grpc.py files instead.
190 from grpc.beta import implementations as beta_implementations
191 from grpc.beta import interfaces as beta_interfaces
192 from grpc.framework.common import cardinality
193 from grpc.framework.interfaces.face import utilities as face_utilities
196 class KVStub(object):
198 def __init__(self, channel):
202 channel: A grpc.Channel.
204 self.Get = channel.unary_unary(
206 request_serializer=GetRequest.SerializeToString,
207 response_deserializer=GetResponse.FromString,
209 self.Put = channel.unary_unary(
211 request_serializer=PutRequest.SerializeToString,
212 response_deserializer=Empty.FromString,
216 class KVServicer(object):
218 def Get(self, request, context):
219 context.set_code(grpc.StatusCode.UNIMPLEMENTED)
220 context.set_details('Method not implemented!')
221 raise NotImplementedError('Method not implemented!')
223 def Put(self, request, context):
224 context.set_code(grpc.StatusCode.UNIMPLEMENTED)
225 context.set_details('Method not implemented!')
226 raise NotImplementedError('Method not implemented!')
229 def add_KVServicer_to_server(servicer, server):
230 rpc_method_handlers = {
231 'Get': grpc.unary_unary_rpc_method_handler(
233 request_deserializer=GetRequest.FromString,
234 response_serializer=GetResponse.SerializeToString,
236 'Put': grpc.unary_unary_rpc_method_handler(
238 request_deserializer=PutRequest.FromString,
239 response_serializer=Empty.SerializeToString,
242 generic_handler = grpc.method_handlers_generic_handler(
243 'proto.KV', rpc_method_handlers)
244 server.add_generic_rpc_handlers((generic_handler,))
247 class BetaKVServicer(object):
248 """The Beta API is deprecated for 0.15.0 and later.
250 It is recommended to use the GA API (classes and functions in this
251 file not marked beta) for all further purposes. This class was generated
252 only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
253 def Get(self, request, context):
254 context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
255 def Put(self, request, context):
256 context.code(beta_interfaces.StatusCode.UNIMPLEMENTED)
259 class BetaKVStub(object):
260 """The Beta API is deprecated for 0.15.0 and later.
262 It is recommended to use the GA API (classes and functions in this
263 file not marked beta) for all further purposes. This class was generated
264 only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0."""
265 def Get(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
266 raise NotImplementedError()
268 def Put(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
269 raise NotImplementedError()
273 def beta_create_KV_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None):
274 """The Beta API is deprecated for 0.15.0 and later.
276 It is recommended to use the GA API (classes and functions in this
277 file not marked beta) for all further purposes. This function was
278 generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
279 request_deserializers = {
280 ('proto.KV', 'Get'): GetRequest.FromString,
281 ('proto.KV', 'Put'): PutRequest.FromString,
283 response_serializers = {
284 ('proto.KV', 'Get'): GetResponse.SerializeToString,
285 ('proto.KV', 'Put'): Empty.SerializeToString,
287 method_implementations = {
288 ('proto.KV', 'Get'): face_utilities.unary_unary_inline(servicer.Get),
289 ('proto.KV', 'Put'): face_utilities.unary_unary_inline(servicer.Put),
291 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)
292 return beta_implementations.server(method_implementations, options=server_options)
295 def beta_create_KV_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None):
296 """The Beta API is deprecated for 0.15.0 and later.
298 It is recommended to use the GA API (classes and functions in this
299 file not marked beta) for all further purposes. This function was
300 generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0"""
301 request_serializers = {
302 ('proto.KV', 'Get'): GetRequest.SerializeToString,
303 ('proto.KV', 'Put'): PutRequest.SerializeToString,
305 response_deserializers = {
306 ('proto.KV', 'Get'): GetResponse.FromString,
307 ('proto.KV', 'Put'): Empty.FromString,
310 'Get': cardinality.Cardinality.UNARY_UNARY,
311 'Put': cardinality.Cardinality.UNARY_UNARY,
313 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)
314 return beta_implementations.dynamic_stub(channel, 'proto.KV', cardinalities, options=stub_options)
317 # @@protoc_insertion_point(module_scope)