Method getWorkerStatistics

internal/worker_node/worker_node.go:223–231

()

}

func (w *WorkerNode) getWorkerStatistics() (*proto.NodeHeartbeatMessage, error) {
	hardwareUsage := hardware.GetHardwareUsage()

	return &proto.NodeHeartbeatMessage{
		NodeID:      w.Name,
		CpuUsage:    hardwareUsage.CpuUsage,
		MemoryUsage: hardwareUsage.MemoryUsage,
	}, nil
}

func (w *WorkerNode) sendHeartbeatLoop(cfg *config.WorkerNodeConfig) {
	pollContext, cancel := context.WithTimeout(context.Background(), 5*time.Second)