- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for SatisfiedExpectations (0.21 sec)
-
pkg/controller/job/job_controller.go
// and update the expectations after we've retrieved active pods from the store. If a new pod enters // the store after we've checked the expectation, the job sync is just deferred till the next relist. satisfiedExpectations := jm.expectations.SatisfiedExpectations(logger, key) pods, err := jm.getPodsForJob(ctx, &job) if err != nil { return err } var terminating *int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
err := dsc.manage(ctx, ds, nodeList, hash) if err != nil { return err } // Process rolling updates if we're ready. if dsc.expectations.SatisfiedExpectations(klog.FromContext(ctx), key) { switch ds.Spec.UpdateStrategy.Type { case apps.OnDeleteDaemonSetStrategyType: case apps.RollingUpdateDaemonSetStrategyType: err = dsc.rollingUpdate(ctx, ds, nodeList, hash)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
doTestControllerBurstReplicas(t, 3, 2) } type FakeRSExpectations struct { *controller.ControllerExpectations satisfied bool expSatisfied func() } func (fe FakeRSExpectations) SatisfiedExpectations(logger klog.Logger, controllerKey string) bool { fe.expSatisfied() return fe.satisfied } // TestRSSyncExpectations tests that a pod cannot sneak in between counting active pods
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)