- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 754 for retryOn (0.14 sec)
-
tests/integration/pilot/common/routing.go
}, }, }, workloadAgnostic: true, }) // Retry conditions have been added to just check that config is correct. // Retries are not specifically tested. TODO if we actually test retries, include proxyless t.RunTraffic(TrafficTestCase{ name: "retry conditions", config: ` apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner.go
// record the soonest requested retry time in bfr.retryTime and then only signal // the Loop thread once, just like Run does. bfr.retryMu.Lock() defer bfr.retryMu.Unlock() if !bfr.retryTime.IsZero() && bfr.retryTime.Before(retryTime) { return } bfr.retryTime = retryTime select { case bfr.retry <- struct{}{}: default: } } // assumes the lock is not held
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 9.4K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.test-retry.gradle.kts
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 26 06:43:17 UTC 2023 - 810 bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
retryOn: description: Specifies the conditions under which retry takes place. type: string retryRemoteLocalities: description: Flag to specify whether the retries should retry to other localities.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:42 UTC 2024 - 671.6K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner_test.go
lock sync.Mutex run bool retryFn func() } func (r *receiver) F() { r.lock.Lock() defer r.lock.Unlock() r.run = true if r.retryFn != nil { r.retryFn() r.retryFn = nil } } func (r *receiver) reset() bool { r.lock.Lock() defer r.lock.Unlock() was := r.run r.run = false return was } func (r *receiver) setRetryFn(retryFn func()) { r.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 12.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/flags.go
} // DefaultCallRetryOptions returns the default call retry options as specified in command-line flags. func DefaultCallRetryOptions() []retry.Option { return []retry.Option{retry.Timeout(callTimeout), retry.BackoffDelay(callDelay), retry.Converge(callConverge)} } // DefaultReadinessTimeout returns the default echo readiness check timeout.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 13 17:44:00 UTC 2022 - 2.4K bytes - Viewed (0) -
operator/cmd/mesh/testdata/manifest-generate/output/all_on.golden-show-in-gh-pull-request.yaml
retryOn: description: Specifies the conditions under which retry takes place. type: string retryRemoteLocalities: description: Flag to specify whether the retries should retry to other localities.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 05:10:03 UTC 2024 - 506.8K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
} in 15..17 -> { type = null // 'event' on a line of its own } in 18..19 -> { val retryMs = source.readRetryMs() if (retryMs != -1L) { callback.onRetryChange(retryMs) } } -1 -> { val lineEnd = source.indexOfElement(CRLF) if (lineEnd != -1L) { // Skip the line and newline
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.3K bytes - Viewed (0) -
security/pkg/credentialfetcher/plugin/leak_test.go
// metadata server code against a fake metadata server. We do not control the client, and cannot // configure it to exit early, retry faster, etc - its all fixed. As a result, we don't have a good // way to shut it down if it is still retrying in the background.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 12 20:52:37 UTC 2021 - 1020 bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Tue Jul 07 10:50:16 UTC 2020 - 31K bytes - Viewed (0)