com.alibaba.schedulerx.worker.discovery

接口 ServerDiscovery

所有已知实现类:

DefaultServerDiscovery

public interface ServerDiscovery

Created by yanxun on 2018/5/23.

作者:

yanxun

方法概要

限定符和类型	方法和说明
akka.actor.ActorSelection	getActiveHeartBeatActor() get active heartbeat's actor path
String	getActiveServerAddr() get active server ip and port
akka.actor.ActorSelection	getInstanceStatusRouter()
akka.actor.ActorSelection	getMapMasterRouter()
List<akka.actor.ActorSelection>	getStandbyServerHeatbeatActors()
akka.actor.ActorSelection	getTaskStatusRouter()
void	reset(akka.actor.ActorSystem actorSystem)
void	start(String namespace, String namespaceSource, String groupId) start sync process for keeping cache up to date
void	stop() stop sync process for releasing resources

方法详细资料

start

void start(String namespace,
           String namespaceSource,
           String groupId)
    throws Exception

start sync process for keeping cache up to date

抛出:

Exception - exceptions thrown in start process

stop

void stop()
   throws Exception

stop sync process for releasing resources

抛出:

Exception - exceptions thrown in stop process

reset

void reset(akka.actor.ActorSystem actorSystem)

getActiveServerAddr

String getActiveServerAddr()

get active server ip and port

返回:

active server's ip:port

getStandbyServerHeatbeatActors

List<akka.actor.ActorSelection> getStandbyServerHeatbeatActors()

getActiveHeartBeatActor

akka.actor.ActorSelection getActiveHeartBeatActor()

get active heartbeat's actor path

返回:

active heartbeat actor

getInstanceStatusRouter

akka.actor.ActorSelection getInstanceStatusRouter()

getMapMasterRouter

akka.actor.ActorSelection getMapMasterRouter()

getTaskStatusRouter

akka.actor.ActorSelection getTaskStatusRouter()