repository

Documentation

Index

• type QueueNotFoundError
  • func (qe *QueueNotFoundError) Error() string
• type QueueRepository
• type Repositories
• type RoutingRepository

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.