Package amqpwrap has some simple wrappers to make it easier to abstract the go-amqp types.

Package auth provides an abstraction over claims-based security for Azure Event Hub and Service Bus.

Copyright (c) Microsoft Corporation.

Package mock is a generated GoMock package.

CancelScheduledMessages allows for removal of messages that have been handed to the Service Bus broker for later delivery, but have not yet ben enqueued.

GetRecoveryKind determines the recovery type for non-session based links.

GetRecoveryKindForSession determines the recovery type for session-based links.

GetSessionState retrieves state associated with the session.

NamespaceWithConnectionString configures a namespace with the information provided in a Service Bus connection string.

NamespaceWithCustomEndpoint sets a custom endpoint, useful for when you're connecting through a TCP proxy.

NamespaceWithNewClientFn lets you inject a construction function to create new AMQP clients.

NamespaceWithTLSConfig appends to the TLS config.

NamespaceWithTokenCredential sets the token provider on the namespace fullyQualifiedNamespace is the Service Bus namespace name (ex: myservicebus.servicebus.windows.net).

NamespaceWithUserAgent appends to the root user-agent value.

NamespaceWithWebSocket configures the namespace and all entities to use wss:// rather than amqps://.

NegotiateClaim attempts to put a token to the $cbs management endpoint to negotiate auth for the given audience.

NewAMQPLinks creates a session, starts the claim refresher and creates an associated management link for a specific entity path.

NewErrIncorrectType lets you skip using the `reflect` package.

NewNamespace creates a new namespace configured through NamespaceOption(s).

NewRPCLink will build a new request response link.

RenewLocks renews the locks in a single 'com.microsoft:renew-lock' operation.

RenewSessionLocks renews a session lock.

ScheduleMessages will send a batch of messages to a Queue, schedule them to be enqueued, and return the sequence numbers that can be used to cancel each message.

SetSessionState sets the state associated with the session.

SettleOnMgmtLink allows you settle a message using the management link, rather than via your *amqp.Receiver.

TransformError will create a proper error type that users can potentially inspect.

RPCResponseCodeLockLost comes back if you lose a message lock _or_ a session lock.

Version is the semantic version number.

AMQPLinksImpl manages the set of AMQP links (and detritus) typically needed to work within Service Bus: - An *goamqp.Sender or *goamqp.Receiver AMQP link (could also be 'both' if needed) - A `$management` link - an *goamqp.Session State management can be done through Recover (close and reopen), Close (close permanently, return failures) and Get() (retrieve latest version of all AMQPLinksImpl, or create if needed).

LinkID is ID that represent our current link and the client used to create it.

RPCError is an error from an RPCLink.

NamespaceForAMQPLinks is the Namespace surface needed for the internals of AMQPLinks.

CreateLinkFunc creates the links, using the given session.

RecoveryKind dictates what kind of recovery is possible.