arq_controller

Documentation

Index

• Constants
• type ArqController
  • func NewArqController(clientSet client.AAQClient, podInformer cache.SharedIndexInformer, ...) *ArqController
  • func (ctrl *ArqController) Execute() bool
  • func (ctrl *ArqController) Run(ctx context.Context, workers int)

Constants

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

Types

type ArqController

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

func NewArqController

func NewArqController(clientSet client.AAQClient,
	podInformer cache.SharedIndexInformer,
	arqInformer cache.SharedIndexInformer,
	rqInformer cache.SharedIndexInformer,
	aaqjqcInformer cache.SharedIndexInformer,
	calcRegistry *aaq_evaluator.AaqCalculatorsRegistry,
	stop <-chan struct{},
) *ArqController

func (*ArqController) Execute

func (ctrl *ArqController) Execute() bool

func (*ArqController) Run

func (ctrl *ArqController) Run(ctx context.Context, workers int)