- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 754 for retryOn (0.16 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy
lock2.doIsLockedByCurrentThread() == (!lock1Locked && !lock2Locked) where: lock1Locked | lock2Locked | expectedDisposition true | true | RETRY true | false | RETRY false | true | RETRY false | false | FINISHED } def "can unlock resources with unlock"() { def lock1 = resourceLock("lock1", lock1Locked, true)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 15.4K bytes - Viewed (0) -
tests/integration/ambient/wasm_test.go
} return nil } func sendTraffic(ctx framework.TestContext, checker echo.Checker, options ...retry.Option) { ctx.Helper() if len(GetClientInstances()) == 0 { ctx.Fatal("there is no client") } cltInstance := GetClientInstances()[0] defaultOptions := []retry.Option{retry.Delay(100 * time.Millisecond), retry.Timeout(200 * time.Second)} httpOpts := echo.CallOptions{ To: GetTarget(), Port: echo.Port{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 7.2K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
} }) workingDNSServer.setFailure(false) t.Run("resolution recovered", func(t *testing.T) { // addresses should be updated retry.UntilOrFail(t, func() bool { return !reflect.DeepEqual(env.NetworkManager.AllGateways(), gateways) }, retry.Timeout(10*model.MinGatewayTTL), retry.Delay(time.Millisecond*10)) xdsUpdater.WaitOrFail(t, "xds full") }) workingDNSServer.setHosts(make(sets.String))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go
return true } // if the error sends the Retry-After header, we respect it as an explicit confirmation we should retry. if _, shouldRetry := apierrors.SuggestsClientDelay(err); shouldRetry { return true } return false } // NewGenericWebhook creates a new GenericWebhook from the provided rest.Config.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
return err } func (spc *StatefulPodControl) UpdateStatefulPod(ctx context.Context, set *apps.StatefulSet, pod *v1.Pod) error { attemptedUpdate := false err := retry.RetryOnConflict(retry.DefaultBackoff, func() error { // assume the Pod is consistent consistent := true // if the Pod does not conform to its identity, update the identity and dirty the Pod if !identityMatches(set, pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
cluster/gce/gci/master.yaml
ExecStartPre=/bin/mount --bind /home/kubernetes/bin /home/kubernetes/bin ExecStartPre=/bin/mount -o remount,exec /home/kubernetes/bin ExecStartPre=/usr/bin/curl --fail --retry 600 --retry-delay 3 --retry-connrefused --connect-timeout 10 --silent --show-error -H "X-Google-Metadata-Request: True" -o /home/kubernetes/bin/configure.sh http://metadata.google.internal/computeMetadata/v1/instance/attributes/configure-sh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 12 16:22:20 UTC 2021 - 5.5K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
} } return nil }, retry.Timeout(retryTimeOut), retry.Delay(retryDelay)) // test operator remove command by purge scopes.Framework.Infof("checking operator remove command") removeCmd = []string{ "operator", "remove", "--skip-confirmation", "--purge", } istioCtl.InvokeOrFail(t, removeCmd) retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/server_tracing_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.3K bytes - Viewed (0) -
src/testing/testing_other.go
// license that can be found in the LICENSE file. //go:build !windows package testing import "time" // isWindowsRetryable reports whether err is a Windows error code // that may be fixed by retrying a failed filesystem operation. func isWindowsRetryable(err error) bool { return false } // highPrecisionTime represents a single point in time. // On all systems except Windows, using time.Time is fine.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Apr 27 19:42:36 UTC 2024 - 876 bytes - Viewed (0) -
pkg/test/framework/components/echo/common/call.go
} return result, err } if opts.Retry.NoRetry { // Retry is disabled, just send once. t0 := time.Now() defer func() { scopes.Framework.Debugf("echo call complete with duration %v", time.Since(t0)) }() return sendAndValidate() } // Retry the call until it succeeds or times out. var result echo.CallResult var err error _, _ = retry.UntilComplete(func() (any, bool, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 6.7K bytes - Viewed (0)