643
}
644
645
>
func workerHeartbeatToListInfo(hb *workerpb.WorkerHeartbeat) *workerpb.WorkerListInfo {
handler.go
646
>
hostInfo := hb.GetHostInfo()
647
>
return &workerpb.WorkerListInfo{
648
>
WorkerInstanceKey: hb.GetWorkerInstanceKey(),
649
>
WorkerIdentity: hb.GetWorkerIdentity(),
650
>
TaskQueue: hb.GetTaskQueue(),
651
>
DeploymentVersion: hb.GetDeploymentVersion(),
652
>
SdkName: hb.GetSdkName(),
653
>
SdkVersion: hb.GetSdkVersion(),
654
>
Status: hb.GetStatus(),
655
>
StartTime: hb.GetStartTime(),
656
>
HostName: hostInfo.GetHostName(),
657
>
WorkerGroupingKey: hostInfo.GetWorkerGroupingKey(),
658
>
ProcessId: hostInfo.GetProcessId(),
659
>
Plugins: hb.GetPlugins(),
660
>
Drivers: hb.GetDrivers(),
661
>
}
662
>
}
663
664
func (h *Handler) CountWorkers(