worker

package
v0.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 14, 2017 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Args

type Args map[string]interface{}

Args are the arguments passed into a job

func (Args) String added in v0.9.2

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 added in v0.9.2

func (j Job) String() string

type Simple added in v0.9.2

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 added in v0.9.2

func (w Simple) Perform(job Job) error

Perform a job as soon as possibly using a goroutine.

func (Simple) PerformAt added in v0.9.2

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

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

func (Simple) PerformIn added in v0.9.2

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 added in v0.9.2

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

Register Handler with the worker

func (*Simple) Start added in v0.9.2

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

Start the worker

func (Simple) Stop added in v0.9.2

func (w Simple) Stop() error

Stop the worker

type SimpleLogger added in v0.9.2

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"

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL