factory

Documentation

Index

• func NewImpl(q *model.Queue) jobqueue.Impl
• type IncomingJob
• type JobQueue
  • func Start(q *model.Queue) JobQueue

Functions

func NewImpl

func NewImpl(q *model.Queue) jobqueue.Impl

NewImpl creates a new jobqueue.Impl instance according to the value of "driver" configuration.

Types

type IncomingJob

type IncomingJob = jobqueue.IncomingJob

IncomingJob imitates IncomingJob in jobqueue package: factory package is intended to be used as a jobqueue package (by import jobqueue ".../fireworq/jobqueue/factory" since the only reason for having a separate package is to avoid cyclic import with a driver package such as mysql.

type JobQueue

type JobQueue = jobqueue.JobQueue

JobQueue imitates JobQueue in jobqueue package: factory package is intended to be used as a jobqueue package (by import jobqueue ".../fireworq/jobqueue/factory" since the only reason for having a separate package is to avoid cyclic import with a driver package such as mysql.

func Start

func Start(q *model.Queue) JobQueue

Start creates and starts a new JobQueue instance whose implementation is decided by the value of "driver" configuration.