com.alibaba.schedulerx.worker.discovery

类 DefaultServerDiscovery

java.lang.Object

com.alibaba.schedulerx.worker.discovery.DefaultServerDiscovery

所有已实现的接口:

ServerDiscovery

public class DefaultServerDiscovery
extends Object
implements ServerDiscovery

heart beat get active leader of specific group through console.

作者:

@yanxun

构造器概要

构造器

构造器和说明
DefaultServerDiscovery()

方法概要

限定符和类型	方法和说明
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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DefaultServerDiscovery

public DefaultServerDiscovery()

方法详细资料

start

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

从接口复制的说明: ServerDiscovery

start sync process for keeping cache up to date

指定者:

start 在接口中 ServerDiscovery

抛出:

Exception - exceptions thrown in start process

getActiveServerAddr

public String getActiveServerAddr()

从接口复制的说明: ServerDiscovery

get active server ip and port

指定者:

getActiveServerAddr 在接口中 ServerDiscovery

返回:

active server's ip:port

getActiveHeartBeatActor

public akka.actor.ActorSelection getActiveHeartBeatActor()

从接口复制的说明: ServerDiscovery

get active heartbeat's actor path

指定者:

getActiveHeartBeatActor 在接口中 ServerDiscovery

返回:

active heartbeat actor

stop

public void stop()
          throws Exception

从接口复制的说明: ServerDiscovery

stop sync process for releasing resources

指定者:

stop 在接口中 ServerDiscovery

抛出:

Exception - exceptions thrown in stop process

getInstanceStatusRouter

public akka.actor.ActorSelection getInstanceStatusRouter()

指定者:

getInstanceStatusRouter 在接口中 ServerDiscovery

getMapMasterRouter

public akka.actor.ActorSelection getMapMasterRouter()

指定者:

getMapMasterRouter 在接口中 ServerDiscovery

getTaskStatusRouter

public akka.actor.ActorSelection getTaskStatusRouter()

指定者:

getTaskStatusRouter 在接口中 ServerDiscovery

getStandbyServerHeatbeatActors

@Deprecated
public List<akka.actor.ActorSelection> getStandbyServerHeatbeatActors()

已过时。

指定者:

getStandbyServerHeatbeatActors 在接口中 ServerDiscovery

reset

public void reset(akka.actor.ActorSystem actorSystem)

指定者:

reset 在接口中 ServerDiscovery