goqueue

package module

v0.0.5 Latest Latest Go to latest Published: Feb 20, 2022 License: LGPL-2.1 Imports: 6 Imported by: 3

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Simple rabbitmq queue wrapper for golang.

View Source

const (
	RetryNext = iota - 3
	RetryStop
	RetryIgnore
)

View Source

const RetryHeader = "x-goqueue-retry"

This section is empty.

func Publish(amqpCh *amqp.Channel, consumerName string, data interface{}) error

type Callback func(amqp.Delivery, *log.Entry) (Retry, error)

type Consumer interface {
	Consume() error
}

func NewConsumer(name string, retryIntervals []time.Duration, callback Callback, amqpConn *amqp.Connection, consumerLog *log.Entry) Consumer

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

func (c DefaultConsumer) Consume() error

func (c DefaultConsumer) ProcessDelivery(delivery amqp.Delivery, deliveryLog *log.Entry, retry int)

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

func (p DefaultPool) Start()

type Pool interface {
	Start()
}

func NewPool(queue string, workers int, retryIntervals []time.Duration, callback Callback, amqpConn *amqp.Connection, poolLog *log.Entry) Pool

type Retry int