Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for updateStatefulSetStatus (0.32 sec)

  1. pkg/controller/statefulset/stateful_set_status_updater_test.go

    		}
    		return true, update.GetObject(), nil
    
    	})
    	if err := updater.UpdateStatefulSetStatus(context.TODO(), set, &status); err != nil {
    		t.Errorf("UpdateStatefulSetStatus returned an error: %s", err)
    	}
    	if set.Status.Replicas != 2 {
    		t.Errorf("UpdateStatefulSetStatus mutated the sets replicas %d", set.Status.Replicas)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 13 15:37:10 UTC 2022
    - 5.9K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_status_updater.go

    type StatefulSetStatusUpdaterInterface interface {
    	// UpdateStatefulSetStatus sets the set's Status to status. Implementations are required to retry on conflicts,
    	// but fail on other errors. If the returned error is nil set's Status has been successfully set to status.
    	UpdateStatefulSetStatus(ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 13 20:32:13 UTC 2021
    - 2.9K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set_control.go

    		}
    	}
    	return &status, nil
    }
    
    // updateStatefulSetStatus updates set's Status to be equal to status. If status indicates a complete update, it is
    // mutated to indicate completion. If status is semantically equivalent to set's Status no update is performed. If the
    // returned error is nil, the update is successful.
    func (ssc *defaultStatefulSetControl) updateStatefulSetStatus(
    	ctx context.Context,
    	set *apps.StatefulSet,
    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_control_test.go

    	return &fakeStatefulSetStatusUpdater{
    		setInformer.Lister(),
    		setInformer.Informer().GetIndexer(),
    		newRequestTracker(0, nil, 0),
    	}
    }
    
    func (ssu *fakeStatefulSetStatusUpdater) UpdateStatefulSetStatus(ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error {
    	defer ssu.updateStatusTracker.trackParallelRequests()
    	if err := ssu.updateStatusTracker.incWithOptionalError(); err != nil {
    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