Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newRevision (0.17 sec)

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