Versions in this module Expand all Collapse all v1 v1.0.0 Dec 21, 2017 Changes in this version + type PushResult struct + ID uint64 + QueueName string + type RunningQueue interface + MaxWorkers func() uint + PollingInterval func() uint + WorkerStats func() *dispatcher.Stats + type Service struct + func NewService(repos *repository.Repositories) *Service + func (s *Service) AddJobQueue(q *model.Queue) error + func (s *Service) DeleteJobQueue(qn string) error + func (s *Service) GetJobQueue(qn string) (RunningQueue, bool) + func (s *Service) Push(job jobqueue.IncomingJob) (*PushResult, error) + func (s *Service) Stop() <-chan struct{}