scheduler

Documentation

Index

• Constants
• type Bind
  • func NewXPUBind(clientset *kubernetes.Clientset, c *cache.SchedulerCache) *Bind
  • func (b Bind) Handler(args schedulerapi.ExtenderBindingArgs) *schedulerapi.ExtenderBindingResult
• type Device
• type Inspect
  • func NewXPUInspect(c *cache.SchedulerCache) *Inspect
  • func (in Inspect) Handler(name string) *Result
• type Node
• type Pod
• type Predicate
  • func NewXPUPredicate(clientset *kubernetes.Clientset, c *cache.SchedulerCache) *Predicate
  • func (p Predicate) Handler(args schedulerapi.ExtenderArgs) *schedulerapi.ExtenderFilterResult
• type Result

Constants

const (
	OptimisticLockErrorMsg = "the object has been modified; please apply your changes to the latest version and try again"
)

Types

type Bind

type Bind struct {
	Name string
	Func func(podName string, podNamespace string, podUID types.UID, node string, cache *cache.SchedulerCache) error
	// contains filtered or unexported fields
}

Bind is responsible for binding node and pod

func NewXPUBind

func NewXPUBind(clientset *kubernetes.Clientset, c *cache.SchedulerCache) *Bind

func (Bind) Handler

func (b Bind) Handler(args schedulerapi.ExtenderBindingArgs) *schedulerapi.ExtenderBindingResult

Handler handles the Bind request

type Device

type Device struct {
	ID       int    `json:"id"`
	TotalGPU uint   `json:"totalGPU"`
	UsedGPU  uint   `json:"usedGPU"`
	Pods     []*Pod `json:"pods"`
}

type Inspect

type Inspect struct {
	Name string
	// contains filtered or unexported fields
}

func NewXPUInspect

func NewXPUInspect(c *cache.SchedulerCache) *Inspect

func (Inspect) Handler

func (in Inspect) Handler(name string) *Result

type Node

type Node struct {
	Name     string    `json:"name"`
	TotalGPU uint      `json:"totalGPU"`
	UsedGPU  uint      `json:"usedGPU"`
	Devices  []*Device `json:"devs"`
}

type Pod

type Pod struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	UsedGPU   int    `json:"usedGPU"`
}

type Predicate

type Predicate struct {
	Name string
	Func func(pod *v1.Pod, nodeName string, c *cache.SchedulerCache) (bool, error)
	// contains filtered or unexported fields
}

func NewXPUPredicate

func NewXPUPredicate(clientset *kubernetes.Clientset, c *cache.SchedulerCache) *Predicate

func (Predicate) Handler

func (p Predicate) Handler(args schedulerapi.ExtenderArgs) *schedulerapi.ExtenderFilterResult

type Result

type Result struct {
	Nodes []*Node `json:"nodes"`
	Error string  `json:"error,omitempty"`
}