- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for FindPodVolumes (0.29 sec)
-
pkg/scheduler/framework/plugins/volumebinding/fake_binder.go
func (b *FakeVolumeBinder) GetEligibleNodes(_ klog.Logger, boundClaims []*v1.PersistentVolumeClaim) (eligibleNodes sets.Set[string]) { return nil } // FindPodVolumes implements SchedulerVolumeBinder.FindPodVolumes. func (b *FakeVolumeBinder) FindPodVolumes(_ klog.Logger, pod *v1.Pod, _ *PodVolumeClaims, node *v1.Node) (podVolumes *PodVolumes, reasons ConflictReasons, err error) { return nil, b.config.FindReasons, b.config.FindErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 03:28:12 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
equal = false break } } } if !equal { t.Errorf("expected failure reasons %s, got %s", reasonNames(expected), reasonNames(actual)) } } // findPodVolumes gets and finds volumes for given pod and node func findPodVolumes(logger klog.Logger, binder SchedulerVolumeBinder, pod *v1.Pod, node *v1.Node) (*PodVolumes, ConflictReasons, error) { podVolumeClaims, err := binder.GetPodVolumeClaims(logger, pod)
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/scheduler/framework/plugins/volumebinding/binder.go
b.csiStorageCapacityLister = capacityCheck.CSIStorageCapacityInformer.Lister() return b } // FindPodVolumes finds the matching PVs for PVCs and nodes to provision PVs // for the given pod and node. If the node does not fit, conflict reasons are // returned.
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/volumebinding/volume_binding.go
logger := klog.FromContext(ctx) node := nodeInfo.Node() state, err := getStateData(cs) if err != nil { return framework.AsStatus(err) } podVolumes, reasons, err := pl.Binder.FindPodVolumes(logger, pod, state.podVolumeClaims, node) if err != nil { return framework.AsStatus(err) } if len(reasons) > 0 { status := framework.NewStatus(framework.UnschedulableAndUnresolvable)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0)