pool

Documentation

Overview

Package pool handles the database connection pool.

Index

• type Connect
• type Pool
  • func New(maxSize int, maxAge time.Duration, connect Connect, logger log.Logger, ...) *Pool
  • func (p *Pool) Borrow(ctx context.Context, serverNames []string, wait bool, ...) (db.Connection, error)
  • func (p *Pool) CleanUp()
  • func (p *Pool) Close()
  • func (p *Pool) Return(c db.Connection)
• type PoolClosed
  • func (e *PoolClosed) Error() string
• type PoolFull
  • func (e *PoolFull) Error() string
• type PoolTimeout
  • func (e *PoolTimeout) Error() string

Types

type Connect

type Connect func(string, log.BoltLogger) (db.Connection, error)

type Pool

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

func New

func New(maxSize int, maxAge time.Duration, connect Connect, logger log.Logger, logId string) *Pool

func (*Pool) Borrow

func (p *Pool) Borrow(ctx context.Context, serverNames []string, wait bool, boltLogger log.BoltLogger) (db.Connection, error)

Borrow tries to borrow an existing database connection or tries to create a new one if none exists. The wait flag indicates if the caller wants to wait for a connection to be returned if there aren't any idle connection available.

func (*Pool) CleanUp

func (p *Pool) CleanUp()

Prune all old connection on all the servers, this makes sure that servers gets removed from the map at some point in time. If there is a noticed failed connect still active we should wait a while with removal to get prioritization right.

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) Return

func (p *Pool) Return(c db.Connection)

type PoolClosed

type PoolClosed struct {
}

func (*PoolClosed) Error

func (e *PoolClosed) Error() string

type PoolFull

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

func (*PoolFull) Error

func (e *PoolFull) Error() string

type PoolTimeout

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

func (*PoolTimeout) Error

func (e *PoolTimeout) Error() string