Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrConnectionString = errors.New("incorrect connection string") ErrParameterLength = errors.New("incorrect parameter length") ErrConfig = errors.New("incorrect config type") )
View Source
var (
ErrClosed = errors.New("pool is closed")
)
Functions ¶
This section is empty.
Types ¶
type Conn ¶
type Conn struct { *amqp.Connection // contains filtered or unexported fields }
func (*Conn) MarkUnusable ¶
func (p *Conn) MarkUnusable()
type Connection ¶
type Connection interface {
Close() error
}
type Factory ¶
type Factory func() (*amqp.Connection, error)
Click to show internal directories.
Click to hide internal directories.