# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc

import basic_meta_pb2 as basic__meta__pb2
import computing_basic_pb2 as computing__basic__pb2
import node_manager_pb2 as node__manager__pb2


class NodeServiceStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.getProcessor = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/getProcessor',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoint.FromString,
        )
    self.getAllPossibleProcessors = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/getAllPossibleProcessors',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoints.FromString,
        )
    self.killProcessor = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/killProcessor',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoint.FromString,
        )
    self.killAllProcessors = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/killAllProcessors',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoints.FromString,
        )


class NodeServiceServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def getProcessor(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def getAllPossibleProcessors(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def killProcessor(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def killAllProcessors(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_NodeServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'getProcessor': grpc.unary_unary_rpc_method_handler(
          servicer.getProcessor,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoint.SerializeToString,
      ),
      'getAllPossibleProcessors': grpc.unary_unary_rpc_method_handler(
          servicer.getAllPossibleProcessors,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoints.SerializeToString,
      ),
      'killProcessor': grpc.unary_unary_rpc_method_handler(
          servicer.killProcessor,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoint.SerializeToString,
      ),
      'killAllProcessors': grpc.unary_unary_rpc_method_handler(
          servicer.killAllProcessors,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoints.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'com.webank.ai.eggroll.api.framework.egg.NodeService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))


class NodeManagerServiceStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.heartbeat = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeManagerService/heartbeat',
        request_serializer=node__manager__pb2.HeartbeatRequest.SerializeToString,
        response_deserializer=node__manager__pb2.HeartbeatResponse.FromString,
        )


class NodeManagerServiceServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def heartbeat(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_NodeManagerServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'heartbeat': grpc.unary_unary_rpc_method_handler(
          servicer.heartbeat,
          request_deserializer=node__manager__pb2.HeartbeatRequest.FromString,
          response_serializer=node__manager__pb2.HeartbeatResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'com.webank.ai.eggroll.api.framework.egg.NodeManagerService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))


class SessionServiceStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.getOrCreateSession = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.SessionService/getOrCreateSession',
        request_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
        response_deserializer=basic__meta__pb2.SessionInfo.FromString,
        )
    self.stopSession = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.SessionService/stopSession',
        request_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
        response_deserializer=basic__meta__pb2.SessionInfo.FromString,
        )
    self.getComputingEngine = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.SessionService/getComputingEngine',
        request_serializer=node__manager__pb2.ComputingEngineRequest.SerializeToString,
        response_deserializer=computing__basic__pb2.ComputingEngineDescriptor.FromString,
        )


class SessionServiceServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def getOrCreateSession(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def stopSession(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def getComputingEngine(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_SessionServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'getOrCreateSession': grpc.unary_unary_rpc_method_handler(
          servicer.getOrCreateSession,
          request_deserializer=basic__meta__pb2.SessionInfo.FromString,
          response_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
      ),
      'stopSession': grpc.unary_unary_rpc_method_handler(
          servicer.stopSession,
          request_deserializer=basic__meta__pb2.SessionInfo.FromString,
          response_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
      ),
      'getComputingEngine': grpc.unary_unary_rpc_method_handler(
          servicer.getComputingEngine,
          request_deserializer=node__manager__pb2.ComputingEngineRequest.FromString,
          response_serializer=computing__basic__pb2.ComputingEngineDescriptor.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'com.webank.ai.eggroll.api.framework.egg.SessionService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

cd1533ff9842b2477c75ce2f37442894de2ef74e
<mask token>


class NodeServiceServicer(object):
    pass

    def getProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')
    <mask token>
    <mask token>

    def killAllProcessors(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class NodeManagerServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.heartbeat = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.NodeManagerService/heartbeat'
            , request_serializer=node__manager__pb2.HeartbeatRequest.
            SerializeToString, response_deserializer=node__manager__pb2.
            HeartbeatResponse.FromString)


class NodeManagerServiceServicer(object):
    pass

    def heartbeat(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class SessionServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.getOrCreateSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getOrCreateSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.stopSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/stopSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.getComputingEngine = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getComputingEngine'
            , request_serializer=node__manager__pb2.ComputingEngineRequest.
            SerializeToString, response_deserializer=computing__basic__pb2.
            ComputingEngineDescriptor.FromString)


class SessionServiceServicer(object):
    pass

    def getOrCreateSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def stopSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def getComputingEngine(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

<mask token>


class NodeServiceServicer(object):
    pass

    def getProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')
    <mask token>

    def killProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def killAllProcessors(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class NodeManagerServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.heartbeat = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.NodeManagerService/heartbeat'
            , request_serializer=node__manager__pb2.HeartbeatRequest.
            SerializeToString, response_deserializer=node__manager__pb2.
            HeartbeatResponse.FromString)


class NodeManagerServiceServicer(object):
    pass

    def heartbeat(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class SessionServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.getOrCreateSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getOrCreateSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.stopSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/stopSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.getComputingEngine = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getComputingEngine'
            , request_serializer=node__manager__pb2.ComputingEngineRequest.
            SerializeToString, response_deserializer=computing__basic__pb2.
            ComputingEngineDescriptor.FromString)


class SessionServiceServicer(object):
    pass

    def getOrCreateSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def stopSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def getComputingEngine(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

<mask token>


class NodeServiceServicer(object):
    pass

    def getProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def getAllPossibleProcessors(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def killProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def killAllProcessors(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class NodeManagerServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.heartbeat = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.NodeManagerService/heartbeat'
            , request_serializer=node__manager__pb2.HeartbeatRequest.
            SerializeToString, response_deserializer=node__manager__pb2.
            HeartbeatResponse.FromString)


class NodeManagerServiceServicer(object):
    pass

    def heartbeat(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class SessionServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.getOrCreateSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getOrCreateSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.stopSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/stopSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.getComputingEngine = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getComputingEngine'
            , request_serializer=node__manager__pb2.ComputingEngineRequest.
            SerializeToString, response_deserializer=computing__basic__pb2.
            ComputingEngineDescriptor.FromString)


class SessionServiceServicer(object):
    pass

    def getOrCreateSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def stopSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def getComputingEngine(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

<mask token>


class NodeServiceStub(object):
    pass
    <mask token>


class NodeServiceServicer(object):
    pass

    def getProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def getAllPossibleProcessors(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def killProcessor(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def killAllProcessors(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class NodeManagerServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.heartbeat = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.NodeManagerService/heartbeat'
            , request_serializer=node__manager__pb2.HeartbeatRequest.
            SerializeToString, response_deserializer=node__manager__pb2.
            HeartbeatResponse.FromString)


class NodeManagerServiceServicer(object):
    pass

    def heartbeat(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>


class SessionServiceStub(object):
    pass

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.getOrCreateSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getOrCreateSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.stopSession = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/stopSession'
            , request_serializer=basic__meta__pb2.SessionInfo.
            SerializeToString, response_deserializer=basic__meta__pb2.
            SessionInfo.FromString)
        self.getComputingEngine = channel.unary_unary(
            '/com.webank.ai.eggroll.api.framework.egg.SessionService/getComputingEngine'
            , request_serializer=node__manager__pb2.ComputingEngineRequest.
            SerializeToString, response_deserializer=computing__basic__pb2.
            ComputingEngineDescriptor.FromString)


class SessionServiceServicer(object):
    pass

    def getOrCreateSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def stopSession(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def getComputingEngine(self, request, context):
        pass
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc

import basic_meta_pb2 as basic__meta__pb2
import computing_basic_pb2 as computing__basic__pb2
import node_manager_pb2 as node__manager__pb2


class NodeServiceStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.getProcessor = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/getProcessor',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoint.FromString,
        )
    self.getAllPossibleProcessors = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/getAllPossibleProcessors',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoints.FromString,
        )
    self.killProcessor = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/killProcessor',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoint.FromString,
        )
    self.killAllProcessors = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeService/killAllProcessors',
        request_serializer=basic__meta__pb2.Endpoint.SerializeToString,
        response_deserializer=basic__meta__pb2.Endpoints.FromString,
        )


class NodeServiceServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def getProcessor(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def getAllPossibleProcessors(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def killProcessor(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def killAllProcessors(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_NodeServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'getProcessor': grpc.unary_unary_rpc_method_handler(
          servicer.getProcessor,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoint.SerializeToString,
      ),
      'getAllPossibleProcessors': grpc.unary_unary_rpc_method_handler(
          servicer.getAllPossibleProcessors,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoints.SerializeToString,
      ),
      'killProcessor': grpc.unary_unary_rpc_method_handler(
          servicer.killProcessor,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoint.SerializeToString,
      ),
      'killAllProcessors': grpc.unary_unary_rpc_method_handler(
          servicer.killAllProcessors,
          request_deserializer=basic__meta__pb2.Endpoint.FromString,
          response_serializer=basic__meta__pb2.Endpoints.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'com.webank.ai.eggroll.api.framework.egg.NodeService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))


class NodeManagerServiceStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.heartbeat = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.NodeManagerService/heartbeat',
        request_serializer=node__manager__pb2.HeartbeatRequest.SerializeToString,
        response_deserializer=node__manager__pb2.HeartbeatResponse.FromString,
        )


class NodeManagerServiceServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def heartbeat(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_NodeManagerServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'heartbeat': grpc.unary_unary_rpc_method_handler(
          servicer.heartbeat,
          request_deserializer=node__manager__pb2.HeartbeatRequest.FromString,
          response_serializer=node__manager__pb2.HeartbeatResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'com.webank.ai.eggroll.api.framework.egg.NodeManagerService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))


class SessionServiceStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.getOrCreateSession = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.SessionService/getOrCreateSession',
        request_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
        response_deserializer=basic__meta__pb2.SessionInfo.FromString,
        )
    self.stopSession = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.SessionService/stopSession',
        request_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
        response_deserializer=basic__meta__pb2.SessionInfo.FromString,
        )
    self.getComputingEngine = channel.unary_unary(
        '/com.webank.ai.eggroll.api.framework.egg.SessionService/getComputingEngine',
        request_serializer=node__manager__pb2.ComputingEngineRequest.SerializeToString,
        response_deserializer=computing__basic__pb2.ComputingEngineDescriptor.FromString,
        )


class SessionServiceServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def getOrCreateSession(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def stopSession(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def getComputingEngine(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_SessionServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'getOrCreateSession': grpc.unary_unary_rpc_method_handler(
          servicer.getOrCreateSession,
          request_deserializer=basic__meta__pb2.SessionInfo.FromString,
          response_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
      ),
      'stopSession': grpc.unary_unary_rpc_method_handler(
          servicer.stopSession,
          request_deserializer=basic__meta__pb2.SessionInfo.FromString,
          response_serializer=basic__meta__pb2.SessionInfo.SerializeToString,
      ),
      'getComputingEngine': grpc.unary_unary_rpc_method_handler(
          servicer.getComputingEngine,
          request_deserializer=node__manager__pb2.ComputingEngineRequest.FromString,
          response_serializer=computing__basic__pb2.ComputingEngineDescriptor.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'com.webank.ai.eggroll.api.framework.egg.SessionService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
