Versions in this module Expand all Collapse all v0 v0.0.14 Jan 4, 2023 Changes in this version + var ErrConnectionClosed = errors.New("connections closed") + var ErrConnectionNotExists = errors.New("connection doesn't exist") + var ErrCouldNotAssignConnection = errors.New("assigning connection to gRPC client failed") + var ErrGroupNotExist = errors.New("group doesn't exist") + var ErrInvalidConnectionPool = errors.New("invalid connection pool") + type ClientConn struct + func (cc *ClientConn) Address() string + func (cc *ClientConn) Close() error + func (cc *ClientConn) Conn() FactoryConn + type CloseFunc func(conn interface{}) error + type Connection interface + Address func() string + Close func() error + Conn func() FactoryConn + type ConnectionPool struct + CloseFunc CloseFunc + func NewPool(opts ...Option) *ConnectionPool + func (p *ConnectionPool) Close() error + func (p *ConnectionPool) Get(address string) (Connection, error) + type Factory func(address string) (FactoryConn, error) + type FactoryConn interface + type Option func(*ConnectionPool) + func WithCloseFunc(closeFunc CloseFunc) Option + func WithFactory(factory Factory) Option + func WithLogger(logger logger.Logger) Option + func WithSize(size int) Option + type Pool interface + Close func() error + Get func(address string) (Connection, error) v0.0.13 Mar 29, 2021
Go to main page