show worker queue size in the cluster status

pkg/controller/status.go

@@ -51,9 +51,15 @@ func (c *Controller) GetStatus() *spec.ControllerStatus {
 	clustersCnt := len(c.clusters)
 	c.clustersMu.RUnlock()
 
+	queueSizes := make(map[int]int, c.opConfig.Workers)
+	for workerID, queue := range c.clusterEventQueues {
+		queueSizes[workerID] = len(queue.ListKeys())
+	}
+
 	return &spec.ControllerStatus{
 		LastSyncTime:    atomic.LoadInt64(&c.lastClusterSyncTime),
 		Clusters:        clustersCnt,
+		WorkerQueueSize: queueSizes,
 	}
 }
 

pkg/spec/types.go

@@ -104,6 +104,7 @@ type ClusterStatus struct {
 type ControllerStatus struct {
 	LastSyncTime    int64
 	Clusters        int
+	WorkerQueueSize map[int]int
 }
 
 // QueueDump describes cache.FIFO queue