Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 226 for Backoff (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top