jobs

Sep 6, 2019

Changes in this version

type Service

+ func (svc *Service) Server() *roadrunner.Server

May 19, 2019

Changes in this version

+ const EventJobOK

+ const EventJobStart

+ const EventPipeActive

+ const EventPipeConsume

+ const EventPipeError

+ const EventPipeStop

+ const EventPipeStopped

+ const EventPushOK

type Service

+ func (svc *Service) Attach(ctr roadrunner.Controller)

Jan 21, 2019

Changes in this version

+ const EventBrokerReady

+ const EventJobComplete

+ const EventJobError

+ const EventJobReceived

+ const EventPipelineConsume

+ const EventPipelineConsuming

+ const EventPipelineError

+ const EventPipelineStop

+ const EventPipelineStopped

+ const EventPushComplete

+ const EventPushError

type Broker

+ Consume func(pipe *Pipeline, execPool chan Handler, errHandler ErrorHandler) error

+ Register func(pipe *Pipeline) error

+ Stat func(pipe *Pipeline) (stat *Stat, err error)

type Config

+ Consume []string

+ Dispatch Dispatcher

+ func (c *Config) Get(service string) service.Config

+ func (c *Config) MatchPipeline(job *Job) (*Pipeline, *Options, error)

+ func (c *Config) Unmarshal(out interface{}) error

+ type Dispatcher map[string]*Options

+ type EventProvider interface

+ Listen func(lsn func(event int, ctx interface{}))

+ type JobError struct

+ Caused error

+ ID string

+ Job *Job

+ func (e *JobError) Elapsed() time.Duration

+ func (e *JobError) Error() string

+ type JobEvent struct

+ ID string

+ Job *Job

+ func (e *JobEvent) Elapsed() time.Duration

type Options

+ Attempts int

+ Pipeline string

+ func (o *Options) CanRetry(attempt int) bool

+ func (o *Options) Merge(from *Options)

type Pipeline

+ func (p Pipeline) Bool(name string, d bool) bool

+ func (p Pipeline) Duration(name string, d time.Duration) time.Duration

+ func (p Pipeline) Integer(name string, d int) int

+ func (p Pipeline) Map(name string) Pipeline

+ func (p Pipeline) Name() string

+ func (p Pipeline) String(name string, d string) string

+ func (p Pipeline) With(name string, value interface{}) Pipeline

+ type PipelineError struct

+ Caused error

+ Pipeline *Pipeline

+ func (e *PipelineError) Error() string

+ type PipelineList struct

+ Pipelines []*Stat

+ type Pipelines []*Pipeline

+ func (ps Pipelines) Broker(broker string) Pipelines

+ func (ps Pipelines) Get(name string) *Pipeline

+ func (ps Pipelines) Names(only ...string) Pipelines

+ func (ps Pipelines) Reverse() Pipelines

type Service

+ func (s *Service) AddListener(l func(event int, ctx interface{}))

+ func (s *Service) Consume(pipe *Pipeline, execPool chan Handler, errHandler ErrorHandler) error

+ func (s *Service) Pipelines() Pipelines

+ func (s *Service) Stat(pipe *Pipeline) (stat *Stat, err error)

+ type Stat struct

+ Active int64

+ Broker string

+ Consuming bool

+ Delayed int64

+ InternalName string

+ Pipeline string

+ Queue int64

+ type WorkerList struct

+ Workers []*util.State

Sep 26, 2018

Changes in this version

+ func Listener(logger *logrus.Logger) func(event int, ctx interface{})

Sep 24, 2018

Changes in this version

+ const BrokersConfig

+ type Broker interface

+ Listen func(pipelines []*Pipeline, pool chan Handler, err ErrorHandler) error

+ Push func(p *Pipeline, j *Job) (id string, err error)

+ Serve func() error

+ Stop func()

type Config

+ Workers *roadrunner.ServerConfig

+ type ErrorHandler func(id string, j *Job, err error) error

+ type Handler func(id string, j *Job) error

+ type Job struct

+ Attempt int

+ Job string

+ Options Options

+ Payload string

+ func (j *Job) Body() []byte

+ func (j *Job) CanRetry() bool

+ func (j *Job) Context(id string) ([]byte, error)

+ type Options struct

+ Delay int

+ MaxAttempts int

+ RetryDelay int

+ Timeout int

+ func (o *Options) DelayDuration() time.Duration

+ func (o *Options) RetryDuration() time.Duration

+ func (o *Options) TimeoutDuration() time.Duration

+ type Pipeline struct

+ Broker string

+ Handle []string

+ Listen bool

+ Options PipelineOptions

+ Retry int

+ RetryDelay int

+ func (p *Pipeline) Has(job string) bool

+ type PipelineOptions map[string]interface

+ func (o PipelineOptions) Bool(name string, d bool) bool

+ func (o PipelineOptions) Duration(name string, d time.Duration) time.Duration

+ func (o PipelineOptions) Integer(name string, d int) int

+ func (o PipelineOptions) String(name string, d string) string

type Service

+ Brokers map[string]Broker

+ func (s *Service) Push(j *Job) (string, error)

Aug 26, 2018

Changes in this version

+ const ID

+ type Config struct

+ Enabled bool

+ Handlers struct{ ... }

+ Pipelines map[string]string

+ func (c *Config) Hydrate(cfg service.Config) error

+ func (c *Config) Valid() error

+ type Service struct

+ Logger *logrus.Logger

+ func (s *Service) Init(cfg *Config, r *rpc.Service) (ok bool, err error)

+ func (s *Service) Serve() error

+ func (s *Service) Stop()