Documentation
¶
Index ¶
Constants ¶
View Source
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
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompletedConfig ¶
type CompletedConfig struct {
// contains filtered or unexported fields
}
CompletedConfig wrapper workqueue
func Completed ¶
func Completed(qc *QueueConfig) *CompletedConfig
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
Source Files
Click to show internal directories.
Click to hide internal directories.