rq_controller

Documentation

Index

• Constants
• type RQController
  • func NewRQController(aaqCli client.AAQClient, rqInformer cache.SharedIndexInformer, ...) *RQController
  • func (ctrl *RQController) Execute() bool
  • func (ctrl *RQController) Run(threadiness int)

Constants

const (
	Immediate enqueueState = "Immediate"
	Forget    enqueueState = "Forget"
	BackOff   enqueueState = "BackOff"
	RQSuffix  string       = "-non-schedulable-resources-managed-rq-x"
)

Types

type RQController

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

func NewRQController

func NewRQController(aaqCli client.AAQClient,
	rqInformer cache.SharedIndexInformer,
	arqInformer cache.SharedIndexInformer,
	stop <-chan struct{},
) *RQController

func (*RQController) Execute

func (ctrl *RQController) Execute() bool

func (*RQController) Run

func (ctrl *RQController) Run(threadiness int)