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

   1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
   2 import grpc
   3
   4 import kv_pb2 as kv__pb2
   5
   6
   7 class KVStub(object):
   8
   9   def __init__(self, channel):
  10     """Constructor.
  11
  12     Args:
  13       channel: A grpc.Channel.
  14     """
  15     self.Get = channel.unary_unary(
  16         '/proto.KV/Get',
  17         request_serializer=kv__pb2.GetRequest.SerializeToString,
  18         response_deserializer=kv__pb2.GetResponse.FromString,
  19         )
  20     self.Put = channel.unary_unary(
  21         '/proto.KV/Put',
  22         request_serializer=kv__pb2.PutRequest.SerializeToString,
  23         response_deserializer=kv__pb2.Empty.FromString,
  24         )
  25
  26
  27 class KVServicer(object):
  28
  29   def Get(self, request, context):
  30     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
  31     context.set_details('Method not implemented!')
  32     raise NotImplementedError('Method not implemented!')
  33
  34   def Put(self, request, context):
  35     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
  36     context.set_details('Method not implemented!')
  37     raise NotImplementedError('Method not implemented!')
  38
  39
  40 def add_KVServicer_to_server(servicer, server):
  41   rpc_method_handlers = {
  42       'Get': grpc.unary_unary_rpc_method_handler(
  43           servicer.Get,
  44           request_deserializer=kv__pb2.GetRequest.FromString,
  45           response_serializer=kv__pb2.GetResponse.SerializeToString,
  46       ),
  47       'Put': grpc.unary_unary_rpc_method_handler(
  48           servicer.Put,
  49           request_deserializer=kv__pb2.PutRequest.FromString,
  50           response_serializer=kv__pb2.Empty.SerializeToString,
  51       ),
  52   }
  53   generic_handler = grpc.method_handlers_generic_handler(
  54       'proto.KV', rpc_method_handlers)
  55   server.add_generic_rpc_handlers((generic_handler,))