com.github.kfcfans.powerjob.worker.core.ha

类 ProcessorTrackerStatusHolder

java.lang.Object

com.github.kfcfans.powerjob.worker.core.ha.ProcessorTrackerStatusHolder

public class ProcessorTrackerStatusHolder
extends Object

统一管理 ProcessorTracker 的状态

从以下版本开始:

2020/3/28

作者:

tjq

构造器概要

构造器

构造器和说明
ProcessorTrackerStatusHolder(List<String> allWorkerAddress)

方法概要

限定符和类型	方法和说明
List<String>	getAllDisconnectedProcessorTrackers() 获取所有失联 ProcessorTracker 的IP地址
List<String>	getAllProcessorTrackers() 获取所有 ProcessorTracker 的IP地址（包括不可用状态）
List<String>	getAvailableProcessorTrackers() 获取可用 ProcessorTracker 的IP地址
ProcessorTrackerStatus	getProcessorTrackerStatus(String address)
void	updateStatus(ProcessorTrackerStatusReportReq heartbeatReq) 根据 ProcessorTracker 的心跳更新状态

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

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

构造器详细资料

ProcessorTrackerStatusHolder

public ProcessorTrackerStatusHolder(List<String> allWorkerAddress)

方法详细资料

getProcessorTrackerStatus

public ProcessorTrackerStatus getProcessorTrackerStatus(String address)

updateStatus

public void updateStatus(ProcessorTrackerStatusReportReq heartbeatReq)

根据 ProcessorTracker 的心跳更新状态

getAvailableProcessorTrackers

public List<String> getAvailableProcessorTrackers()

获取可用 ProcessorTracker 的IP地址

getAllProcessorTrackers

public List<String> getAllProcessorTrackers()

获取所有 ProcessorTracker 的IP地址（包括不可用状态）

getAllDisconnectedProcessorTrackers

public List<String> getAllDisconnectedProcessorTrackers()

获取所有失联 ProcessorTracker 的IP地址