monitor

Documentation

Index

• type Heartbeat
  • func NewDefaultHeartBeat(machineType MACHINE_TYPE) (*Heartbeat, error)
  • func NewHeartBeat(workerName string, machineType MACHINE_TYPE) (*Heartbeat, error)
• type MACHINE_TYPE

Types

type Heartbeat

type Heartbeat struct {
	UUID        string
	WorkerName  string
	MachineType MACHINE_TYPE
	Ip          string
	CpuNum      int
	CpuUsage    float64
	MemNum      string
	MemUsage    float64
	TaskNum     int
	Timestamp   int64
}

TODO 丰富监听心跳的信息

func NewDefaultHeartBeat

func NewDefaultHeartBeat(machineType MACHINE_TYPE) (*Heartbeat, error)

NewSignature creates a new heartbeat signature

func NewHeartBeat

func NewHeartBeat(workerName string, machineType MACHINE_TYPE) (*Heartbeat, error)

NewSignature creates a new heartbeat signature

type MACHINE_TYPE

type MACHINE_TYPE string

const (
	MACHINERY_SERVER MACHINE_TYPE = "machinery-server" //server节点
	SPARK_CLUSTER    MACHINE_TYPE = "spark-cluster"    //spark集群
	FLINK_CLUSTER    MACHINE_TYPE = "flink-cluster"    //flink集群
	HADOOP_CLUSTER   MACHINE_TYPE = "hadoop-cluster"   //flink集群
	K8S_CLUSTER      MACHINE_TYPE = "k8s-cluster"      //k8s集群
	OTHER_CLUSTER    MACHINE_TYPE = "other-cluster"    //其他
)

TODO 丰富machine type