pool

Documentation

Overview

*

*
* @author liangjf
* @create on 2020/6/8
* @version 1.0

*

*
* @author liangjf
* @create on 2020/6/8
* @version 1.0

*

*
* @author liangjf
* @create on 2020/6/8
* @version 1.0

*

*
* @author liangjf
* @create on 2020/6/8
* @version 1.0

Index

• Variables
• type Builder
• type IPool
  • func NewPool(opts ...Option) (IPool, error)
• type Option
  • func WithBuilder(builder Builder) Option
  • func WithInitCap(initCap int) Option
  • func WithMaxCap(maxCap int) Option
  • func WithMaxIdle(maxIdle int) Option
• type Options

Variables

var (
	ErrPoolParam       = errors.New("param is error")
	ErrPoolBilderNil   = errors.New("builder is nil")
	ErrPoolBuilder     = errors.New("pool builder is error")
	ErrPoolConnIsNil   = errors.New("pool conn is nil")
	ErrPoolBuilderConn = errors.New("pool builder conn error")
	ErrPoolNoIdeConn   = errors.New("pool no ide conn")
)

var (
	ErrNetHadClosed = errors.New("net had closed")
)

Types

type Builder

type Builder func(context.Context) (net.Conn, error)

type IPool

type IPool interface {
	Get() (net.Conn, error)
	Close()
}

IPool 连接池管理接口

func NewPool

func NewPool(opts ...Option) (IPool, error)

type Option

type Option func(*Options)

func WithBuilder

func WithBuilder(builder Builder) Option

func WithInitCap

func WithInitCap(initCap int) Option

func WithMaxCap

func WithMaxCap(maxCap int) Option

func WithMaxIdle

func WithMaxIdle(maxIdle int) Option

type Options

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