acrq_controller

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Immediate enqueueState = "Immediate"
	Forget    enqueueState = "Forget"
	BackOff   enqueueState = "BackOff"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AcrqController

type AcrqController struct {
	AcrqInformer cache.SharedIndexInformer
	// contains filtered or unexported fields
}

func NewAcrqController

func NewAcrqController(aaqCli client.AAQClient,
	clusterQuotaMapper clusterquotamapping.ClusterQuotaMapper,
	AcrqInformer cache.SharedIndexInformer,
	crqInformer cache.SharedIndexInformer,
	podInformer cache.SharedIndexInformer,
	aaqjqcInformer cache.SharedIndexInformer,
	calcRegistry *aaq_evaluator.AaqEvaluatorRegistry,
	namespaceLister v12.NamespaceLister,
	stop <-chan struct{},
	collectCrqsData bool,
) *AcrqController

func (*AcrqController) AddMapping

func (c *AcrqController) AddMapping(quotaName, namespaceName string)

func (*AcrqController) Execute

func (ctrl *AcrqController) Execute() bool

func (*AcrqController) RemoveMapping

func (c *AcrqController) RemoveMapping(quotaName, namespaceName string)

func (*AcrqController) Run

func (c *AcrqController) Run(ctx context.Context, workers int)

Run begins quota controller using the specified number of workers

Jump to

Keyboard shortcuts

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