vendor/github.com/hashicorp/go-plugin/examples/grpc/plugin-python/kv_pb2.py

   1 # Generated by the protocol buffer compiler.  DO NOT EDIT!
   2 # source: kv.proto
   3
   4 import sys
   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)
  12
  13 _sym_db = _symbol_database.Default()
  14
  15
  16
  17
  18 DESCRIPTOR = _descriptor.FileDescriptor(
  19   name='kv.proto',
  20   package='proto',
  21   syntax='proto3',
  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')
  23 )
  24 _sym_db.RegisterFileDescriptor(DESCRIPTOR)
  25
  26
  27
  28
  29 _GETREQUEST = _descriptor.Descriptor(
  30   name='GetRequest',
  31   full_name='proto.GetRequest',
  32   filename=None,
  33   file=DESCRIPTOR,
  34   containing_type=None,
  35   fields=[
  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,
  42       options=None),
  43   ],
  44   extensions=[
  45   ],
  46   nested_types=[],
  47   enum_types=[
  48   ],
  49   options=None,
  50   is_extendable=False,
  51   syntax='proto3',
  52   extension_ranges=[],
  53   oneofs=[
  54   ],
  55   serialized_start=19,
  56   serialized_end=44,
  57 )
  58
  59
  60 _GETRESPONSE = _descriptor.Descriptor(
  61   name='GetResponse',
  62   full_name='proto.GetResponse',
  63   filename=None,
  64   file=DESCRIPTOR,
  65   containing_type=None,
  66   fields=[
  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,
  73       options=None),
  74   ],
  75   extensions=[
  76   ],
  77   nested_types=[],
  78   enum_types=[
  79   ],
  80   options=None,
  81   is_extendable=False,
  82   syntax='proto3',
  83   extension_ranges=[],
  84   oneofs=[
  85   ],
  86   serialized_start=46,
  87   serialized_end=74,
  88 )
  89
  90
  91 _PUTREQUEST = _descriptor.Descriptor(
  92   name='PutRequest',
  93   full_name='proto.PutRequest',
  94   filename=None,
  95   file=DESCRIPTOR,
  96   containing_type=None,
  97   fields=[
  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,
 104       options=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,
 111       options=None),
 112   ],
 113   extensions=[
 114   ],
 115   nested_types=[],
 116   enum_types=[
 117   ],
 118   options=None,
 119   is_extendable=False,
 120   syntax='proto3',
 121   extension_ranges=[],
 122   oneofs=[
 123   ],
 124   serialized_start=76,
 125   serialized_end=116,
 126 )
 127
 128
 129 _EMPTY = _descriptor.Descriptor(
 130   name='Empty',
 131   full_name='proto.Empty',
 132   filename=None,
 133   file=DESCRIPTOR,
 134   containing_type=None,
 135   fields=[
 136   ],
 137   extensions=[
 138   ],
 139   nested_types=[],
 140   enum_types=[
 141   ],
 142   options=None,
 143   is_extendable=False,
 144   syntax='proto3',
 145   extension_ranges=[],
 146   oneofs=[
 147   ],
 148   serialized_start=118,
 149   serialized_end=125,
 150 )
 151
 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
 156
 157 GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), dict(
 158   DESCRIPTOR = _GETREQUEST,
 159   __module__ = 'kv_pb2'
 160   # @@protoc_insertion_point(class_scope:proto.GetRequest)
 161   ))
 162 _sym_db.RegisterMessage(GetRequest)
 163
 164 GetResponse = _reflection.GeneratedProtocolMessageType('GetResponse', (_message.Message,), dict(
 165   DESCRIPTOR = _GETRESPONSE,
 166   __module__ = 'kv_pb2'
 167   # @@protoc_insertion_point(class_scope:proto.GetResponse)
 168   ))
 169 _sym_db.RegisterMessage(GetResponse)
 170
 171 PutRequest = _reflection.GeneratedProtocolMessageType('PutRequest', (_message.Message,), dict(
 172   DESCRIPTOR = _PUTREQUEST,
 173   __module__ = 'kv_pb2'
 174   # @@protoc_insertion_point(class_scope:proto.PutRequest)
 175   ))
 176 _sym_db.RegisterMessage(PutRequest)
 177
 178 Empty = _reflection.GeneratedProtocolMessageType('Empty', (_message.Message,), dict(
 179   DESCRIPTOR = _EMPTY,
 180   __module__ = 'kv_pb2'
 181   # @@protoc_insertion_point(class_scope:proto.Empty)
 182   ))
 183 _sym_db.RegisterMessage(Empty)
 184
 185
 186 try:
 187   # THESE ELEMENTS WILL BE DEPRECATED.
 188   # Please use the generated *_pb2_grpc.py files instead.
 189   import grpc
 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
 194
 195
 196   class KVStub(object):
 197
 198     def __init__(self, channel):
 199       """Constructor.
 200
 201       Args:
 202         channel: A grpc.Channel.
 203       """
 204       self.Get = channel.unary_unary(
 205           '/proto.KV/Get',
 206           request_serializer=GetRequest.SerializeToString,
 207           response_deserializer=GetResponse.FromString,
 208           )
 209       self.Put = channel.unary_unary(
 210           '/proto.KV/Put',
 211           request_serializer=PutRequest.SerializeToString,
 212           response_deserializer=Empty.FromString,
 213           )
 214
 215
 216   class KVServicer(object):
 217
 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!')
 222
 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!')
 227
 228
 229   def add_KVServicer_to_server(servicer, server):
 230     rpc_method_handlers = {
 231         'Get': grpc.unary_unary_rpc_method_handler(
 232             servicer.Get,
 233             request_deserializer=GetRequest.FromString,
 234             response_serializer=GetResponse.SerializeToString,
 235         ),
 236         'Put': grpc.unary_unary_rpc_method_handler(
 237             servicer.Put,
 238             request_deserializer=PutRequest.FromString,
 239             response_serializer=Empty.SerializeToString,
 240         ),
 241     }
 242     generic_handler = grpc.method_handlers_generic_handler(
 243         'proto.KV', rpc_method_handlers)
 244     server.add_generic_rpc_handlers((generic_handler,))
 245
 246
 247   class BetaKVServicer(object):
 248     """The Beta API is deprecated for 0.15.0 and later.
 249
 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)
 257
 258
 259   class BetaKVStub(object):
 260     """The Beta API is deprecated for 0.15.0 and later.
 261
 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()
 267     Get.future = None
 268     def Put(self, request, timeout, metadata=None, with_call=False, protocol_options=None):
 269       raise NotImplementedError()
 270     Put.future = None
 271
 272
 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.
 275
 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,
 282     }
 283     response_serializers = {
 284       ('proto.KV', 'Get'): GetResponse.SerializeToString,
 285       ('proto.KV', 'Put'): Empty.SerializeToString,
 286     }
 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),
 290     }
 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)
 293
 294
 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.
 297
 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,
 304     }
 305     response_deserializers = {
 306       ('proto.KV', 'Get'): GetResponse.FromString,
 307       ('proto.KV', 'Put'): Empty.FromString,
 308     }
 309     cardinalities = {
 310       'Get': cardinality.Cardinality.UNARY_UNARY,
 311       'Put': cardinality.Cardinality.UNARY_UNARY,
 312     }
 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)
 315 except ImportError:
 316   pass
 317 # @@protoc_insertion_point(module_scope)