stomp

Documentation

Index

• type Deliverer
  • func New(conf *config.STOMP) (*Deliverer, error)
  • func (d *Deliverer) Deliver(ctx context.Context, nID uuid.UUID) error
  • func (d *Deliverer) Name() string
• type DirectDeliverer
  • func NewDirectDeliverer(conf *config.STOMP) (*DirectDeliverer, error)
  • func (d *DirectDeliverer) Deliver(ctx context.Context, nID 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 a STOMP deliverer which publishes a notifier.Callback to the the broker.

func New

func New(conf *config.STOMP) (*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
}

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

func NewDirectDeliverer

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

func (*DirectDeliverer) Deliver

func (d *DirectDeliverer) Deliver(ctx context.Context, nID 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 STOMP delivery.