diff --git a/pkg/collector/k8s_api.go b/pkg/collector/k8s_api.go index 2a995d459..02ff1c8ec 100644 --- a/pkg/collector/k8s_api.go +++ b/pkg/collector/k8s_api.go @@ -150,11 +150,11 @@ func (c *k8sAPICollector) ComputeMetadata(ctx context.Context, ingestor Metadata } func (c *k8sAPICollector) wait(_ context.Context, resourceType string, tags []string) { + c.mu.Lock() prev := time.Now() now := c.rl.Take() waitTime := now.Sub(prev) - c.mu.Lock() defer c.mu.Unlock() c.waitTime[resourceType] += waitTime