- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for PVCs (0.17 sec)
-
pkg/scheduler/framework/plugins/volumebinding/binder.go
unboundClaimsDelayBinding []*v1.PersistentVolumeClaim // unboundClaimsImmediate are the pod's unbound with immediate binding PVCs (i.e., supposed to be bound already) . unboundClaimsImmediate []*v1.PersistentVolumeClaim // unboundVolumesDelayBinding are PVs that belong to storage classes of the pod's unbound PVCs with delayed binding. unboundVolumesDelayBinding map[string][]*v1.PersistentVolume }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go
} return s, nil } // calPreFilterState computes preFilterState describing which PVCs use ReadWriteOncePod // and which pods in the cluster are in conflict. func (pl *VolumeRestrictions) calPreFilterState(ctx context.Context, pod *v1.Pod, pvcs sets.Set[string]) (*preFilterState, error) { conflictingPVCRefCount := 0 for pvc := range pvcs { key := framework.GetNamespacedName(pod.Namespace, pvc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go
maxVols: 3, test: "new pod's count considers PVCs backed by AzureDisk volumes", }, { newPod: splitPVCPod(azureDiskVolumeFilterType), existingPods: []*v1.Pod{splitAzureDiskPod, oneAzureDiskPod}, filterName: azureDiskVolumeFilterType, maxVols: 3, test: "new pod's count ignores PVCs not backed by AzureDisk volumes", }, { newPod: twoAzureDiskPod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 36.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
makeNode("node-a").Node, }, pvcs: []*v1.PersistentVolumeClaim{}, wantPreFilterStatus: framework.NewStatus(framework.UnschedulableAndUnresolvable, `persistentvolumeclaim "pvc-a" not found`), wantFilterStatus: []*framework.Status{ nil, }, wantScores: []int64{ 0, }, }, { name: "Part of PVCs do not exist",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
ps := make([]*v1.PersistentVolumeClaim, len(pvcs)) for i := range pvcs { ps[i] = &pvcs[i] } return &persistentVolumeClaimNamespaceLister{ pvcs: ps, namespace: namespace, } } // NodeInfoLister declares a framework.NodeInfo type for testing. type NodeInfoLister []*framework.NodeInfo // Get returns a fake node object in the fake nodes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
func (spc *StatefulPodControl) CreateStatefulPod(ctx context.Context, set *apps.StatefulSet, pod *v1.Pod) error { // Create the Pod's PVCs prior to creating the Pod if err := spc.createPersistentVolumeClaims(set, pod); err != nil { spc.recordPodEvent("create", set, pod, err) return err } // If we created the PVCs attempt to create the Pod err := spc.objectMgr.CreatePod(ctx, pod) // sink already exists errors
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/scheduler/framework/plugins/volumebinding/volume_binding.go
} // Filter invoked at the filter extension point. // It evaluates if a pod can fit due to the volumes it requests, // for both bound and unbound PVCs. // // For PVCs that are bound, then it checks that the corresponding PV's node affinity is // satisfied by the given node. // // For PVCs that are unbound, it tries to find available PVs that can satisfy the PVC requirements // and that the PV node affinity is satisfied by the given node. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} pvcs := getPersistentVolumeClaims(set, pod) pvcIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) for k := range pvcs { pvc := pvcs[k] pvcIndexer.Add(&pvc) } pvcLister := corelisters.NewPersistentVolumeClaimLister(pvcIndexer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go
limitSource: "csinode-with-no-limit", }, // should count pending PVCs { newPod: csiEBSOneVolPod, existingPods: []*v1.Pod{pendingVolumePod, csiEBSTwoVolPod}, filterName: "csi", maxVols: 2, driverNames: []string{ebsCSIDriverName}, test: "count pending PVCs towards volume limit <= pods CSI volume", limitSource: "node",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go
pluginFactory := func(ctx context.Context, plArgs runtime.Object, fh framework.Handle) (framework.Plugin, error) { return New(ctx, plArgs, fh, feature.Features{}) } snapshot := cache.NewSnapshot(pods, nodes) objects := make([]runtime.Object, 0, len(pvcs)) for _, pvc := range pvcs { objects = append(objects, pvc) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 17.3K bytes - Viewed (0)