- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for newRevision (0.33 sec)
-
pkg/controller/statefulset/stateful_set_utils_test.go
set.Status.CollisionCount = new(int32) currentSet := set.DeepCopy() currentRevision, err := newRevision(set, 1, set.Status.CollisionCount) if err != nil { t.Fatal(err) } set.Spec.Template.Spec.Containers[0].Env = []v1.EnvVar{{Name: "foo", Value: "bar"}} updateSet := set.DeepCopy() updateRevision, err := newRevision(set, 2, set.Status.CollisionCount) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
specCopy["template"] = template template["$patch"] = "replace" objCopy["spec"] = specCopy patch, err := json.Marshal(objCopy) return patch, err } // newRevision creates a new ControllerRevision containing a patch that reapplies the target state of set. // The Revision of the returned ControllerRevision is set to revision. If the returned error is nil, the returned
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
var collisionCount int32 if set.Status.CollisionCount != nil { collisionCount = *set.Status.CollisionCount } // create a new revision from the current set updateRevision, err := newRevision(set, nextRevision(revisions), &collisionCount) if err != nil { return nil, nil, collisionCount, err } // find any equivalent revisions equalRevisions := history.FindEqualRevisions(revisions, updateRevision)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
// The recheck occurs in the presence of a matching orphan. pod := newStatefulSetPod(set, 1) pod.OwnerReferences = nil om.podsIndexer.Add(pod) set.Status.CollisionCount = new(int32) revision, err := newRevision(set, 1, set.Status.CollisionCount) if err != nil { t.Fatal(err) } revision.OwnerReferences = nil _, err = ssh.CreateControllerRevision(set, revision, set.Status.CollisionCount) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
if err != nil { return err } } return invariants(set, om) } func newRevisionOrDie(set *apps.StatefulSet, revision int64) *apps.ControllerRevision { rev, err := newRevision(set, revision, set.Status.CollisionCount) if err != nil { panic(err) } return rev } func isOrHasInternalError(err error) bool { if err == nil { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/authz.go
Verb: verb, User: a.groupCheck.authorizer.userInfo, } decision, reason, err := a.groupCheck.authorizer.authAuthorizer.Authorize(ctx, attr) return newDecision(decision, err, reason) } func newDecision(authDecision authorizer.Decision, err error, reason string) decisionVal { return decisionVal{receiverOnlyObjectVal: receiverOnlyVal(DecisionType), authDecision: authDecision, err: err, reason: reason} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 21:31:27 UTC 2023 - 21.1K bytes - Viewed (0)