relyq

type ArbitraryTask map[string]interface{}

type Config struct {
	// Required: Prefix on simpleq.Queue key names for redis
	Prefix string
	// Field in any object which contains a unique identifier
	// Defaults to "id"
	IdField string
	// Redis delimeter. Defaults to ":"
	Delimiter string
	// Clean finish (i.e. no Done queue)
	// Defaults to false
	UseDoneQueue bool
	// Should we keep the task stored after they are done?
	// Defaults to false
	KeepDoneTasks bool
}

type Ider interface {
	// Ensure an id exists by creating it if necessary. Always return it.
	Id() []byte
}

type Listener struct {
	Errors              chan error
	Tasks, Fail, Finish chan Ider
	// contains filtered or unexported fields
}

type Queue struct {
	// The underlying simpleqs
	Todo, Doing, Done, Failed *simpleq.Queue
	Storage                   Storage
	Cfg                       *Config
	// contains filtered or unexported fields
}

type Storage interface {
	// Get a task object
	Get(taskid []byte, task interface{}) error
	// Save a task object
	Set(task interface{}, taskid []byte) error
	// Delete the task object in the storage
	Del(taskid []byte) error
	// End the Storage connection
	io.Closer
}

type StructuredTask struct {
	RqId string `json:"id"`
}