Versions in this module Expand all Collapse all v1 v1.1.0 Jul 27, 2020 v1.0.0 Jul 23, 2020 Changes in this version + var ErrEmpty = errors.New("queue: queue is empty") + type AsyncQueue interface + Enqueue func(data []byte) error + func NewAsyncQueue(q Queue, handler Handler, workers int) (AsyncQueue, error) + type Handler func(data []byte, err error) + type Queue interface + Dequeue func() ([]byte, error) + Enqueue func(data []byte) error + func NewMemoryQueue() Queue + func NewSqlite3Queue(file string) (Queue, error)
Go to main page