pool

Nov 9, 2022

Changes in this version

type ConnNode

+ func (cn *ConnNode) IsBusy() bool

+ func (cn *ConnNode) Wait()

Nov 8, 2022

Changes in this version

+ const DOWN

+ const UP

type Pool

+ func (p *Pool) Read(b []byte) (n int, err error)

Nov 3, 2022

Changes in this version

type ConnNode

+ func (cn *ConnNode) Down() bool

+ func (cn *ConnNode) IsClosed() bool

+ func (cn *ConnNode) IsDown() bool

+ func (cn *ConnNode) Up() bool

Oct 31, 2022

Changes in this version

type PoolNetconn

+ func (p *PoolNetconn) WriteTo(w io.Writer) (n int64, err error)

Oct 24, 2022

Changes in this version

type PoolNetconn

+ func (p *PoolNetconn) ReadFrom(r io.Reader) (n int64, err error)

type PoolWrapper

+ func (p *PoolWrapper) ReadFrom(r io.Reader) (n int64, err error)

Oct 23, 2022

Changes in this version

type ConnNode

+ func (cn *ConnNode) IsAvailable() bool

Oct 23, 2022

Changes in this version

+ const EPOLL_MAX_SIZE

type Pool

+ func (p *Pool) AddConn(cn *ConnNode)

+ func (p *Pool) RemoveConn(cn *ConnNode)

+ func (p *Pool) ReplaceRemote(remote string) error

+ func (p *Pool) SetDialContext(ctx context.Context)

+ func (p *Pool) SetDialer(d *net.Dialer)

+ func (p *Pool) SetMaxConn(max int32)

+ func (p *Pool) SetMinConn(min int32) error

+ func (p *Pool) SetRemote(remote string)

Oct 20, 2022

Changes in this version

type Pool

+ func (p *Pool) Remove(n *ConnNode)

Oct 20, 2022

Changes in this version

+ const ATTEMPT_RECONNECT

+ const EPOLLET

+ const MIN_READABLE_QUEUE_SIZE

+ const MIN_SIZE

+ const RECONNECT_TIMEOUT

+ var NO_AVAILABLE_CONN = errors.New("no available connections!")

+ var POOL_CLOSED = errors.New("pool has been closed")

+ func CreatePool(remote string) (net.Conn, error)

+ func GetSysMax() int32

+ func NetConn(p *Pool) net.Conn

+ func Wrapper(p *Pool) io.ReadWriteCloser

+ type ConnNode struct

+ Conn net.Conn

+ Lock sync.Mutex

+ func (cn *ConnNode) After(n *ConnNode)

+ func (cn *ConnNode) Before(n *ConnNode)

+ func (cn *ConnNode) MoveTo(next *ConnNode, prev *ConnNode)

+ type Opts []interface

+ func (o Opts) Parse() (*net.Dialer, int32, context.Context)

+ func (o Opts) WithContext(c context.Context)

+ func (o Opts) WithDialer(d *net.Dialer)

+ func (o Opts) WithMinSize(m int32)

+ func DefaultOpts() Opts

+ type Pool struct

+ func New(remote string, opts Opts) (*Pool, error)

+ func (p *Pool) Close()

+ func (p *Pool) EpollClose()

+ func (p *Pool) Get() (*ConnNode, error)

+ func (p *Pool) GetReadableConn() (net.Conn, error)

+ func (p *Pool) MoveToHead(cp *ConnNode)

+ func (p *Pool) MoveToTail(cp *ConnNode)

+ func (p *Pool) Push(c net.Conn) *ConnNode

+ func (p *Pool) Put(c *ConnNode)

+ func (p *Pool) Reconnect(cn *ConnNode)

+ func (p *Pool) Remote() string

+ type PoolNetconn struct

+ func (p *PoolNetconn) Close() error

+ func (p *PoolNetconn) LocalAddr() net.Addr

+ func (p *PoolNetconn) Read(b []byte) (n int, err error)

+ func (p *PoolNetconn) RemoteAddr() net.Addr

+ func (p *PoolNetconn) SetDeadline(t time.Time) error

+ func (p *PoolNetconn) SetReadDeadline(t time.Time) error

+ func (p *PoolNetconn) SetWriteDeadline(t time.Time) error

+ func (p *PoolNetconn) Write(b []byte) (n int, err error)

+ type PoolWrapper struct

+ func (p *PoolWrapper) Close() error

+ func (p *PoolWrapper) Read(b []byte) (n int, err error)

+ func (p *PoolWrapper) Write(b []byte) (n int, err error)