fsjobqueue

Documentation

Overview

Package fsjobqueue implements a filesystem-backed job queue. It implements the interfaces in package jobqueue.

Jobs are stored in the file system, using the `jsondb` package. However, this package does not use the file system as a database, but keeps some state in memory. This means that access to a given directory must be exclusive to only one `fsJobQueue` object at a time. A single `fsJobQueue` can be safely accessed from multiple goroutines, though.

Data is stored non-reduntantly. Any data structure necessary for efficient access (e.g., dependants) are kept in memory.

Index

• func New(dir string) (*fsJobQueue, error)

Functions

func New

func New(dir string) (*fsJobQueue, error)

Create a new fsJobQueue object for `dir`. This object must have exclusive access to `dir`. If `dir` contains jobs created from previous runs, they are loaded and rescheduled to run if necessary.