- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for claimStatus (0.29 sec)
-
pkg/apis/resource/validation/validation.go
var allErrs field.ErrorList names := sets.NewString() for i, claimStatus := range claimStatuses { allErrs = append(allErrs, validatePodSchedulingClaim(claimStatus, fldPath.Index(i))...) if names.Has(claimStatus.Name) { allErrs = append(allErrs, field.Duplicate(fldPath.Index(i), claimStatus.Name)) } else { names.Insert(claimStatus.Name) } } return allErrs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 09:18:10 UTC 2024 - 28.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go
} for name, tc := range testcases { t.Run(name, func(t *testing.T) { tCtx := ktesting.Init(t) var inFlightAllocations sync.Map for uid, claimStatus := range tc.inFlight { inFlightAllocations.Store(uid, &resourceapi.ResourceClaim{Status: claimStatus}) } slices := tc.slices if slices == nil { slices = sliceList{} } claims := tc.claims if claims == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 09:27:01 UTC 2024 - 34.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
if podScheduling.Spec.SelectedNode != "" { for _, claimStatus := range podScheduling.Status.ResourceClaims { if slices.Contains(claimStatus.UnsuitableNodes, podScheduling.Spec.SelectedNode) { logger.V(5).Info("PodSchedulingContext has unsuitable selected node, schedule immediately", "pod", klog.KObj(pod), "selectedNode", podScheduling.Spec.SelectedNode, "podResourceName", claimStatus.Name) return framework.Queue, nil } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
func (ctrl *PersistentVolumeController) syncClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) error { logger := klog.FromContext(ctx) logger.V(4).Info("Synchronizing PersistentVolumeClaim", "PVC", klog.KObj(claim), "claimStatus", getClaimStatusForLogging(claim)) // Set correct "migrated-to" annotations on PVC and update in API server if // necessary newClaim, err := ctrl.updateClaimMigrationAnnotations(ctx, claim) if err != nil {
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_pod_control_test.go
testCases := []struct { name string claimStates []string expected bool skipPodUID bool }{ { name: "all missing", claimStates: []string{missing, missing}, expected: false, }, { name: "no claims", claimStates: []string{}, expected: false, }, { name: "exists", claimStates: []string{missing, exists}, expected: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0)