puddle

Sep 10, 2024

Changes in this version

type Stat

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

Sep 17, 2022

Changes in this version

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

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

+ type Config struct

+ Constructor Constructor[T]

+ Destructor Destructor[T]

+ MaxSize int32

+ type Constructor func(ctx context.Context) (res T, err error)

+ type Destructor func(res T)

+ type Pool struct

+ func NewPool(config *Config[T]) (*Pool[T], error)

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

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

+ func (p *Pool[T]) Close()

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

+ func (p *Pool[T]) Reset()

+ func (p *Pool[T]) Stat() *Stat

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

+ type Resource struct

+ func (res *Resource[T]) CreationTime() time.Time

+ func (res *Resource[T]) Destroy()

+ func (res *Resource[T]) Hijack()

+ func (res *Resource[T]) IdleDuration() time.Duration

+ func (res *Resource[T]) LastUsedNanotime() int64

+ func (res *Resource[T]) Release()

+ func (res *Resource[T]) ReleaseUnused()

+ func (res *Resource[T]) Value() T

+ 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