amqp

Documentation

Index

• type Deliverer
  • func New(conf *config.AMQP) (*Deliverer, error)
  • func (d *Deliverer) Deliver(ctx context.Context, nID uuid.UUID) error
  • func (d *Deliverer) Name() string
• type DirectDeliverer
  • func NewDirectDeliverer(conf *config.AMQP) (*DirectDeliverer, error)
  • func (d *DirectDeliverer) Deliver(ctx context.Context, _ uuid.UUID) error
  • func (d *DirectDeliverer) Name() string
  • func (d *DirectDeliverer) Notifications(ctx context.Context, n []notifier.Notification) error

Types

type Deliverer

type Deliverer struct {
	// contains filtered or unexported fields
}

Deliverer is an AMQP deliverer which publishes a notifier.Callback to the the broker.

It's an error to configure this deliverer with an Exchange that does not exist. Administrators should configure the Exchange, Queue, and Bindings before starting this deliverer.

func New

func New(conf *config.AMQP) (*Deliverer, error)

func (*Deliverer) Deliver

func (d *Deliverer) Deliver(ctx context.Context, nID uuid.UUID) error

func (*Deliverer) Name

func (d *Deliverer) Name() string

type DirectDeliverer

type DirectDeliverer struct {
	Deliverer
	// contains filtered or unexported fields
}

DirectDeliverer is an AMQP deliverer which publishes notifications directly to the broker.

It's an error to configure this deliverer with an exchange that does not exist. Administrators should configure the Exchange, Queue, and Bindings before starting this deliverer.

func NewDirectDeliverer

func NewDirectDeliverer(conf *config.AMQP) (*DirectDeliverer, error)

func (*DirectDeliverer) Deliver

func (d *DirectDeliverer) Deliver(ctx context.Context, _ uuid.UUID) error

func (*DirectDeliverer) Name

func (d *DirectDeliverer) Name() string

func (*DirectDeliverer) Notifications

func (d *DirectDeliverer) Notifications(ctx context.Context, n []notifier.Notification) error

Notifications will copy the provided notifications into a buffer for AMQP delivery.