d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

feat: Add methods to get length of PodController queues (#1145)

Browse Source
This commit is contained in:
Jose Fernandez
2023-09-14 12:32:19 -06:00
committed by GitHub
parent 72045b221b
commit 394128a0f2
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
node/podcontroller.go
View File

@@ -453,6 +453,21 @@ func (pc *PodController) Err() error {
return pc.err 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. // syncPodFromKubernetesHandler compares the actual state with the desired, and attempts to converge the two.
func (pc *PodController) syncPodFromKubernetesHandler(ctx context.Context, key string) error { func (pc *PodController) syncPodFromKubernetesHandler(ctx context.Context, key string) error {
ctx, span := trace.StartSpan(ctx, "syncPodFromKubernetesHandler") ctx, span := trace.StartSpan(ctx, "syncPodFromKubernetesHandler")