Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ItemProcessFunc ¶
type ItemProcessFunc func(obj interface{}) error
type RetryingWorkQueue ¶
type RetryingWorkQueue struct {
// contains filtered or unexported fields
}
func NewRetryingWorkQueue ¶
func NewRetryingWorkQueue(queueType string, indexer cache.Indexer, threadiness int, stopCh chan struct{}) *RetryingWorkQueue
func (*RetryingWorkQueue) AddItem ¶
func (rwq *RetryingWorkQueue) AddItem(obj interface{})
func (*RetryingWorkQueue) Run ¶
func (rwq *RetryingWorkQueue) Run(businessLogicFunc ItemProcessFunc)
Source Files
Click to show internal directories.
Click to hide internal directories.