Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for UpdateStatefulPod (0.26 sec)

  1. pkg/controller/statefulset/stateful_pod_control_test.go

    		t.Error("no-op update should not make any client invocation")
    		return true, nil, apierrors.NewInternalError(errors.New("if we are here we have a problem"))
    	})
    	if err := control.UpdateStatefulPod(ctx, set, pod); err != nil {
    		t.Errorf("Error returned on no-op update error: %s", err)
    	}
    	events := collectEvents(recorder.Events)
    	if eventCount := len(events); eventCount != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_pod_control.go

    			spc.recordPodEvent("update", set, pod, err)
    			return err
    		}
    	}
    	spc.recordPodEvent("create", set, pod, err)
    	return err
    }
    
    func (spc *StatefulPodControl) UpdateStatefulPod(ctx context.Context, set *apps.StatefulSet, pod *v1.Pod) error {
    	attemptedUpdate := false
    	err := retry.RetryOnConflict(retry.DefaultBackoff, func() error {
    		// assume the Pod is consistent
    		consistent := true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set_control.go

    		return false, nil
    	}
    
    	// Make a deep copy so we don't mutate the shared cache
    	replica := replicas[i].DeepCopy()
    	if err := ssc.podControl.UpdateStatefulPod(ctx, updateSet, replica); err != nil {
    		return true, err
    	}
    
    	return false, 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)
Back to top