controller

Documentation

Index

• type CommonController
  • func NewMovementController(queue workqueue.RateLimitingInterface, stopCh <-chan struct{}, ...) CommonController
• type MovementController
  • func (mc *MovementController) AddMovement(movement *schedulingv1a1.Movement)
  • func (mc *MovementController) Close()
  • func (mc *MovementController) Run()

Types

type CommonController

type CommonController interface {
	// Run starts the goroutines managing the queue.
	Run()
	// Close closes the queue so that the goroutine which is
	// waiting to pop items can exit gracefully.
	Close()
	// add movement into queue
	AddMovement(movement *schedulingv1a1.Movement)
}

func NewMovementController

func NewMovementController(queue workqueue.RateLimitingInterface, stopCh <-chan struct{},
	movementLister schedulinglisterv1a1.MovementLister, schedulerName string,
	crdClient godelclient.Interface,
) CommonController

type MovementController

type MovementController struct {
	workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

func (*MovementController) AddMovement

func (mc *MovementController) AddMovement(movement *schedulingv1a1.Movement)

func (*MovementController) Close

func (mc *MovementController) Close()

Close closes the priority queue.

func (*MovementController) Run

func (mc *MovementController) Run()