amqp

package
v4.7.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.