controller

Documentation

Index

• func WithFakeRecorder(bufferSize int) func(ctrl *ElasticQuotaController)
• type ElasticQuotaController
  • func NewElasticQuotaController(kubeClient kubernetes.Interface, eqInformer schedinformer.ElasticQuotaInformer, ...) *ElasticQuotaController
  • func (ctrl *ElasticQuotaController) Run(workers int, stopCh <-chan struct{})
• type PodGroupController
  • func NewPodGroupController(client kubernetes.Interface, pgInformer schedinformer.PodGroupInformer, ...) *PodGroupController
  • func (ctrl *PodGroupController) Run(workers int, stopCh <-chan struct{})

Functions

func WithFakeRecorder

func WithFakeRecorder(bufferSize int) func(ctrl *ElasticQuotaController)

WithFakeRecorder will set a fake recorder.It is usually used for unit testing

Types

type ElasticQuotaController

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

ElasticQuotaController is a controller that process elastic quota using provided Handler interface

func NewElasticQuotaController

func NewElasticQuotaController(
	kubeClient kubernetes.Interface,
	eqInformer schedinformer.ElasticQuotaInformer,
	podInformer coreinformer.PodInformer,
	schedClient schedclientset.Interface,
	newOpt ...func(ctrl *ElasticQuotaController),
) *ElasticQuotaController

NewElasticQuotaController returns a new *ElasticQuotaController

func (*ElasticQuotaController) Run

func (ctrl *ElasticQuotaController) Run(workers int, stopCh <-chan struct{})

type PodGroupController

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

PodGroupController is a controller that process pod groups using provided Handler interface

func NewPodGroupController

func NewPodGroupController(client kubernetes.Interface,
	pgInformer schedinformer.PodGroupInformer,
	podInformer coreinformer.PodInformer,
	pgClient schedclientset.Interface) *PodGroupController

NewPodGroupController returns a new *PodGroupController

func (*PodGroupController) Run

func (ctrl *PodGroupController) Run(workers int, stopCh <-chan struct{})

Run starts listening on channel events