# Functions
GetType identifies message bus type from an url.
NewNatsBus creates a NatsBus.
NewRabbitmqBus creates a RabbitmqBus.
WithNatsConn binds an existing NATS connection.
WithRabbitmqConn binds an existing RabbitMQ connection.
# Constants
DefaultMessageExpire value message expire.
DefaultQueueExpire value for queue auto expire.
DefaultReconnectionAttemts is the default number of reconnection attempts It implements a hard coded fault tolerance for a starting NATS cluster.
DefaultReconnectionWait is the default wating time between each reconnection attempt.
NATS type.
RabbitMQ type.
unknown type.
one word like pre.*.post.
undefined type.
zero or more words like pre.>.
# Structs
Config has general configuration for MessageBus.
NatsBus is MessageBus implementation for RabbitMQ.
NatsMSubscription handle multiple subscriptions with same handler.
RabbitmqBus is MessageBus implementation for RabbitMQ.
RmqSubscription handle RabbitMQ subscription.
# Interfaces
Client defines the functions used on ari-proxy client.
Server defines the functions used on ari-proxy server.
Subscription defines subscription interface.
# Type aliases
AnnounceHandler handles announce messages.
EventHandler handles event messages.
OptionNatsFunc options for RabbitMQ.
OptionRabbitmqFunc options for RabbitMQ.
PingHandler handles ping messages.
RequestHandler handles requests messages.
ResponseHandler handles response messages.
Type is the type of MessageBus (RabbitMQ / NATS).
WildcardType used to identify wildcards used on routing keys on message bus.