| 程序包 | 说明 |
|---|---|
| com.github.kfcfans.powerjob.worker.core.ha | |
| com.github.kfcfans.powerjob.worker.core.tracker.task | |
| com.github.kfcfans.powerjob.worker.pojo.request |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ProcessorTrackerStatus.update(ProcessorTrackerStatusReportReq req)
接收到 ProcessorTracker 的心跳信息后,更新状态
|
void |
ProcessorTrackerStatusHolder.updateStatus(ProcessorTrackerStatusReportReq heartbeatReq)
根据 ProcessorTracker 的心跳更新状态
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
TaskTracker.receiveProcessorTrackerHeartbeat(ProcessorTrackerStatusReportReq heartbeatReq)
处理 ProcessorTracker 的心跳信息
|
| 限定符和类型 | 方法和说明 |
|---|---|
static ProcessorTrackerStatusReportReq |
ProcessorTrackerStatusReportReq.buildIdleReport(Long instanceId) |
static ProcessorTrackerStatusReportReq |
ProcessorTrackerStatusReportReq.buildLoadReport(Long instanceId,
Long remainTaskNum) |
Copyright © 2020. All rights reserved.