show worker queue size in the cluster status

zalando · Aug 28, 2017 · 53ceede · 53ceede
1 parent f44c8e1
commit 53ceede
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/pkg/controller/status.go b/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,
+		LastSyncTime:    atomic.LoadInt64(&c.lastClusterSyncTime),
+		Clusters:        clustersCnt,
+		WorkerQueueSize: queueSizes,
 	}
 }
 

diff --git a/pkg/spec/types.go b/pkg/spec/types.go
@@ -102,8 +102,9 @@ type ClusterStatus struct {
 
 // ControllerStatus describes status of the controller
 type ControllerStatus struct {
-	LastSyncTime int64
-	Clusters     int
+	LastSyncTime    int64
+	Clusters        int
+	WorkerQueueSize map[int]int
 }
 
 // QueueDump describes cache.FIFO queue