connpool

Documentation

Overview

线程安全且管理高效 未添加连接心跳

Index

• Variables
• type Ipool
  • func NewChannelPool(poolConfig *PoolConfig) (Ipool, error)
• type PoolConfig

Variables

var (
	CLOSEPOOL = errors.New("pool closed")
)

Types

type Ipool

type Ipool interface {
	Get() (interface{}, error) // 获取一个连接
	Put(interface{}) error     // 归还一个连接
	Close(interface{}) error   // 关闭一个连接
	Release()                  // 释放连接池
	Len() int                  // 获取连接池的容量
}

func NewChannelPool

func NewChannelPool(poolConfig *PoolConfig) (Ipool, error)

新建

type PoolConfig

type PoolConfig struct {
	// 连接池中拥有的最小连接数
	MinCap int
	// 连接池中拥有的最大的连接数
	MaxCap int
	// 生成连接的方法
	Factory func() (interface{}, error)
	// 关闭连接的方法
	Close func(interface{}) error
	// 连接最大空闲时间，超时将失效
	IdleTimeout time.Duration
}

配置