core

Documentation

Index

• type Coordinator
  • func NewCoordinator(mgr ctrl.Manager) Coordinator
• type Iterator
• type QueueSelector
  • func NewRoundRobinSelector() QueueSelector

Types

type Coordinator

type Coordinator interface {
	Run(ctx context.Context)
	EnqueueOrUpdate(qu *jobcoordinator.QueueUnit)
	Dequeue(uid types.UID)
	IsQueuing(uid types.UID) bool
	SetQueueUnitOwner(uid types.UID, owner workqueue.RateLimitingInterface)
}

func NewCoordinator

func NewCoordinator(mgr ctrl.Manager) Coordinator

type Iterator

type Iterator interface {
	// HasNext indicates that is iterator at the ending position of queue.
	HasNext() bool
	// Next returns current unit pointed by pivot and increment pivot.
	Next() *jobcoordinator.QueueUnit
}

Iterator defines how to iterate a units queue, and it is irreversible once pivot has incremented.

type QueueSelector

type QueueSelector interface {
	Next(queues map[string]*queue) (string, *queue)
}

func NewRoundRobinSelector

func NewRoundRobinSelector() QueueSelector