puddle

Nov 20, 2021

Changes in this version

+ var ErrNotAvailable = errors.New("resource not available")

type Pool

+ func (p *Pool) TryAcquire(ctx context.Context) (*Resource, error)

Feb 5, 2020

Changes in this version

type Pool

+ func (p *Pool) CreateResource(ctx context.Context) error

type Resource

+ func (res *Resource) IdleDuration() time.Duration

+ func (res *Resource) LastUsedNanotime() int64

+ func (res *Resource) ReleaseUnused()

Jun 8, 2019

Changes in this version

+ var ErrClosedPool = errors.New("closed pool")

+ type Constructor func(ctx context.Context) (res interface{}, err error)

+ type Destructor func(res interface{})

+ type Pool struct

+ func NewPool(constructor Constructor, destructor Destructor, maxSize int32) *Pool

+ func (p *Pool) Acquire(ctx context.Context) (*Resource, error)

+ func (p *Pool) AcquireAllIdle() []*Resource

+ func (p *Pool) Close()

+ func (p *Pool) Stat() *Stat

+ type Resource struct

+ func (res *Resource) CreationTime() time.Time

+ func (res *Resource) Destroy()

+ func (res *Resource) Hijack()

+ func (res *Resource) Release()

+ func (res *Resource) Value() interface{}

+ type Stat struct

+ func (s *Stat) AcquireCount() int64

+ func (s *Stat) AcquireDuration() time.Duration

+ func (s *Stat) AcquiredResources() int32

+ func (s *Stat) CanceledAcquireCount() int64

+ func (s *Stat) ConstructingResources() int32

+ func (s *Stat) EmptyAcquireCount() int64

+ func (s *Stat) IdleResources() int32

+ func (s *Stat) MaxResources() int32

+ func (s *Stat) TotalResources() int32