Documentation ¶ Index ¶ func NewQueue(ctl app_control.Control, concurrency int) rc_worker.LegacyQueue type Queue func (z *Queue) Enqueue(w rc_worker.Worker) func (z *Queue) Launch(concurrency int) func (z *Queue) Wait() error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewQueue ¶ func NewQueue(ctl app_control.Control, concurrency int) rc_worker.LegacyQueue Types ¶ type Queue ¶ type Queue struct { // contains filtered or unexported fields } func (*Queue) Enqueue ¶ func (z *Queue) Enqueue(w rc_worker.Worker) func (*Queue) Launch ¶ func (z *Queue) Launch(concurrency int) func (*Queue) Wait ¶ func (z *Queue) Wait() error Source Files ¶ View all Source files worker.go Click to show internal directories. Click to hide internal directories.