Report as debug log, the time spent waiting for resources

Signed-off-by: Benoit Tigeot <benoit.tigeot@lifen.fr>
pull/30689/head
Benoit Tigeot 6 months ago
parent 07a57c6073
commit 5e7f12d4c3
No known key found for this signature in database
GPG Key ID: 8E6D4FC8AEBDA62C

@ -49,6 +49,7 @@ type waiter struct {
func (w *waiter) waitForResources(created ResourceList) error {
w.log("beginning wait for %d resources with timeout of %v", len(created), w.timeout)
startTime := time.Now()
ctx, cancel := context.WithTimeout(context.Background(), w.timeout)
defer cancel()
@ -57,7 +58,7 @@ func (w *waiter) waitForResources(created ResourceList) error {
numberOfErrors[i] = 0
}
return wait.PollUntilContextCancel(ctx, 2*time.Second, true, func(ctx context.Context) (bool, error) {
err := wait.PollUntilContextCancel(ctx, 2*time.Second, true, func(ctx context.Context) (bool, error) {
waitRetries := 30
for i, v := range created {
ready, err := w.c.IsReady(ctx, v)
@ -78,6 +79,15 @@ func (w *waiter) waitForResources(created ResourceList) error {
}
return true, nil
})
elapsed := time.Since(startTime).Round(time.Second)
if err != nil {
w.log("wait for resources failed after %v: %v", elapsed, err)
} else {
w.log("wait for ressources succeeded within %v", elapsed)
}
return err
}
func (w *waiter) isRetryableError(err error, resource *resource.Info) bool {

Loading…
Cancel
Save