Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDummyObject ¶
func GetDummyObject(name string) *metav1.ObjectMeta
GetDummyObject returns a valid object that can be used in the Queue
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue manages a time work queue through an independent worker that invokes the given sync function for every work item inserted. The queue uses an internal timestamp that allows the removal of certain elements which timestamp is older than the last successful get operation.
func NewCustomTaskQueue ¶
func NewCustomTaskQueue(syncFn func(interface{}) error, fn func(interface{}) (interface{}, error)) *Queue
NewCustomTaskQueue ...
func NewTaskQueue ¶
NewTaskQueue creates a new task queue with the given sync function. The sync function is called for every element inserted into the queue.
func (*Queue) EnqueueSkippableTask ¶
func (t *Queue) EnqueueSkippableTask(obj interface{})
EnqueueSkippableTask enqueues ns/name of the given api object in the task queue that can be skipped
func (*Queue) EnqueueTask ¶
func (t *Queue) EnqueueTask(obj interface{})
EnqueueTask enqueues ns/name of the given api object in the task queue.
func (*Queue) IsShuttingDown ¶
IsShuttingDown returns if the method Shutdown was invoked
Source Files