workqueue

Documentation

Index

• Constants
• type CompletedConfig
  • func Completed(qc *QueueConfig) *CompletedConfig
  • func (cc *CompletedConfig) NewQueue() (api.WorkQueue, error)
• type QueueConfig
  • func NewEventQueueConfig(name string, reconcile api.EventReonciler) *QueueConfig
  • func NewQueueConfig(reconcile api.Reconciler) *QueueConfig
  • func NewWrapQueueConfig(name string, reconcile api.WrapReconciler) *QueueConfig
• type ReconcilerType

Constants

const (
	DequeueTotal          = "dequeue_total"
	UnExpectedObjTotal    = "unexpected_obj_total"
	ReconcileSuccTotal    = "reconcile_succ_total"
	ReconcileFailTotal    = "reconcile_fail_total"
	ReconcileTimeDuration = "reconcile_duration"
	RequeueAfterTotal     = "requeue_after_total"
	RequeueRateLimitTotal = "requeue_rate_limit_total"
)

metrics key with labels

Types

type CompletedConfig

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

CompletedConfig wrapper workqueue

func Completed

func Completed(qc *QueueConfig) *CompletedConfig

func (*CompletedConfig) NewQueue

func (cc *CompletedConfig) NewQueue() (api.WorkQueue, error)

NewQueue build queue

type QueueConfig

type QueueConfig struct {
	Name                  string
	GotInterval           time.Duration
	RateLimitTimeInterval time.Duration
	RateLimitTimeMax      time.Duration
	RateLimit             int
	RateBurst             int
	Threadiness           int

	RT      ReconcilerType
	Do      api.Reconciler
	WrapDo  api.WrapReconciler
	EventDo api.EventReonciler
	// contains filtered or unexported fields
}

func NewEventQueueConfig

func NewEventQueueConfig(name string, reconcile api.EventReonciler) *QueueConfig

NewEventQueueConfig build queue which request with clustername and event function

func NewQueueConfig

func NewQueueConfig(reconcile api.Reconciler) *QueueConfig

NewQueueConfig build standard queue

func NewWrapQueueConfig

func NewWrapQueueConfig(name string, reconcile api.WrapReconciler) *QueueConfig

NewWrapQueueConfig build queue which request with clustername

type ReconcilerType

type ReconcilerType int

const (
	Normal ReconcilerType = iota
	Wrapper
	Event
)