job

Documentation

Index

• type ChainHandler
• type Chainer
• type Handler
• type Notifier
• type Poller
• type Request
  • func New(exchange, queue string, pub pubsub.Publisher, sub pubsub.Subscriber) *Request
  • func (r *Request) Fail(err error) error
  • func (r *Request) Notify() error
  • func (r *Request) NotifySchedules() error
  • func (r *Request) Poll() error

Types

type ChainHandler

type ChainHandler interface {
	Handler
	Chainer
}

ChainHandler — a Handler that can be chained to a "next" handler to create a chain of Handlers.

type Chainer

type Chainer interface {
	SetNext(Handler)
}

A Chainer can accept a Handler as its next Handler to create a chain of Handlers.

type Handler

type Handler interface {
	Handle(*Request)
}

A Handler responds to a Request.

type Notifier

type Notifier interface {
	Notify() error
	NotifySchedules() error
}

Notifier — notifies about the progress/status of a running job.

type Poller

type Poller interface {
	Poll() *Request
}

A Poller polls its source(s) for the available job.

type Request

type Request struct {
	event.JobQueued
	*event.JobUpdated

	*event.Schedules
	// contains filtered or unexported fields
}

func New

func New(exchange, queue string, pub pubsub.Publisher, sub pubsub.Subscriber) *Request

func (*Request) Fail

func (r *Request) Fail(err error) error

func (*Request) Notify

func (r *Request) Notify() error

func (*Request) NotifySchedules

func (r *Request) NotifySchedules() error

func (*Request) Poll

func (r *Request) Poll() error