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
- type VolumeScheduler
Constants ¶
View Source
const (
Name = "hwameistor-scheduler-plugin"
)
Name is the name of the plugin used in Registry and configurations.
Variables ¶
This section is empty.
Functions ¶
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 ¶ added in v0.1.6
func (s *LVMVolumeScheduler) Reserve(pendingPVCs []*corev1.PersistentVolumeClaim, node string) error
func (*LVMVolumeScheduler) Unreserve ¶ added in v0.1.6
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.
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
VolumeScheduler is to scheduler hwameistor volume
func NewScheduler ¶
NewDataCache creates a cache instance
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
Click to show internal directories.
Click to hide internal directories.