asyncImpl

Documentation

Index

• func New() app.Asynchronous
• type Handler
  • func (async Handler) AddJob(ctx app.Context, queue app.Queue, job app.Job) error
• type WorkerGroup
  • func (pool WorkerGroup) AddJob(baseCtx app.Context, job app.Job) error
  • func (pool WorkerGroup) Start()

Functions

func New

func New() app.Asynchronous

Types

type Handler

type Handler struct {
	Queues map[app.Queue]app.WorkerPool
}

func (Handler) AddJob

func (async Handler) AddJob(ctx app.Context, queue app.Queue, job app.Job) error

type WorkerGroup

type WorkerGroup struct {
	NumWorkers int
	JobChan    chan func()
}

func (WorkerGroup) AddJob

func (pool WorkerGroup) AddJob(baseCtx app.Context, job app.Job) error

func (WorkerGroup) Start

func (pool WorkerGroup) Start()