README
¶
Rpool 💍
Go connection pool implemented by circular linked list(in go we call it ring💍)
Basically it makes all connections in pool work simultaneously and it can be used to manage and reuse connections.
Documentation
¶
Index ¶
- Variables
- type Client
- type Connection
- func (conn *Connection) ClearSession()
- func (conn *Connection) Close() error
- func (conn *Connection) GetClient() interface{}
- func (conn *Connection) GetCreateTime() time.Time
- func (conn *Connection) GetPool() RPool
- func (conn *Connection) GetSession() interface{}
- func (conn *Connection) GetUsage() int64
- func (conn *Connection) GetVersion() int64
- func (conn *Connection) HandleClose(_close func() error)
- func (conn *Connection) HandleIsClosed(isClosed func() bool)
- func (conn *Connection) HandleReset(reset func() error)
- func (conn *Connection) IncrUsage()
- func (conn *Connection) IsClosed() bool
- func (conn *Connection) Reset() error
- func (conn *Connection) SetSession(session interface{})
- type Pool
- func (pool *Pool) Acquire() (conn RConnection, err error)
- func (pool *Pool) Capacity() int
- func (pool *Pool) GetDescription() string
- func (pool *Pool) GetDomain() string
- func (pool *Pool) GetPayload() interface{}
- func (pool *Pool) GetVersion() int64
- func (pool *Pool) IncrVersion()
- func (pool *Pool) Len() int
- func (pool *Pool) Release(conn RConnection)
- func (pool *Pool) SetCapacity(limit int)
- func (pool *Pool) SetConnExpire(expire time.Duration)
- func (pool *Pool) SetConnMaxUsage(usage int64)
- func (pool *Pool) SetDescription(description string)
- func (pool *Pool) SetDropConnThreshold(threshold float64)
- func (pool *Pool) SetPayload(payload interface{})
- type RConnection
- type RPool
- type Ring
- type Statistics
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrExceedMaxPoolLimit = errors.New("exceed max pool limit")
)
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(pool RPool, client interface{}, version int64) *Connection
func (*Connection) ClearSession ¶
func (conn *Connection) ClearSession()
func (*Connection) Close ¶
func (conn *Connection) Close() error
func (*Connection) GetClient ¶
func (conn *Connection) GetClient() interface{}
func (*Connection) GetCreateTime ¶
func (conn *Connection) GetCreateTime() time.Time
func (*Connection) GetPool ¶
func (conn *Connection) GetPool() RPool
func (*Connection) GetSession ¶
func (conn *Connection) GetSession() interface{}
func (*Connection) GetUsage ¶
func (conn *Connection) GetUsage() int64
func (*Connection) GetVersion ¶
func (conn *Connection) GetVersion() int64
func (*Connection) HandleClose ¶
func (conn *Connection) HandleClose(_close func() error)
func (*Connection) HandleIsClosed ¶
func (conn *Connection) HandleIsClosed(isClosed func() bool)
func (*Connection) HandleReset ¶
func (conn *Connection) HandleReset(reset func() error)
func (*Connection) IncrUsage ¶
func (conn *Connection) IncrUsage()
func (*Connection) IsClosed ¶
func (conn *Connection) IsClosed() bool
func (*Connection) Reset ¶
func (conn *Connection) Reset() error
func (*Connection) SetSession ¶
func (conn *Connection) SetSession(session interface{})
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
func (*Pool) Acquire ¶
func (pool *Pool) Acquire() (conn RConnection, err error)
func (*Pool) GetDescription ¶
func (*Pool) GetPayload ¶
func (pool *Pool) GetPayload() interface{}
func (*Pool) GetVersion ¶
func (*Pool) IncrVersion ¶
func (pool *Pool) IncrVersion()
func (*Pool) Release ¶
func (pool *Pool) Release(conn RConnection)
func (*Pool) SetCapacity ¶
func (*Pool) SetConnExpire ¶
func (*Pool) SetConnMaxUsage ¶
func (*Pool) SetDescription ¶
func (*Pool) SetDropConnThreshold ¶
func (*Pool) SetPayload ¶
func (pool *Pool) SetPayload(payload interface{})
type RConnection ¶
type RConnection interface {
GetUsage() int64
GetPool() RPool
GetVersion() int64
GetClient() interface{}
SetSession(interface{})
GetSession() interface{}
GetCreateTime() time.Time
IncrUsage()
Close() error
Reset() error
IsClosed() bool
HandleClose(func() error)
HandleReset(func() error)
HandleIsClosed(func() bool)
}
type RPool ¶
type RPool interface {
GetDomain() string
Acquire() (RConnection, error)
Release(RConnection)
GetPayload() interface{}
SetPayload(interface{})
GetDescription() string
SetDescription(string)
GetVersion() int64
IncrVersion()
SetConnExpire(time.Duration)
SetConnMaxUsage(int64)
SetDropConnThreshold(float64)
Len() int
Capacity() int
SetCapacity(int)
}
type Ring ¶
func (*Ring) Pop ¶
func (r *Ring) Pop() (conn RConnection)
func (*Ring) Push ¶
func (r *Ring) Push(conn RConnection)
type Statistics ¶
Source Files
Click to show internal directories.
Click to hide internal directories.