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.

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

NamespaceWithConnectionString configures a namespace with the information provided in a Event Hub connection string.

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

NamespaceWithTLSConfig appends to the TLS config.

NamespaceWithTokenCredential sets the token provider on the namespace fullyQualifiedNamespace is the Event Hub 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.

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

NewRPCLink will build a new request response link.

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

Version is the semantic version number.

RPCError is an error from an RPCLink.

Closeable is implemented by pretty much any AMQP link/client including our own higher level Receiver/Sender.

LinksForPartitionClient are the functions that the PartitionClient uses within Links[T] (for unit testing only).

LinkWithID is a readonly interface over the top of a linkState.

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

NamespaceWithNewAMQPLinks is the Namespace surface for consumers of AMQPLinks.

TODO: might just consolidate.

RecoveryKind dictates what kind of recovery is possible.