state

Documentation

Index

• type QueueActionFn
• type State
  • func NewState(queue *v1alpha2.Queue) State
• type UpdateQueueStatusFn

Types

type QueueActionFn

type QueueActionFn func(queue *v1alpha2.Queue, fn UpdateQueueStatusFn) error

QueueActionFn will open, close or sync queue.

var (
	// SyncQueue will sync queue status.
	SyncQueue QueueActionFn
	// OpenQueue will set state of queue to open
	OpenQueue QueueActionFn
	// CloseQueue will set state of queue to close
	CloseQueue QueueActionFn
)

type State

type State interface {
	// Execute executes the actions based on current state.
	Execute(action v1alpha2.QueueAction) error
}

State interface

func NewState

func NewState(queue *v1alpha2.Queue) State

NewState gets the state from queue status

type UpdateQueueStatusFn

type UpdateQueueStatusFn func(status *v1alpha2.QueueStatus, podGroupList []string)

UpdateQueueStatusFn updates the queue status