package
0.6.0
Repository: https://github.com/azure/azure-sdk-for-go.git
Documentation: pkg.go.dev

# Functions

Dial connects to an AMQP server.
LinkFilterSelector creates or updates the selector filter (apache.org:selector-filter:string) for this LinkFilter.
LinkFilterSource creates or updates the named filter for this LinkFilter.
New establishes an AMQP client connection over conn.
NewMessage returns a *Message with data as the payload.
ConnSASLAnonymous enables SASL ANONYMOUS authentication for the connection.
ConnSASLExternal enables SASL EXTERNAL authentication for the connection.
ConnSASLPlain enables SASL PLAIN authentication for the connection.
ConnSASLXOAUTH2 enables SASL XOAUTH2 authentication for the connection.

# Constants

Only the existence and configuration of the terminus is retained durably.
No terminus state is retained durably.
In addition to the existence and configuration of the terminus, the unsettled state for durable messages is retained durably.
Connection Errors.
Error Conditions.
Error Conditions.
Link Errors.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
AMQP Errors.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Error Conditions.
Session Errors.
The expiry timer starts when most recently associated connection is closed.
The expiry timer starts when terminus is detached.
The terminus never expires.
The expiry timer starts when the most recently associated session is ended.
Receiver will spontaneously settle all incoming transfers.
Sender MAY send a mixture of settled and unsettled deliveries to the receiver.
Receiver will only settle after sending the disposition to the sender and receiving a disposition indicating settlement of the delivery from the sender.
Sender will send all deliveries settled to the receiver.
Sender will send all deliveries initially unsettled to the receiver.

# Variables

ErrLinkClosed is returned by send and receive operations when Sender.Close() or Receiver.Close() are called.
ErrSessionClosed is propagated to Sender/Receivers when Session.Close() is called.

# Structs

Client is an AMQP client connection.
ConnectionError is propagated to Session and Senders/Receivers when the connection has been closed or is no longer functional.
ConnOptions contains the optional settings for configuring an AMQP connection.
DetachError is returned by a link (Receiver/Sender) when a detach frame is received.
Message is an AMQP message.
MessageHeader carries standard delivery details about the transfer of a message.
MessageProperties is the defined set of properties for AMQP messages.
ModifyMessageOptions contains the optional parameters to ModifyMessage.
Receiver receives messages on a single AMQP link.
No description provided by the author
Sender sends messages on a single AMQP link.
No description provided by the author
Session is an AMQP session.
SessionOption contains the optional settings for configuring an AMQP session.

# Interfaces

AMQP types.

# Type aliases

AMQP types.
Annotations keys must be of type string, int, or int64.
AMQP types.
Durability specifies the durability of a link.
No description provided by the author
No description provided by the author
ExpiryPolicy specifies when the expiry timer of a terminus starts counting down from the timeout value.
LinkFilter is an advanced API for setting non-standard source filters.
ReceiverSettleMode specifies how the receiver will settle messages.
SASLType represents a SASL configuration to use during authentication.
SenderSettleMode specifies how the sender will settle messages.
AMQP types.
AMQP types.
No description provided by the author