repository

type QueueNotFoundError struct {
	QueueName string
}

type QueueRepository interface {
	Add(q *model.Queue) error
	FindAll() ([]model.Queue, error)
	FindByName(name string) (*model.Queue, error)
	DeleteByName(name string) error
	Revision() (uint64, error)
}

type Repositories struct {
	Queue   QueueRepository
	Routing RoutingRepository
}

type RoutingRepository interface {
	Add(jobCategory string, queueName string) error
	FindAll() ([]model.Routing, error)
	FindQueueNameByJobCategory(category string) string
	DeleteByJobCategory(category string) error
	Revision() (uint64, error)
	Reload() error
}