type VolumeRestrictions … var _ … var _ … var _ … var _ … const Name … const preFilterStateKey … const ErrReasonDiskConflict … const ErrReasonReadWriteOncePodConflict … type preFilterState … func (s *preFilterState) updateWithPod(podInfo *framework.PodInfo, multiplier int) { … } func (s *preFilterState) conflictingPVCRefCountForPod(podInfo *framework.PodInfo) int { … } // Clone the prefilter state. func (s *preFilterState) Clone() framework.StateData { … } // Name returns name of the plugin. It is used in logs, etc. func (pl *VolumeRestrictions) Name() string { … } func isVolumeConflict(volume *v1.Volume, pod *v1.Pod) bool { … } // haveOverlap searches two arrays and returns true if they have at least one common element; returns false otherwise. func haveOverlap(a1, a2 []string) bool { … } // return true if there are conflict checking targets. func needsRestrictionsCheck(v v1.Volume) bool { … } // PreFilter computes and stores cycleState containing details for enforcing ReadWriteOncePod. func (pl *VolumeRestrictions) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … } // AddPod from pre-computed data in cycleState. func (pl *VolumeRestrictions) AddPod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … } // RemovePod from pre-computed data in cycleState. func (pl *VolumeRestrictions) RemovePod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … } func getPreFilterState(cycleState *framework.CycleState) (*preFilterState, error) { … } // 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) { … } func (pl *VolumeRestrictions) readWriteOncePodPVCsForPod(ctx context.Context, pod *v1.Pod) (sets.Set[string], error) { … } // Checks if scheduling the pod onto this node would cause any conflicts with // existing volumes. func satisfyVolumeConflicts(pod *v1.Pod, nodeInfo *framework.NodeInfo) bool { … } // Checks if scheduling the pod would cause any ReadWriteOncePod PVC access mode conflicts. func satisfyReadWriteOncePod(ctx context.Context, state *preFilterState) *framework.Status { … } // PreFilterExtensions returns prefilter extensions, pod add and remove. func (pl *VolumeRestrictions) PreFilterExtensions() framework.PreFilterExtensions { … } // Filter invoked at the filter extension point. // It evaluates if a pod can fit due to the volumes it requests, and those that // are already mounted. If there is already a volume mounted on that node, another pod that uses the same volume // can't be scheduled there. // This is GCE, Amazon EBS, ISCSI and Ceph RBD specific for now: // - GCE PD allows multiple mounts as long as they're all read-only // - AWS EBS forbids any two pods mounting the same volume ID // - Ceph RBD forbids if any two pods share at least same monitor, and match pool and image, and the image is read-only // - ISCSI forbids if any two pods share at least same IQN and ISCSI volume is read-only // If the pod uses PVCs with the ReadWriteOncePod access mode, it evaluates if // these PVCs are already in-use and if preemption will help. func (pl *VolumeRestrictions) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { … } // EventsToRegister returns the possible events that may make a Pod // failed by this plugin schedulable. func (pl *VolumeRestrictions) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … } // isSchedulableAfterPersistentVolumeClaimAdded is invoked whenever a PersistentVolumeClaim added or changed, It checks whether // that change made a previously unschedulable pod schedulable. func (pl *VolumeRestrictions) isSchedulableAfterPersistentVolumeClaimAdded(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … } // isSchedulableAfterPodDeleted is invoked whenever a pod deleted, // It checks whether the deleted pod will conflict with volumes of other pods on the same node func (pl *VolumeRestrictions) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{ … } // New initializes a new plugin and returns it. func New(_ context.Context, _ runtime.Object, handle framework.Handle, fts feature.Features) (framework.Plugin, error) { … }
Codebase Browser
kubernetes