Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Closure ¶
type Closure func(v interface{}) error
Closure is the function used for each item in the Queue to handle the logic
type QueueWorker ¶
type QueueWorker struct {
// contains filtered or unexported fields
}
QueueWorker allow us to run N concurrent jobs in order
func (*QueueWorker) Work ¶
func (qw *QueueWorker) Work(closure Closure) error
Work starts N coroutines based on QueueWorker.workers The queue will stop at first failure if any. The workers expect the queue to be populated before any work is started.
Source Files
Click to show internal directories.
Click to hide internal directories.