Versions in this module Expand all Collapse all v0 v0.0.1 Oct 12, 2019 Changes in this version + var ErrPoolClosed = errors.New("pool closed") + type ChanPool struct + func NewChanPool(factory func(Pool) (Elem, error), maxActive, maxIdle int, ...) (cp *ChanPool) + func (p *ChanPool) Close() error + func (p *ChanPool) Get() (elem Elem, err error) + func (p *ChanPool) IsClosed() bool + func (p *ChanPool) Len() int + func (p *ChanPool) OutAllBefore(t time.Time) + func (p *ChanPool) Put(elem Elem) (err error) + type Elem interface + IsAlive func() bool + Out func() error + type ElemBase interface + CreatedTime func() time.Time + IsInPool func() bool + SetInPool func(bool) + func NewElemBase() ElemBase + type Pool interface + Close func() error + Get func() (elem Elem, err error) + IsClosed func() bool + Len func() int + OutAllBefore func(time.Time) + Put func(elem Elem) (err error)
Go to main page