scheduler

README

Scheduler

This directory contains the implementation of a scheduler extender. It is meant to be linked into the PMEM-CSI master controller because that is where we know about nodes and can get their current capacity.

Documentation

Index

• Constants
• func NewScheduler(driverName string, capacity Capacity, clientSet kubernetes.Interface, ...) (http.Handler, error)
• type Capacity
  • func CapacityViaRegistry(rs *registryserver.RegistryServer) Capacity

Constants

const (
	// Resource is the resource that will trigger the scheduler extender.
	Resource = "pmem-csi.intel.com/scheduler"
)

Functions

func NewScheduler

func NewScheduler(
	driverName string,
	capacity Capacity,
	clientSet kubernetes.Interface,
	pvcLister corelisters.PersistentVolumeClaimLister,
	scLister storagelisters.StorageClassLister,
) (http.Handler, error)

Types

type Capacity

type Capacity interface {
	// NodeCapacity returns the available PMEM for the node.
	NodeCapacity(nodeName string) (int64, error)
}

Capacity provides information of remaining free PMEM per node.

func CapacityViaRegistry

func CapacityViaRegistry(rs *registryserver.RegistryServer) Capacity