- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for waitForWithContext (0.2 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
type waitWithContextFunc func(ctx context.Context) <-chan struct{} // waitForWithContext continually checks 'fn' as driven by 'wait'. // // waitForWithContext gets a channel from 'wait()”, and then invokes 'fn' // once for every value placed on the channel and once more when the // channel is closed. If the channel is closed and 'fn' // returns false without error, waitForWithContext returns ErrWaitTimeout. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
// waitForWithContext cancels the context it supplies to the WaitWithContextFunc. func Test_waitForWithContextCancelsContext(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() waitFn := poller(time.Millisecond, ForeverTestTimeout) var ctxPassedToWait context.Context waitForWithContext(ctx, func(ctx context.Context) <-chan struct{} {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go
} } select { case <-ctx.Done(): // returning ctx.Err() will break backward compatibility, use new PollUntilContext* // methods instead return ErrWaitTimeout default: return waitForWithContext(ctx, wait, condition) } } // poller returns a WaitFunc that will send to the channel every interval until // timeout has elapsed and then closes the channel. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 06:13:35 UTC 2023 - 14K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
- The `WaitFor` and `WaitForWithContext` functions in the wait package have now been marked private. Callers should use the equivalent `Poll*` method with a zero duration interval. ([#115116](https://github.com/kubernetes/kubernetes/pull/115116), [@smarterclayton](https://github....
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 23:01:06 UTC 2024 - 455.3K bytes - Viewed (0)