From 394128a0f266b5a343f583fe18f992cc0d171084 Mon Sep 17 00:00:00 2001 From: Jose Fernandez Date: Thu, 14 Sep 2023 12:32:19 -0600 Subject: [PATCH] feat: Add methods to get length of PodController queues (#1145) --- node/podcontroller.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/node/podcontroller.go b/node/podcontroller.go index 3dd83365e..0fda4c433 100644 --- a/node/podcontroller.go +++ b/node/podcontroller.go @@ -453,6 +453,21 @@ func (pc *PodController) Err() error { return pc.err } +// SyncPodsFromKubernetesQueueLen returns the length of the SyncPodsFromKubernetes queue +func (pc *PodController) SyncPodsFromKubernetesQueueLen() int { + return pc.syncPodsFromKubernetes.Len() +} + +// DeletePodsFromKubernetesQueueLen returns the length of the DeletePodsFromKubernetes queue +func (pc *PodController) DeletePodsFromKubernetesQueueLen() int { + return pc.deletePodsFromKubernetes.Len() +} + +// SyncPodStatusFromProviderQueueLen returns the length of the SyncPodStatusFromProvider queue +func (pc *PodController) SyncPodStatusFromProviderQueueLen() int { + return pc.syncPodStatusFromProvider.Len() +} + // syncPodFromKubernetesHandler compares the actual state with the desired, and attempts to converge the two. func (pc *PodController) syncPodFromKubernetesHandler(ctx context.Context, key string) error { ctx, span := trace.StartSpan(ctx, "syncPodFromKubernetesHandler")