amqp

package

v0.0.0-...-2844cfb Latest Latest Go to latest Published: May 29, 2024 License: Apache-2.0 Imports: 14 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, withTLS bool) 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"

	// Plaintext is a flag to indicate that the server should be started with plaintext
	Plaintext = false
	// TLS is a flag to indicate that the server should be started with TLS
	TLS = true
)

Variables ¶

This section is empty.

Functions ¶

func RunServer ¶

func RunServer(t testing.TB, serverAddr, serverPort string, withTLS bool) 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

	// WithTLS indicates whether the connection should be made using TLS
	WithTLS bool
}

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