Documentation
¶
Overview ¶
Package queue_filesystem provides a queue storage backed by the filesystem
Index ¶
Constants ¶
const CollectionLog = "Log"
CollectionLog is the name of the mongodb collection where completed/logged tasks are stored
const CollectionQueue = "Queue"
CollectionQueue is the name of the mongodb collection where queued tasks are stored
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
Storage implements a simplified queue Storage interface using a filesystem. This storage engine does not support duplicate checking. It returns a single task at a time, probably in order of creation time (but no guarantees are made). This storage engine is not safe for concurrent access by multiple workers.
func (Storage) DeleteTask ¶
DeleteTask removes a task from the queue
func (Storage) DeleteTaskBySignature ¶ added in v0.4.1
DeleteTaskBySignature removes a task from the queue by its signature
func (Storage) LogFailure ¶
LogFailure adds a task to the error log
Source Files