Documentation ¶
Index ¶
Constants ¶
View Source
const ( ConnectionManagerStatusNew = "new" ConnectionManagerStatusConnected = "connected" ConnectionManagerStatusDisconnected = "disconnected" ConnectionManagerStatusShutdown = "shutdown" )
Variables ¶
View Source
var ConnectionManagerDisconnected = errors.New("connection manager disconnected")
Functions ¶
This section is empty.
Types ¶
type ConnectionInitializer ¶
type ConnectionInitializer interface { Connect() error ShutDown() error GetAMQPChannel() (*amqp.Channel, error) ReconnectWithConnectionError() ReconnectSuccessfulNotifierChannel() <-chan bool }
func NewConnectionInitializer ¶
func NewConnectionInitializer(conf *eventbusclient.Config) ConnectionInitializer
Click to show internal directories.
Click to hide internal directories.