Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueNotFoundError ¶
type QueueNotFoundError struct {
QueueName string
}
QueueNotFoundError is an error returned when a non-existing queue is specifie as the destination of a routing.
func (*QueueNotFoundError) Error ¶
func (qe *QueueNotFoundError) Error() string
type QueueRepository ¶
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) }
QueueRepository is an interface of a queue repository.
type Repositories ¶
type Repositories struct { Queue QueueRepository Routing RoutingRepository }
Repositories contains a queue repository and a routing repository.
type 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 }
RoutingRepository is an interface of a routing repository.
Click to show internal directories.
Click to hide internal directories.