arq_controller

Documentation

Index

• Constants
• type AaqGateController
  • func NewAaqGateController(aaqCli client.AAQClient, podInformer cache.SharedIndexInformer, ...) *AaqGateController
  • func (ctrl *AaqGateController) AddMapping(_, namespaceName string)
  • func (ctrl *AaqGateController) Execute() bool
  • func (ctrl *AaqGateController) RemoveMapping(_, namespaceName string)
  • func (ctrl *AaqGateController) Run(ctx context.Context, threadiness int)

Constants

const (
	Immediate                                    enqueueState = "Immediate"
	Forget                                       enqueueState = "Forget"
	BackOff                                      enqueueState = "BackOff"
	AaqjqcName                                                = "aaqjqc"
	ApplicationAwareResourceQuotaLockName                     = "application-aware-resource-quota-lock"
	ApplicationAwareClusterResourceQuotaLockName              = "application-aware-cluster-resource-quota-lock"
)

Types

type AaqGateController

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

func NewAaqGateController

func NewAaqGateController(aaqCli client.AAQClient,
	podInformer cache.SharedIndexInformer,
	arqInformer cache.SharedIndexInformer,
	aaqjqcInformer cache.SharedIndexInformer,
	acrqInformer cache.SharedIndexInformer,
	evalRegistry *aaq_evaluator.AaqEvaluatorRegistry,
	clusterQuotaLister v1alpha1.ApplicationAwareClusterResourceQuotaLister,
	namespaceLister v12.NamespaceLister,
	clusterQuotaMapper clusterquotamapping.ClusterQuotaMapper,
	recorder record.EventRecorder,
	clusterQuotaEnabled bool,
	stop <-chan struct{},
) *AaqGateController

func (*AaqGateController) AddMapping

func (ctrl *AaqGateController) AddMapping(_, namespaceName string)

func (*AaqGateController) Execute

func (ctrl *AaqGateController) Execute() bool

func (*AaqGateController) RemoveMapping

func (ctrl *AaqGateController) RemoveMapping(_, namespaceName string)

func (*AaqGateController) Run

func (ctrl *AaqGateController) Run(ctx context.Context, threadiness int)