- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 754 for retryFn (3.76 sec)
-
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) -
pilot/pkg/networking/core/route/retry/retry.go
out.RetryOn, out.RetriableStatusCodes = parseRetryOn(in.RetryOn) // If user has just specified HTTP status codes in retryOn but have not specified "retriable-status-codes", let us add it. if len(out.RetriableStatusCodes) > 0 && !strings.Contains(out.RetryOn, "retriable-status-codes") { out.RetryOn += ",retriable-status-codes" } } if in.PerTryTimeout != nil { out.PerTryTimeout = in.PerTryTimeout }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 5K bytes - Viewed (0) -
bin/retry.sh
# limitations under the License. # retry.sh retries a command until it succeeds. It accepts a regex pattern to match failures on to # determine if a retry should be attempted. # Example: retry.sh "connection timed out" ./my-flaky-script.sh some args # This will run "my-flaky-script.sh", retrying any failed runs that output "connection timed out" up # to 5 times. function fail {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 11 16:08:08 UTC 2021 - 2K bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry_test.go
g.Expect(policy).To(Not(BeNil())) g.Expect(policy.RetryOn).To(Equal(retry.DefaultPolicy().RetryOn)) g.Expect(policy.RetriableStatusCodes).To(Equal(retry.DefaultPolicy().RetriableStatusCodes)) }, }, { name: "TestMissingPerTryTimeoutShouldReturnNil", // Create a route with a retry policy without per try timeout. route: &networking.HTTPRoute{ Retries: &networking.HTTPRetry{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/security/retry.go
var CARetryOptions = []retry.CallOption{ retry.WithMax(5), retry.WithBackoff(wrapBackoffWithMetrics(retry.BackoffExponentialWithJitter(100*time.Millisecond, 0.1))), retry.WithCodes(codes.Canceled, codes.DeadlineExceeded, codes.ResourceExhausted, codes.Aborted, codes.Internal, codes.Unavailable), } // CARetryInterceptor is a grpc UnaryInterceptor that adds retry options, as a convenience wrapper
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/test/util/retry/retry.go
// limitations under the License. package retry import ( "errors" "fmt" "time" "istio.io/istio/pkg/log" "istio.io/istio/pkg/test" ) var scope = log.RegisterScope("retry", "logs for retries") const ( // DefaultTimeout the default timeout for the entire retry operation DefaultTimeout = time.Second * 30 // DefaultDelay the default delay between successive retry attempts
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 5.6K bytes - Viewed (0) -
src/runtime/retry.go
// license that can be found in the LICENSE file. //go:build unix package runtime // retryOnEAGAIN retries a function until it does not return EAGAIN. // It will use an increasing delay between calls, and retry up to 20 times. // The function argument is expected to return an errno value, // and retryOnEAGAIN will return any errno value other than EAGAIN. // If all retries return EAGAIN, then retryOnEAGAIN will return EAGAIN.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 10 20:44:45 UTC 2022 - 760 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) -
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)