- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PollImmediateWithContext (0.27 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go
return PollImmediateWithContext(context.Background(), interval, timeout, condition.WithContext()) } // PollImmediateWithContext tries a condition func until it returns true, an error, // or the timeout is reached or the specified context expires, whichever happens first. // // PollImmediateWithContext always checks 'condition' before waiting for the interval.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 06:13:35 UTC 2023 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/fake.go
return errors.New(cmp.Diff(f.expect.Actions, f.Actions)) } return nil } func (f *fakeResourceManager) WaitForActions(ctx context.Context, timeout time.Duration) error { err := wait.PollImmediateWithContext( ctx, 100*time.Millisecond, // try every 100ms timeout, // timeout after timeout func(ctx context.Context) (done bool, err error) { if f.HasExpectedNumberActions() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
} // really make sure that the immediate check does not hang var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, kmsPluginCloseGracePeriod) defer cancel() pollErr := wait.PollImmediateWithContext(ctx, 100*time.Millisecond, kmsPluginCloseGracePeriod, func(ctx context.Context) (bool, error) { // create a fake http get request to health check endpoint
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0)