Function waitUntilLeaseExpires

internal/cli/cli_integration_test.go:4148–4166

(t *testing.T, leaseUntil time.Time, timeout time.Duration)

}

func waitUntilLeaseExpires(t *testing.T, leaseUntil time.Time, timeout time.Duration) {
	t.Helper()

	ctx, cancel := context.WithTimeout(context.Background(), timeout)
	defer cancel()
	ticker := time.NewTicker(10 * time.Millisecond)
	defer ticker.Stop()

	for {
		if time.Now().After(leaseUntil) {
			return
		}
		select {
		case <-ctx.Done():
			t.Fatalf("timed out waiting for lease expiry at %s", leaseUntil.Format(time.RFC3339Nano))
		case <-ticker.C:
		}
	}
}