Versions in this module Expand all Collapse all v1 v1.0.0 Dec 21, 2017 Changes in this version + func Init() + type Application struct + AccessLogWriter io.Writer + QueueRepository repository.QueueRepository + RoutingRepository repository.RoutingRepository + Service Service + Version string + func (app *Application) Serve() + type IncomingJob struct + CategoryField string + MaxRetriesField uint + PayloadField json.RawMessage + RetryDelayField uint + RunAfterField uint + TimeoutField uint + URLField string + func (job *IncomingJob) Category() string + func (job *IncomingJob) DecodePayload() error + func (job *IncomingJob) NextDelay() uint64 + func (job *IncomingJob) Payload() string + func (job *IncomingJob) RetryCount() uint + func (job *IncomingJob) RetryDelay() uint + func (job *IncomingJob) Timeout() uint + func (job *IncomingJob) URL() string + type PushResult struct + ID uint64 + QueueName string + type Service interface + AddJobQueue func(q *model.Queue) error + DeleteJobQueue func(qn string) error + GetJobQueue func(qn string) (service.RunningQueue, bool) + Push func(job jobqueue.IncomingJob) (*service.PushResult, error) + Stop func() <-chan struct{} + type Stats struct + ActiveNodes int64
Go to main page