queue_mongo

Documentation

Index

• Constants
• type Storage
  • func New(database *mongo.Database, lockQuantity int, timeoutMinutes int) Storage
  • func (storage Storage) DeleteTask(taskID string) error
  • func (storage Storage) GetTasks() ([]queue.Task, error)
  • func (storage Storage) LogFailure(task queue.Task) error
  • func (storage Storage) SaveTask(task queue.Task) error

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

Types

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

Storage implements a queue Storage interface using MongoDB

func New

func New(database *mongo.Database, lockQuantity int, timeoutMinutes int) Storage

New returns a fully initialized Storage object

func (Storage) DeleteTask

func (storage Storage) DeleteTask(taskID string) error

DeleteTask removes a task from the queue

func (Storage) GetTasks

func (storage Storage) GetTasks() ([]queue.Task, error)

GetTasks returns all tasks that are currently locked by this worker

func (Storage) LogFailure

func (storage Storage) LogFailure(task queue.Task) error

LogFailure adds a task to the error log

func (Storage) SaveTask

func (storage Storage) SaveTask(task queue.Task) error

SaveTask adds/updates a task to the queue