Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue manages a work queue through an independent worker that invokes the given sync function for every work item inserted.
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) Enqueue ¶
func (t *Queue) Enqueue(obj interface{})
Enqueue 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
Click to show internal directories.
Click to hide internal directories.