package worker

import "github.com/gobuffalo/buffalo/worker"

Index ¶

• type Args
• func (a Args) String() string
• type Handler
• type Job
• func (j Job) String() string
• type Simple
• func NewSimple() *Simple
• func NewSimpleWithContext(ctx context.Context) *Simple
• func (w *Simple) Perform(job Job) error
• func (w *Simple) PerformAt(job Job, t time.Time) error
• func (w *Simple) PerformIn(job Job, d time.Duration) error
• func (w *Simple) Register(name string, h Handler) error
• func (w *Simple) Start(ctx context.Context) error
• func (w *Simple) Stop() error
• type SimpleLogger
• type Worker

Types ¶

type Args ¶

type Args map[string]interface{}

Args are the arguments passed into a job

func (Args) String ¶

func (a Args) String() string

type Handler ¶

type Handler func(Args) error

Handler function that will be run by the worker and given a slice of arguments

type Job ¶

type Job struct {
	// Queue the job should be placed into
	Queue string
	// Args that will be passed to the Handler when run
	Args Args
	// Handler that will be run by the worker
	Handler string
}

Job to be processed by a Worker

func (Job) String ¶

func (j Job) String() string

type Simple ¶

type Simple struct {
	Logger SimpleLogger
	// contains filtered or unexported fields
}

Simple is a basic implementation of the Worker interface that is backed using just the standard library and goroutines.

func NewSimple ¶

func NewSimple() *Simple

NewSimple creates a basic implementation of the Worker interface that is backed using just the standard library and goroutines.

func NewSimpleWithContext ¶

func NewSimpleWithContext(ctx context.Context) *Simple

NewSimpleWithContext creates a basic implementation of the Worker interface that is backed using just the standard library and goroutines.

func (*Simple) Perform ¶

func (w *Simple) Perform(job Job) error

Perform a job as soon as possibly using a goroutine.

func (*Simple) PerformAt ¶

func (w *Simple) PerformAt(job Job, t time.Time) error

PerformAt performs a job at a particular time using a goroutine.

func (*Simple) PerformIn ¶

func (w *Simple) PerformIn(job Job, d time.Duration) error

PerformIn performs a job after waiting for a specified amount using a goroutine.

func (*Simple) Register ¶

func (w *Simple) Register(name string, h Handler) error

Register Handler with the worker

func (*Simple) Start ¶

func (w *Simple) Start(ctx context.Context) error

Start the worker

func (*Simple) Stop ¶

func (w *Simple) Stop() error

Stop the worker

type SimpleLogger ¶

type SimpleLogger interface {
	Debugf(string, ...interface{})
	Infof(string, ...interface{})
	Errorf(string, ...interface{})
	Debug(...interface{})
	Info(...interface{})
	Error(...interface{})
}

SimpleLogger is used by the Simple worker to write logs

type Worker ¶

type Worker interface {
	// Start the worker with the given context
	Start(context.Context) error
	// Stop the worker
	Stop() error
	// Perform a job as soon as possibly
	Perform(Job) error
	// PerformAt performs a job at a particular time
	PerformAt(Job, time.Time) error
	// PerformIn performs a job after waiting for a specified amount of time
	PerformIn(Job, time.Duration) error
	// Register a Handler
	Register(string, Handler) error
}

Worker interface that needs to be implemented to be considered a "worker"

Source Files ¶

job.go simple.go worker.go