arq_controller

package
v1.1.12 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: 27 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 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.AaqEvaluatorRegistry,
	namespaceLister v12.NamespaceLister,
	stop <-chan struct{},
) *ArqController

func (*ArqController) Execute

func (ctrl *ArqController) Execute() bool

func (*ArqController) Run

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

Jump to

Keyboard shortcuts

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