scheduler

Documentation

Index

• Constants
• func New(_ runtime.Object, f framework.Handle) (framework.Plugin, error)
• type LVMVolumeScheduler
  • 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
  • func (p *Plugin) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (p Plugin) Name() string
  • 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)
• type Scheduler
  • func NewScheduler(f framework.Handle) *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
  • func NewDiskVolumeScheduler(f framework.Handle) VolumeScheduler
  • func NewLVMVolumeScheduler(f framework.Handle, scheduler localstoragev1alpha1.VolumeScheduler, ...) VolumeScheduler

Constants

const (
	Name = "hwameistor-scheduler-plugin"
)

Name is the name of the plugin used in Registry and configurations.

Functions

func New

func New(_ runtime.Object, f framework.Handle) (framework.Plugin, error)

New initializes a new plugin and returns it.

Types

type LVMVolumeScheduler

type LVMVolumeScheduler struct {
	// contains filtered or unexported fields
}

func (*LVMVolumeScheduler) CSIDriverName

func (s *LVMVolumeScheduler) CSIDriverName() string

func (*LVMVolumeScheduler) Filter

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

func (*LVMVolumeScheduler) Reserve

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

func (*LVMVolumeScheduler) Unreserve

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

type Plugin

type Plugin struct {
	// contains filtered or unexported fields
}

func (*Plugin) Filter

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

Filter is the functions invoked by the framework at "filter" extension point.

func (Plugin) Name

func (p Plugin) Name() string

Name returns name of the plugin. It is used in logs, etc.

func (*Plugin) Reserve

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

Reserve is the functions invoked by the framework at "reserve" extension point.

func (*Plugin) Unreserve

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

Unreserve is the functions invoked by the framework at "reserve" extension point.

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

VolumeScheduler is to scheduler hwameistor volume

func NewScheduler

func NewScheduler(f framework.Handle) *Scheduler

NewDataCache creates a cache instance

func (*Scheduler) Filter

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

func (*Scheduler) Reserve

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

func (*Scheduler) Unreserve

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

type VolumeScheduler

type VolumeScheduler interface {
	Filter(existingLocalVolume []string, unboundPVCs []*v1.PersistentVolumeClaim, node *v1.Node) (bool, error)
	Reserve(unboundPVCs []*v1.PersistentVolumeClaim, node string) error
	Unreserve(unboundPVCs []*v1.PersistentVolumeClaim, node string) error
	CSIDriverName() string
}

func NewDiskVolumeScheduler

func NewDiskVolumeScheduler(f framework.Handle) VolumeScheduler

func NewLVMVolumeScheduler

func NewLVMVolumeScheduler(f framework.Handle, scheduler localstoragev1alpha1.VolumeScheduler, hwameiStorCache cache.Cache, cli client.Client) VolumeScheduler