rpc_pb2.py 文件源码

def add_KVServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Range': grpc.unary_unary_rpc_method_handler(
            servicer.Range,
            request_deserializer=RangeRequest.FromString,
            response_serializer=RangeResponse.SerializeToString,
        ),
        'Put': grpc.unary_unary_rpc_method_handler(
            servicer.Put,
            request_deserializer=PutRequest.FromString,
            response_serializer=PutResponse.SerializeToString,
        ),
        'DeleteRange': grpc.unary_unary_rpc_method_handler(
            servicer.DeleteRange,
            request_deserializer=DeleteRangeRequest.FromString,
            response_serializer=DeleteRangeResponse.SerializeToString,
        ),
        'Txn': grpc.unary_unary_rpc_method_handler(
            servicer.Txn,
            request_deserializer=TxnRequest.FromString,
            response_serializer=TxnResponse.SerializeToString,
        ),
        'Compact': grpc.unary_unary_rpc_method_handler(
            servicer.Compact,
            request_deserializer=CompactionRequest.FromString,
            response_serializer=CompactionResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'etcdserverpb.KV', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))