- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of about 10,000 for requeued (0.19 sec)
-
pkg/controller/deployment/progress.go
// requeueStuckDeployment checks whether the provided deployment needs to be synced for a progress // check. It returns the time after the deployment will be requeued for the progress check, 0 if it // will be requeued now, or -1 if it does not need to be requeued. func (dc *DeploymentController) requeueStuckDeployment(ctx context.Context, d *apps.Deployment, newStatus apps.DeploymentStatus) time.Duration { logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 11:00:44 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
expected: time.Duration(-1), }, { name: "complete deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 3, nil), status: newDeploymentStatus(3, 3, 3), expected: time.Duration(-1), }, { name: "already failed deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 0, failed), status: newDeploymentStatus(3, 3, 0),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
func (t *trackingWorkqueue[T]) queue(item T) { if _, queued := t.pendingMap[item]; queued { // fmt.Printf("already queued: %#v\n", item) return } t.pendingMap[item] = struct{}{} t.pendingList = append(t.pendingList, item) } func (t *trackingWorkqueue[T]) dequeue(item T) { if _, queued := t.pendingMap[item]; !queued { // fmt.Printf("not queued: %#v\n", item) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
}, cidrSynced: deletedServiceCIDR.Name, actions: [][]string{{"patch", "servicecidrs", ""}}, }, { name: "service CIDR being deleted but within the grace period must be requeued not remove the finalizer", // TODO: assert is actually requeued cidrs: []*networkingapiv1alpha1.ServiceCIDR{ deletingServiceCIDR, }, cidrSynced: deletingServiceCIDR.Name, actions: [][]string{}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_utils.go
updatedRS, updateErr = c.UpdateStatus(context.TODO(), rs, metav1.UpdateOptions{}) if updateErr == nil { return updatedRS, nil } // Stop retrying if we exceed statusUpdateRetries - the replicaSet will be requeued with a rate limit. if i >= statusUpdateRetries { break } // Update the ReplicaSet with the latest resource version for the next poll
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/controller/deployment/sync.go
// Matching ReplicaSet is not equal - increment the collisionCount in the DeploymentStatus // and requeue the Deployment. if d.Status.CollisionCount == nil { d.Status.CollisionCount = new(int32) } preCollisionCount := *d.Status.CollisionCount *d.Status.CollisionCount++ // Update the collisionCount for the Deployment and let it requeue by returning the original // error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
ec.queue.AddRateLimited(key) return true } // syncHandler is invoked for each pod which might need to be processed. // If an error is returned from this function, the pod will be requeued. func (ec *ephemeralController) syncHandler(ctx context.Context, key string) error { namespace, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
return } // always requeue resyncs just in case if oldCRD.ResourceVersion == newCRD.ResourceVersion { c.enqueue(newCRD) return } // If the only difference is in the terminating condition, then there's no reason to requeue here. This controller // is likely to be the originator, so requeuing would hot-loop us. Failures are requeued by the workqueue directly.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// a virtual event was produced and will be handled by processGraphChanges, no need to requeue this node return forgetItem } else if err == namespacedOwnerOfClusterScopedObjectErr { // a cluster-scoped object referring to a namespaced owner is an error that will not resolve on retry, no need to requeue this node return forgetItem } else if err != nil { if _, ok := err.(*restMappingError); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
expc.queue.AddRateLimited(key) return true } // syncHandler performs actual expansion of volume. If an error is returned // from this function - PVC will be requeued for resizing. func (expc *expandController) syncHandler(ctx context.Context, key string) error { namespace, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0)