pool

Documentation

Index

• Variables
• type Factory
• type Pool
  • func NewChannelPool(initialCap, maxCap int, factory Factory) (Pool, error)
• type PoolConn
  • func (p PoolConn) Close() error

Variables

var (
	ErrClosed = errors.New("pool is closed")
)

Types

type Factory

type Factory func() (*grpc.ClientConn, error)

type Pool

type Pool interface {
	Get() (PoolConn, error)
	Close()
	Len() int
}

func NewChannelPool

func NewChannelPool(initialCap, maxCap int, factory Factory) (Pool, error)

type PoolConn

type PoolConn struct {
	Conn *grpc.ClientConn
	// contains filtered or unexported fields
}

func (PoolConn) Close

func (p PoolConn) Close() error