- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for updateClaims (0.23 sec)
-
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
} if versioner.CompareResourceVersion(pvInCache, pv) != 0 { return false, nil } } return true, nil }) } func (env *testEnv) updateClaims(ctx context.Context, pvcs []*v1.PersistentVolumeClaim) error { for i, pvc := range pvcs { newPvc, err := env.client.CoreV1().PersistentVolumeClaims(pvc.Namespace).Update(ctx, pvc, metav1.UpdateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
UpdatePod(pod *v1.Pod) error DeletePod(pod *v1.Pod) error CreateClaim(claim *v1.PersistentVolumeClaim) error GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error) UpdateClaim(claim *v1.PersistentVolumeClaim) error } // StatefulPodControl defines the interface that StatefulSetController uses to create, update, and delete Pods,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
ctrl.claimQueue.Add(claimKey) } // updateClaim runs in worker thread and handles "claim added", // "claim updated" and "periodic sync" events. func (ctrl *PersistentVolumeController) updateClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) { // Store the new claim version in the cache and do not process it if this is // an old version.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
// mechanism. func (ctrl *PersistentVolumeController) bind(ctx context.Context, volume *v1.PersistentVolume, claim *v1.PersistentVolumeClaim) error { var err error // use updateClaim/updatedVolume to keep the original claim/volume for // logging in error cases. var updatedClaim *v1.PersistentVolumeClaim var updatedVolume *v1.PersistentVolume logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
func (om *fakeObjectManager) GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error) { return om.claimsLister.PersistentVolumeClaims(namespace).Get(claimName) } func (om *fakeObjectManager) UpdateClaim(claim *v1.PersistentVolumeClaim) error { // Validate ownerRefs. refs := claim.GetOwnerReferences() for _, ref := range refs { if ref.APIVersion == "" || ref.Kind == "" || ref.Name == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)