gopool

README

gopool

go connection pool with channel

Documentation

Index

• Variables
• type ChanPool
  • 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
• type ElemBase
  • func NewElemBase() ElemBase
• type Pool

Variables

var (
	// ErrPoolClosed ...
	ErrPoolClosed = errors.New("pool closed")
)

Types

type ChanPool

type ChanPool struct {
	// contains filtered or unexported fields
}

ChanPool ...

func NewChanPool

func NewChanPool(factory func(Pool) (Elem, error),
	maxActive, maxIdle int, heartTime, maxWait time.Duration) (cp *ChanPool)

NewChanPool ...

func (*ChanPool) Close

func (p *ChanPool) Close() error

Close ...

func (*ChanPool) Get

func (p *ChanPool) Get() (elem Elem, err error)

Get ...

func (*ChanPool) IsClosed

func (p *ChanPool) IsClosed() bool

IsClosed ...

func (*ChanPool) Len

func (p *ChanPool) Len() int

Len ...

func (*ChanPool) OutAllBefore

func (p *ChanPool) OutAllBefore(t time.Time)

OutAllBefore ...

func (*ChanPool) Put

func (p *ChanPool) Put(elem Elem) (err error)

Put ...

type Elem

type Elem interface {
	Out() error
	IsAlive() bool
	ElemBase
}

Elem ...

type ElemBase

type ElemBase interface {
	CreatedTime() time.Time
	SetInPool(bool)
	IsInPool() bool
}

ElemBase ...

func NewElemBase

func NewElemBase() ElemBase

NewElemBase ...

type Pool

type Pool interface {
	Get() (elem Elem, err error)
	Put(elem Elem) (err error)
	Len() int
	Close() error
	IsClosed() bool
	OutAllBefore(time.Time)
}

Pool ...