rpc_pb2.py 文件源码

def add_ClusterServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'MemberAdd': grpc.unary_unary_rpc_method_handler(
            servicer.MemberAdd,
            request_deserializer=MemberAddRequest.FromString,
            response_serializer=MemberAddResponse.SerializeToString,
        ),
        'MemberRemove': grpc.unary_unary_rpc_method_handler(
            servicer.MemberRemove,
            request_deserializer=MemberRemoveRequest.FromString,
            response_serializer=MemberRemoveResponse.SerializeToString,
        ),
        'MemberUpdate': grpc.unary_unary_rpc_method_handler(
            servicer.MemberUpdate,
            request_deserializer=MemberUpdateRequest.FromString,
            response_serializer=MemberUpdateResponse.SerializeToString,
        ),
        'MemberList': grpc.unary_unary_rpc_method_handler(
            servicer.MemberList,
            request_deserializer=MemberListRequest.FromString,
            response_serializer=MemberListResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'etcdserverpb.Cluster', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))