handlers

Documentation

Index

• type Handler
  • func (h *Handler) All(v interface{}) error
  • func (h *Handler) Bind(v interface{}, id string) error
  • func (h *Handler) Create(v interface{}) error
  • func (h *Handler) Delete(v interface{}, id string) error
  • func (h *Handler) Paginate(paginator paginations.Pagination, result interface{}) paginations.Metadata
  • func (h *Handler) Update(v interface{}, id string) error
• type Messenger
  • func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error)
  • func (m *Messenger) Publish(queueName string, data []byte) error

Types

type Handler

type Handler struct {
	Logger     *loggers.Logger
	Dispatcher *events.Dispatcher
	Repository repositories.Repository
	Adapter    paginations.Adapter
}

func (*Handler) All

func (h *Handler) All(v interface{}) error

func (*Handler) Bind

func (h *Handler) Bind(v interface{}, id string) error

func (*Handler) Create

func (h *Handler) Create(v interface{}) error

func (*Handler) Delete

func (h *Handler) Delete(v interface{}, id string) error

func (*Handler) Paginate

func (h *Handler) Paginate(paginator paginations.Pagination, result interface{}) paginations.Metadata

func (*Handler) Update

func (h *Handler) Update(v interface{}, id string) error

type Messenger

type Messenger struct {
	Publisher *amqp.Publisher
	Consumer  *amqp.Subscriber
	Logger    *loggers.Logger
}

func (*Messenger) Consume

func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error)

func (*Messenger) Publish

func (m *Messenger) Publish(queueName string, data []byte) error