amqp

package

v0.0.0-...-1f10c8a Latest Latest Go to latest Published: May 8, 2024 License: Apache-2.0 Imports: 10 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/DataDog/datadog-agent

Documentation ¶

Overview ¶

Package amqp provides a simple wrapper around 3rd party amqp client.

Index ¶

Constants
func RunServer(t testing.TB, serverAddr, serverPort string) error
type Client
- func NewClient(opts Options) (*Client, error)
type Options
type Queue

Constants ¶

View Source

const (
	// User is the user to use for authentication
	User = "guest"
	// Pass is the password to use for authentication
	Pass = "guest"
)

Variables ¶

This section is empty.

Functions ¶

func RunServer ¶

func RunServer(t testing.TB, serverAddr, serverPort string) error

RunServer runs an amqp server in a docker container

Types ¶

type Client ¶

type Client struct {
	PublishConn    *amqp.Connection
	PublishChannel *amqp.Channel
	ConsumeConn    *amqp.Connection
	ConsumeChannel *amqp.Channel
	// contains filtered or unexported fields
}

Client is a wrapper around the amqp client

func NewClient ¶

func NewClient(opts Options) (*Client, error)

NewClient creates a new amqp client

func (*Client) Consume ¶

func (c *Client) Consume(queue string, numberOfMessages int) ([]string, error)

Consume reads a message from the queue

func (*Client) DeclareQueue ¶

func (c *Client) DeclareQueue(name string, ch *amqp.Channel) error

DeclareQueue creates a queue with the given name

func (*Client) DeleteQueues ¶

func (c *Client) DeleteQueues() error

DeleteQueues deletes all queues from the server

func (*Client) Publish ¶

func (c *Client) Publish(queue, body string) error

Publish sends a message to the queue

func (*Client) Terminate ¶

func (c *Client) Terminate()

Terminate closes all connections and channels

type Options ¶

type Options struct {
	ServerAddress string
	Username      string
	Password      string
	Dialer        *net.Dialer
}

Options is a struct to hold the options for the amqp client

type Queue ¶

type Queue struct {
	Name string
}

Queue represents an amqp queue

Source Files ¶

View all Source files

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