shim

Documentation

Index

• Constants
• type KubernetesShim
  • func NewShimScheduler(scheduler api.SchedulerAPI, configs *conf.SchedulerConf, ...) *KubernetesShim
  • func NewShimSchedulerForPlugin(scheduler api.SchedulerAPI, informerFactory informers.SharedInformerFactory, ...) *KubernetesShim
  • func (ss *KubernetesShim) GetContext() *cache.Context
  • func (ss *KubernetesShim) Run() error
  • func (ss *KubernetesShim) Stop()

Constants

const (
	AppHandler  string = "ShimAppHandler"
	TaskHandler string = "ShimTaskHandler"
)

Types

type KubernetesShim

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

shim scheduler watches api server and interacts with unity scheduler to allocate pods

func NewShimScheduler

func NewShimScheduler(scheduler api.SchedulerAPI, configs *conf.SchedulerConf, bootstrapConfigMaps []*v1.ConfigMap) *KubernetesShim

func NewShimSchedulerForPlugin

func NewShimSchedulerForPlugin(scheduler api.SchedulerAPI, informerFactory informers.SharedInformerFactory, configs *conf.SchedulerConf, bootstrapConfigMaps []*v1.ConfigMap) *KubernetesShim

func (*KubernetesShim) GetContext

func (ss *KubernetesShim) GetContext() *cache.Context

func (*KubernetesShim) Run

func (ss *KubernetesShim) Run() error

func (*KubernetesShim) Stop

func (ss *KubernetesShim) Stop()