Function calculateWorkerStats

pkg/cmd/workerpool/view/view.go:187–219

(workers []*machines.Worker)

}

func calculateWorkerStats(workers []*machines.Worker) WorkerStats {
	stats := WorkerStats{}

	for _, worker := range workers {
		stats.Total++

		if worker.IsDisabled {
			stats.Disabled++
		}

		switch worker.HealthStatus {
		case "Healthy":
			stats.Healthy++
		case "HasWarnings":
			stats.HasWarnings++
		case "Unhealthy":
			stats.Unhealthy++
		case "Unavailable":
			stats.Unavailable++
		}

		switch worker.Endpoint.GetCommunicationStyle() {
		case "Ssh":
			stats.SSH++
		case "TentaclePassive":
			stats.ListeningTentacle++
		case "TentacleActive":
			stats.PollingTentacle++
		}
	}

	return stats
}