connector

Documentation

Index

• type Connector
  • func NewConnector(log *logrus.Logger) *Connector
  • func (cn *Connector) CloseAll()
  • func (cn *Connector) GetConnections() (map[string]connections.IConnection, error)
  • func (cn *Connector) NewConnection(name string, opts *connections.ConnectionOptions) error

Types

type Connector

type Connector struct {
	// contains filtered or unexported fields
}

Connector struct contains the connections

func NewConnector

func NewConnector(log *logrus.Logger) *Connector

NewConnector creates a new Connector object

func (*Connector) CloseAll

func (cn *Connector) CloseAll()

CloseAll closes all open connections

func (*Connector) GetConnections

func (cn *Connector) GetConnections() (map[string]connections.IConnection, error)

GetConnections holds all connections and reconnects/reopens them if necessary

func (*Connector) NewConnection

func (cn *Connector) NewConnection(name string, opts *connections.ConnectionOptions) error

NewConnection Add a new connection and initiates first contact connection