- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 226 for Backoff (0.28 sec)
-
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go
newObj interface{} expectedHint framework.QueueingHint wantErr bool }{ { name: "backoff-wrong-new-object", newObj: "not-a-node", expectedHint: framework.Queue, wantErr: true, }, { name: "backoff-wrong-old-object", newObj: nodeWithTaints("nodeA", []v1.Taint{{Key: "dedicated", Value: "user1", Effect: "NoSchedule"}}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// The accompanying status message should explain why the pod is unschedulable. // // We regard the backoff as a penalty of wasting the scheduling cycle. // When the scheduling queue requeues Pods, which was rejected with Unschedulable in the last scheduling, // the Pod goes through backoff. Unschedulable // UnschedulableAndUnresolvable is used when a plugin finds a pod unschedulable and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/kubeapiserver/authenticator/config.go
WebhookTokenAuthnCacheTTL time.Duration // WebhookRetryBackoff specifies the backoff parameters for the authentication 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 TokenSuccessCacheTTL time.Duration TokenFailureCacheTTL time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 15.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/delay.go
) // DelayFunc returns the next time interval to wait. type DelayFunc func() time.Duration // Timer takes an arbitrary delay function and returns a timer that can handle arbitrary interval changes. // Use Backoff{...}.Timer() for simple delays and more efficient timers. func (fn DelayFunc) Timer(c clock.Clock) Timer { return &variableTimer{fn: fn, new: c.NewTimer} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater.go
} func (ssu *realStatefulSetStatusUpdater) UpdateStatefulSetStatus( ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error { // don't wait due to limited number of clients, but backoff after the default number of steps return retry.RetryOnConflict(retry.DefaultRetry, func() error { set.Status = *status // TODO: This context.TODO should use a real context once we have RetryOnConflictWithContext
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/audit.go
fs.DurationVar(&o.InitialBackoff, "audit-webhook-initial-backoff", o.InitialBackoff, "The amount of time to wait before retrying the first failed request.") fs.DurationVar(&o.InitialBackoff, "audit-webhook-batch-initial-backoff", o.InitialBackoff, "The amount of time to wait before retrying the first failed request.") fs.MarkDeprecated("audit-webhook-batch-initial-backoff", "Deprecated, use --audit-webhook-initial-backoff instead.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 24 06:30:04 UTC 2022 - 20.3K bytes - Viewed (0) -
pkg/kubeapiserver/authorizer/reload.go
// initialConfig holds the ReloadFile used to initiate background reloading, // and information used to construct webhooks that isn't exposed in the authorization // configuration file (dial function, backoff settings, etc) initialConfig Config apiServerID string reloadInterval time.Duration requireNonWebhookTypes sets.Set[authzconfig.AuthorizerType] nodeAuthorizer *node.NodeAuthorizer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
q.queue.AddRateLimited(key) // Return early, so we do not call Forget(), allowing the rate limiting to backoff return true } q.log.Errorf("error handling %v, and retry budget exceeded: %v", formatKey(key), err) } // 'Forget indicates that an item is finished being retried.' - should be called whenever we do not want to backoff on this key. q.queue.Forget(key) return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
} return } // If a container is still in backoff, the function will return a brief backoff error and // a detailed error message. func (m *kubeGenericRuntimeManager) doBackOff(pod *v1.Pod, container *v1.Container, podStatus *kubecontainer.PodStatus, backOff *flowcontrol.Backoff) (bool, string, error) { var cStatus *kubecontainer.Status for _, c := range podStatus.ContainerStatuses {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubeapiserver/authorizer/config.go
// Options for ModeWebhook // 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 VersionedInformerFactory versionedinformers.SharedInformerFactory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 8K bytes - Viewed (0)