Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for controllerrevisions (0.35 sec)

  1. pkg/controller/daemon/update.go

    func (dsc *DaemonSetsController) constructHistory(ctx context.Context, ds *apps.DaemonSet) (cur *apps.ControllerRevision, old []*apps.ControllerRevision, err error) {
    	var histories []*apps.ControllerRevision
    	var currentHistories []*apps.ControllerRevision
    	histories, err = dsc.controlledHistories(ctx, ds)
    	if err != nil {
    		return nil, nil, err
    	}
    	for _, history := range histories {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_control.go

    	// ListRevisions returns a array of the ControllerRevisions that represent the revisions of set. If the returned
    	// error is nil, the returns slice of ControllerRevisions is valid.
    	ListRevisions(set *apps.StatefulSet) ([]*apps.ControllerRevision, error)
    	// AdoptOrphanRevisions adopts any orphaned ControllerRevisions that match set's Selector. If all adoptions are
    	// successful the returned error is nil.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set.go

    		return fresh, nil
    	})
    }
    
    // adoptOrphanRevisions adopts any orphaned ControllerRevisions matched by set's Selector.
    func (ssc *StatefulSetController) adoptOrphanRevisions(ctx context.Context, set *apps.StatefulSet) error {
    	revisions, err := ssc.control.ListRevisions(set)
    	if err != nil {
    		return err
    	}
    	orphanRevisions := make([]*apps.ControllerRevision, 0)
    	for i := range revisions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  4. pkg/controlplane/storageversionhashdata/data.go

    	"storage.k8s.io/v1/csistoragecapacities":                            "xeVl+2Ly1kE=",
    	"storage.k8s.io/v1/volumeattachments":                               "tJx/ezt6UDU=",
    	"apps/v1/controllerrevisions":                                       "85nkx63pcBU=",
    	"apps/v1/daemonsets":                                                "dd7pWHUlMKQ=",
    	"apps/v1/deployments":                                               "8aSe+NMegvE=",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 20:14:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/apps/v1/types_swagger_doc_generated.go

    var map_ControllerRevision = map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:14:59 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/apps/v1/generated.proto

    option go_package = "k8s.io/api/apps/v1";
    
    // ControllerRevision implements an immutable snapshot of state data. Clients
    // are responsible for serializing and deserializing the objects that contain
    // their internal state.
    // Once a ControllerRevision has been successfully created, it can not be updated.
    // The API Server will fail validation of all requests that attempt to mutate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:14:59 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set_test.go

    		informerFactory.Core().V1().Pods(),
    		informerFactory.Apps().V1().StatefulSets(),
    		informerFactory.Core().V1().PersistentVolumeClaims(),
    		informerFactory.Apps().V1().ControllerRevisions(),
    		client,
    	)
    	ssh := history.NewFakeHistory(informerFactory.Apps().V1().ControllerRevisions())
    	ssc.podListerSynced = alwaysReady
    	ssc.setListerSynced = alwaysReady
    	ssc.control = NewDefaultStatefulSetControl(spc, ssu, ssh)
    
    	return ssc, spc, om, ssh
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/apps/v1/types.go

    // the Data field. ControllerRevisions may, however, be deleted. Note that, due to its use by both
    // the DaemonSet and StatefulSet controllers for update and rollback, this object is beta. However,
    // it may be subject to name and representation changes in future releases, and clients should not
    // depend on its stability. It is primarily for internal use by controllers.
    type ControllerRevision struct {
    	metav1.TypeMeta `json:",inline"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 49.1K bytes
    - Viewed (0)
  9. pkg/controller/statefulset/stateful_set_control_test.go

    func TestStatefulSetControl_getSetRevisions(t *testing.T) {
    	type testcase struct {
    		name            string
    		existing        []*apps.ControllerRevision
    		set             *apps.StatefulSet
    		expectedCount   int
    		expectedCurrent *apps.ControllerRevision
    		expectedUpdate  *apps.ControllerRevision
    		err             bool
    	}
    
    	testFn := func(test *testcase, t *testing.T) {
    		client := fake.NewSimpleClientset()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  10. pkg/controller/daemon/daemon_controller.go

    // updateHistory figures out what DaemonSet(s) manage a ControllerRevision when the ControllerRevision
    // is updated and wake them up. If anything of the ControllerRevision has changed, we need to  awaken
    // both the old and new DaemonSets.
    func (dsc *DaemonSetsController) updateHistory(logger klog.Logger, old, cur interface{}) {
    	curHistory := cur.(*apps.ControllerRevision)
    	oldHistory := old.(*apps.ControllerRevision)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
Back to top