package tech.powerjob.common.request;
|
|
import tech.powerjob.common.PowerSerializable;
|
import tech.powerjob.common.model.DeployedContainerInfo;
|
import tech.powerjob.common.model.SystemMetrics;
|
import lombok.Data;
|
|
import java.util.List;
|
|
|
/**
|
* Worker 上报健康信息（worker定时发送的heartbeat）
|
*
|
* @author tjq
|
* @since 2020/3/25
|
*/
|
@Data
|
public class WorkerHeartbeat implements PowerSerializable {
|
|
/**
|
* 本机地址 -> IP:port
|
*/
|
private String workerAddress;
|
/**
|
* 当前 appName
|
*/
|
private String appName;
|
/**
|
* 当前 appId
|
*/
|
private Long appId;
|
/**
|
* 当前时间
|
*/
|
private long heartbeatTime;
|
/**
|
* 当前加载的容器（容器名称 -> 容器版本）
|
*/
|
private List<DeployedContainerInfo> containerInfos;
|
/**
|
* worker 版本信息
|
*/
|
private String version;
|
/**
|
* 使用的通讯协议 AKKA / HTTP
|
*/
|
private String protocol;
|
/**
|
* worker tag，标识同一个 worker 下的一类集群 ISSUE: 226
|
*/
|
private String tag;
|
/**
|
* 客户端名称
|
*/
|
private String client;
|
/**
|
* 扩展字段
|
*/
|
private String extra;
|
/**
|
* 是否已经超载，超载的情况下 Server 一段时间内不会再向其派发任务
|
*/
|
private boolean isOverload;
|
|
private int lightTaskTrackerNum;
|
|
private int heavyTaskTrackerNum;
|
|
|
private SystemMetrics systemMetrics;
|
}
|
