Versions in this module Expand all Collapse all v1 v1.0.0 Dec 21, 2017 Changes in this version + type QueueNotFoundError struct + QueueName string + func (qe *QueueNotFoundError) Error() string + type QueueRepository interface + Add func(q *model.Queue) error + DeleteByName func(name string) error + FindAll func() ([]model.Queue, error) + FindByName func(name string) (*model.Queue, error) + Revision func() (uint64, error) + type Repositories struct + Queue QueueRepository + Routing RoutingRepository + type RoutingRepository interface + Add func(jobCategory string, queueName string) error + DeleteByJobCategory func(category string) error + FindAll func() ([]model.Routing, error) + FindQueueNameByJobCategory func(category string) string + Reload func() error + Revision func() (uint64, error)
Go to main page