queue

package

v1.0.5 Latest Latest Go to latest Published: Aug 20, 2019 License: MIT Imports: 1 Imported by: 0

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

Repository

github.com/nrxr/rabbit

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Binding ¶

type Binding struct {
	Key    string
	NoWait bool
	Args   amqp.Table
}

Binding used to declare binding between AMQP Queue and AMQP Exchange

type Option ¶

type Option func(Queue) Queue

func AddBinding ¶

func AddBinding(b Binding) Option

func Args ¶

func Args(a amqp.Table) Option

func AutoDelete ¶

func AutoDelete() Option

func Durable ¶

func Durable() Option

func Exclusive ¶

func Exclusive() Option

func Name ¶

func Name(name string) Option

func NoWait ¶

func NoWait() Option

type Queue ¶

type Queue struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table

	Bindings []Binding
}

Queue hold definition of AMQP queue

func New ¶

func New(opts ...Option) Queue

New returns a Queue definition with the following defaults unless changed via the Option options.

 Queue{
	 Name: "",
	 Durable: false,
	 AutoDelete: false,
	 Exclusive: false,
	 NoWait: false,
	 Args: nil,
	 Bindings: []Binding{},
 }

Source Files ¶

View all Source files

queue.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL