file

Nov 22, 2024

Changes in this version

+ type Queue struct

+ func New(path string, prefix string, extension string) (*Queue, error)

+ func (q *Queue) Enqueue(p io.Reader) error

+ func (q *Queue) Peek() (queue.Entry, error)

+ func (q *Queue) Wait() chan struct{}

+ func (q *Queue) WaitForEmpty() chan struct{}