storage

Documentation

Index

• type ExchangeRepository
• type InMemoryExchangeRepository
  • func NewInMemoryExchangeRepository(exchangeList map[string]*internal.Exchange) *InMemoryExchangeRepository
  • func (r *InMemoryExchangeRepository) DeleteExchange(name string) (err errs.AppError)
  • func (r *InMemoryExchangeRepository) FindExchanges() []*internal.Exchange
  • func (r *InMemoryExchangeRepository) GetExchange(name string) (exchange *internal.Exchange, err errs.AppError)
  • func (r *InMemoryExchangeRepository) StoreExchange(exchange *internal.Exchange)
• type InMemoryQueueRepository
  • func NewInMemoryQueueRepository(queueList map[string]*internal.Queue) *InMemoryQueueRepository
  • func (r *InMemoryQueueRepository) DeleteQueue(name string) (err errs.AppError)
  • func (r *InMemoryQueueRepository) FindQueues() []*internal.Queue
  • func (r *InMemoryQueueRepository) GetQueue(name string) (queue *internal.Queue, err errs.AppError)
  • func (r *InMemoryQueueRepository) StoreQueue(queue *internal.Queue)
• type QueueRepository

Types

type ExchangeRepository

type ExchangeRepository interface {
	StoreExchange(exchange *internal.Exchange)
	FindExchanges() []*internal.Exchange
	GetExchange(name string) (queue *internal.Exchange, err errs.AppError)
	DeleteExchange(name string) (err errs.AppError)
}

type InMemoryExchangeRepository

type InMemoryExchangeRepository struct {
	ExchangeList map[string]*internal.Exchange
	// contains filtered or unexported fields
}

func NewInMemoryExchangeRepository

func NewInMemoryExchangeRepository(exchangeList map[string]*internal.Exchange) *InMemoryExchangeRepository

func (*InMemoryExchangeRepository) DeleteExchange

func (r *InMemoryExchangeRepository) DeleteExchange(name string) (err errs.AppError)

func (*InMemoryExchangeRepository) FindExchanges

func (r *InMemoryExchangeRepository) FindExchanges() []*internal.Exchange

func (*InMemoryExchangeRepository) GetExchange

func (r *InMemoryExchangeRepository) GetExchange(name string) (exchange *internal.Exchange, err errs.AppError)

func (*InMemoryExchangeRepository) StoreExchange

func (r *InMemoryExchangeRepository) StoreExchange(exchange *internal.Exchange)

type InMemoryQueueRepository

type InMemoryQueueRepository struct {
	QueueList map[string]*internal.Queue
	// contains filtered or unexported fields
}

func NewInMemoryQueueRepository

func NewInMemoryQueueRepository(queueList map[string]*internal.Queue) *InMemoryQueueRepository

func (*InMemoryQueueRepository) DeleteQueue

func (r *InMemoryQueueRepository) DeleteQueue(name string) (err errs.AppError)

func (*InMemoryQueueRepository) FindQueues

func (r *InMemoryQueueRepository) FindQueues() []*internal.Queue

func (*InMemoryQueueRepository) GetQueue

func (r *InMemoryQueueRepository) GetQueue(name string) (queue *internal.Queue, err errs.AppError)

func (*InMemoryQueueRepository) StoreQueue

func (r *InMemoryQueueRepository) StoreQueue(queue *internal.Queue)

type QueueRepository

type QueueRepository interface {
	StoreQueue(queue *internal.Queue)
	FindQueues() []*internal.Queue
	GetQueue(name string) (queue *internal.Queue, err errs.AppError)
	DeleteQueue(name string) (err errs.AppError)
}