connectionpool

Documentation

Index

• type Container
• type IConnectionProvider
• type Pool
  • func NewConnectionPool(serverList *[]string, username string, password string, ...) *Pool
  • func (pool *Pool) GetConnection() (*amqp.Connection, error)

Types

type Container

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

Container contains connection and related info

type IConnectionProvider

type IConnectionProvider interface {
	NewConnection(string, string, string, *gologger.CustomLogger) (*amqp.Connection, error)
}

IConnectionProvider defines the interface to be implemented by a connection provider.

type Pool

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

Pool represents a pool of connections

func NewConnectionPool

func NewConnectionPool(serverList *[]string, username string, password string, connectionProvider IConnectionProvider, logger *gologger.CustomLogger) *Pool

NewConnectionPool returns new connection pool, waits for 3 seconds before returning

func (*Pool) GetConnection

func (pool *Pool) GetConnection() (*amqp.Connection, error)

GetConnection provides a rabbitmq connection from connection pool, times out in 1 minute if unable to get a connection