acrq_controller

Documentation

Index

• Constants
• type AcrqController
  • func NewAcrqController(aaqCli client.AAQClient, ...) *AcrqController
  • func (c *AcrqController) AddMapping(quotaName, namespaceName string)
  • func (ctrl *AcrqController) Execute() bool
  • func (c *AcrqController) RemoveMapping(quotaName, namespaceName string)
  • func (c *AcrqController) Run(ctx context.Context, workers int)

Constants

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

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