scheduler

Nov 22, 2023

Changes in this version

+ const VolumeClaim

Sep 18, 2023

Changes in this version

+ const VolumeSnapshot

Feb 10, 2023

Changes in this version

type LVMVolumeScheduler

+ func (s *LVMVolumeScheduler) Score(unboundPVCs []*corev1.PersistentVolumeClaim, node string) (int64, error)

type Plugin

+ func (p *Plugin) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string) (int64, *framework.Status)

+ func (p *Plugin) ScoreExtensions() framework.ScoreExtensions

type Scheduler

+ func (s *Scheduler) Score(pod *corev1.Pod, node string) (int64, error)

type VolumeScheduler

+ Score func(unboundPVCs []*v1.PersistentVolumeClaim, node string) (int64, error)

Jul 26, 2022

Changes in this version

+ const MaxHAVolumeCount

+ const Name

+ func New(_ *runtime.Unknown, f framework.FrameworkHandle) (framework.Plugin, error)

+ type LVMVolumeScheduler struct

+ func (s *LVMVolumeScheduler) CSIDriverName() string

+ func (s *LVMVolumeScheduler) Filter(lvs []string, pendingPVCs []*corev1.PersistentVolumeClaim, node *corev1.Node) (bool, error)

+ func (s *LVMVolumeScheduler) Reserve(pendingPVCs []*corev1.PersistentVolumeClaim, node string) error

+ func (s *LVMVolumeScheduler) Unreserve(pendingPVCs []*corev1.PersistentVolumeClaim, node string) error

+ type Plugin struct

+ func (p *Plugin) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status

+ func (p *Plugin) Reserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string) *framework.Status

+ func (p *Plugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string)

+ func (p Plugin) Name() string

+ type Scheduler struct

+ func NewScheduler(f framework.FrameworkHandle) *Scheduler

+ func (s *Scheduler) Filter(pod *corev1.Pod, node *corev1.Node) (bool, error)

+ func (s *Scheduler) Reserve(pod *corev1.Pod, node string) error

+ func (s *Scheduler) Unreserve(pod *corev1.Pod, node string) error

+ type VolumeScheduler interface

+ CSIDriverName func() string

+ Filter func(existingLocalVolume []string, unboundPVCs []*v1.PersistentVolumeClaim, ...) (bool, error)

+ Reserve func(unboundPVCs []*v1.PersistentVolumeClaim, node string) error

+ Unreserve func(unboundPVCs []*v1.PersistentVolumeClaim, node string) error

+ func NewDiskVolumeScheduler(f framework.FrameworkHandle) VolumeScheduler

+ func NewLVMVolumeScheduler(f framework.FrameworkHandle, scheduler localstoragev1alpha1.VolumeScheduler, ...) VolumeScheduler