Versions in this module Expand all Collapse all v0 v0.4.2 Mar 29, 2019 v0.4.1 Mar 11, 2019 Changes in this version + type Binder interface + Bind func(task *v1.Pod, hostname string) error + type Cache interface + Bind func(task *api.TaskInfo, hostname string) error + Evict func(task *api.TaskInfo) error + LoadSchedulerConf func(path string) (map[string]string, error) + Run func(stopCh <-chan struct{}) + Snapshot func() *api.ClusterInfo + WaitForCacheSync func(stopCh <-chan struct{}) bool + func New(config *rest.Config, schedulerName string) Cache + type Evictor interface + Evict func(pod *v1.Pod) error + type SchedulerCache struct + Binder Binder + Evictor Evictor + Jobs map[arbapi.JobID]*arbapi.JobInfo + Nodes map[string]*arbapi.NodeInfo + func (sc *SchedulerCache) AddNode(obj interface{}) + func (sc *SchedulerCache) AddPDB(obj interface{}) + func (sc *SchedulerCache) AddPod(obj interface{}) + func (sc *SchedulerCache) AddSchedulingSpec(obj interface{}) + func (sc *SchedulerCache) Bind(taskInfo *arbapi.TaskInfo, hostname string) error + func (sc *SchedulerCache) DeleteNode(obj interface{}) + func (sc *SchedulerCache) DeletePDB(obj interface{}) + func (sc *SchedulerCache) DeletePod(obj interface{}) + func (sc *SchedulerCache) DeleteSchedulingSpec(obj interface{}) + func (sc *SchedulerCache) Evict(taskInfo *arbapi.TaskInfo) error + func (sc *SchedulerCache) LoadSchedulerConf(path string) (map[string]string, error) + func (sc *SchedulerCache) Run(stopCh <-chan struct{}) + func (sc *SchedulerCache) Snapshot() *arbapi.ClusterInfo + func (sc *SchedulerCache) String() string + func (sc *SchedulerCache) UpdateNode(oldObj, newObj interface{}) + func (sc *SchedulerCache) UpdatePDB(oldObj, newObj interface{}) + func (sc *SchedulerCache) UpdatePod(oldObj, newObj interface{}) + func (sc *SchedulerCache) UpdateSchedulingSpec(oldObj, newObj interface{}) + func (sc *SchedulerCache) WaitForCacheSync(stopCh <-chan struct{}) bool
Go to main page