connection_initializer

package
v0.0.0-...-c228acb Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2023 License: MIT Imports: 7 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL