Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for calculateStatus (0.18 sec)

  1. pkg/controller/replicaset/replica_set_utils_test.go

    				Replicas:             1,
    				FullyLabeledReplicas: 1,
    				ReadyReplicas:        1,
    				AvailableReplicas:    0,
    			},
    		},
    	}
    
    	for _, test := range rsStatusTests {
    		replicaSetStatus := calculateStatus(test.replicaset, test.filteredPods, nil)
    		if !reflect.DeepEqual(replicaSetStatus, test.expectedReplicaSetStatus) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 19 20:18:23 UTC 2018
    - 6.6K bytes
    - Viewed (0)
  2. pkg/controller/deployment/sync.go

    	newStatus := calculateStatus(allRSs, newRS, d)
    
    	if reflect.DeepEqual(d.Status, newStatus) {
    		return nil
    	}
    
    	newDeployment := d
    	newDeployment.Status = newStatus
    	_, err := dc.client.AppsV1().Deployments(newDeployment.Namespace).UpdateStatus(ctx, newDeployment, metav1.UpdateOptions{})
    	return err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 24.5K bytes
    - Viewed (0)
  3. pkg/controller/replicaset/replica_set_utils.go

    			// If the GET fails we can't trust status.Replicas anymore. This error
    			// is bound to be more interesting than the update failure.
    			return nil, getErr
    		}
    	}
    
    	return nil, updateErr
    }
    
    func calculateStatus(rs *apps.ReplicaSet, filteredPods []*v1.Pod, manageReplicasErr error) apps.ReplicaSetStatus {
    	newStatus := rs.Status
    	// Count the number of pods that have labels matching the labels of the pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 12:19:51 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  4. pkg/controller/deployment/progress.go

    // we shouldn't try to estimate any progress.
    func (dc *DeploymentController) syncRolloutStatus(ctx context.Context, allRSs []*apps.ReplicaSet, newRS *apps.ReplicaSet, d *apps.Deployment) error {
    	newStatus := calculateStatus(allRSs, newRS, d)
    
    	// If there is no progressDeadlineSeconds set, remove any Progressing condition.
    	if !util.HasProgressDeadline(d) {
    		util.RemoveDeploymentCondition(&newStatus, apps.DeploymentProgressing)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 13 11:00:44 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  5. pkg/controller/replicaset/replica_set.go

    		return err
    	}
    
    	var manageReplicasErr error
    	if rsNeedsSync && rs.DeletionTimestamp == nil {
    		manageReplicasErr = rsc.manageReplicas(ctx, filteredPods, rs)
    	}
    	rs = rs.DeepCopy()
    	newStatus := calculateStatus(rs, filteredPods, manageReplicasErr)
    
    	// Always updates status as pods come up or die.
    	updatedRS, err := updateReplicaSetStatus(logger, rsc.kubeClient.AppsV1().ReplicaSets(rs.Namespace), rs, newStatus)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
Back to top