controller

package
Version: v0.22.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 7, 2022 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithFakeRecorder added in v0.20.10

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

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

Types

type ElasticQuotaController added in v0.20.10

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

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

func NewElasticQuotaController added in v0.20.10

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 added in v0.20.10

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL