- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 226 for Backoff (0.1 sec)
-
pkg/kubeapiserver/options/authorization.go
WebhookCacheUnauthorizedTTL time.Duration // WebhookRetryBackoff specifies the backoff parameters for the authorization webhook retry logic. // This allows us to configure the sleep time at each iteration and the maximum number of retries allowed // before we fail the webhook call in order to limit the fan out that ensues when the system is degraded. WebhookRetryBackoff *wait.Backoff // AuthorizationConfigurationFile is mutually exclusive with all of:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/container/testing/runtime_mock.go
m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SyncPod", ctx, pod, podStatus, pullSecrets, backOff) ret0, _ := ret[0].(container.PodSyncResult) return ret0 } // SyncPod indicates an expected call of SyncPod. func (mr *MockRuntimeMockRecorder) SyncPod(ctx, pod, podStatus, pullSecrets, backOff any) *gomock.Call { mr.mock.ctrl.T.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/webhook/webhook_test.go
f.Close() os.Remove(f.Name()) }() // NOTE(ericchiang): Do we need to use a proper serializer? require.NoError(t, stdjson.NewEncoder(f).Encode(config), "writing kubeconfig") retryBackoff := wait.Backoff{ Duration: 500 * time.Millisecond, Factor: 1.5, Jitter: 0.2, Steps: 5, } b, err := NewBackend(f.Name(), groupVersion, retryBackoff, nil) require.NoError(t, err, "initializing backend")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 08 06:37:26 UTC 2022 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/timer.go
"time" "k8s.io/utils/clock" ) // Timer abstracts how wait functions interact with time runtime efficiently. Test // code may implement this interface directly but package consumers are encouraged // to use the Backoff type as the primary mechanism for acquiring a Timer. The // interface is a simplification of clock.Timer to prevent misuse. Timers are not // expected to be safe for calls from multiple goroutines. type Timer interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 2.9K bytes - Viewed (0) -
internal/event/target/kafka.go
// These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 config.Producer.Retry.Max = 2 config.Producer.Retry.Backoff = (1 * time.Second) config.Producer.Return.Successes = true config.Producer.Return.Errors = true config.Producer.RequiredAcks = 1 config.Producer.Timeout = (5 * time.Second) // Set Producer Compression
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/kubelet/images/image_manager_test.go
container = &v1.Container{ Name: "container_name", Image: c.containerImage, ImagePullPolicy: c.policy, } backOff := flowcontrol.NewBackOff(time.Second, time.Minute) fakeClock = testingclock.NewFakeClock(time.Now()) backOff.Clock = fakeClock fakeRuntime = &ctest.FakeRuntime{T: t} fakeRecorder := &record.FakeRecorder{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19K bytes - Viewed (0) -
security/pkg/pki/ca/ca.go
enableJitter: enableJitter, client: client, }, } // always use ``istio-ca-secret` in priority, otherwise fall back to `cacerts` var caCertName string b := backoff.NewExponentialBackOff(backoff.DefaultOption()) err = b.RetryWithContext(ctx, func() error { caCertName = CASecret // 1. fetch `istio-ca-secret` in priority
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 30 19:33:26 UTC 2023 - 17.2K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
syncJobBatchPeriod = time.Second // DefaultJobApiBackOff is the default API backoff period. Exported for tests. DefaultJobApiBackOff = time.Second // MaxJobApiBackOff is the max API backoff period. Exported for tests. MaxJobApiBackOff = time.Minute // DefaultJobPodFailureBackOff is the default pod failure backoff period. Exported for tests. DefaultJobPodFailureBackOff = 10 * time.Second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (1) -
pkg/test/kube/dump.go
// it. Note: this doesn't make the test fail, just adds logging; if we hit this code the test // already failed. // We add backoff because we may see transient warming errors during cleanup of resources. attempts := 0 backoff := time.Second * 1 // Try after 0s, 1s, 2s, 4s, 8s, or 7s total for { attempts++ warming := isWarming(cfgDump) if warming == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 22.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
/** How long to wait to retry pre-emptive connection attempts that fail. */ @JvmField val backoffDelayMillis: Long = 60 * 1000, /** How much jitter to introduce in connection retry backoff delays */ @JvmField val backoffJitterMillis: Int = 100, )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 03 20:39:41 UTC 2024 - 5.6K bytes - Viewed (0)