Versions in this module Expand all Collapse all v1 v1.1.0 Nov 13, 2022 Changes in this version type Conn + func (that *Conn) AsyncReadFromFdAndWait(wg *sync.WaitGroup) + func (that *Conn) AsyncWriteToFdAndWait(wg *sync.WaitGroup) v1.0.1 Nov 12, 2022 Changes in this version type Conn + ErrChan chan error + func (that *Conn) AsyncClose() + func (that *Conn) AsyncReadFromFd() + func (that *Conn) AsyncWriteToFd() v1.0.0 Nov 11, 2022 Changes in this version + type AsyncWriteConn struct + CallBack iface.AsyncCallback + func (that *AsyncWriteConn) Write(data []byte) (n int, err error) + type AsyncWritevConn struct + CallBack iface.AsyncCallback + func (that *AsyncWritevConn) Write(data []byte) (n int, err error) + type Conn struct + AddrLocal net.Addr + AddrRemote net.Addr + Buffer []byte + Ctx *iface.Context + Fd int + Handler iface.IEventHandler + InBuffer elastic.RingBuffer + IsUDP bool + Opened bool + OutBuffer *elastic.Buffer + Poller *poll.Poller + Sock syscall.Sockaddr + WritevChunkSize int + func NewTCPConn(fd int) (c *Conn) + func (that *Conn) Adapt(adapter iface.ConnAdapter, callback ...iface.AsyncCallback) net.Conn + func (that *Conn) AsyncWrite(data []byte, cb ...iface.AsyncCallback) error + func (that *Conn) AsyncWritev(bs [][]byte, cb ...iface.AsyncCallback) error + func (that *Conn) Close() (rerr error) + func (that *Conn) GetBufferFromPool() []byte + func (that *Conn) GetFd() int + func (that *Conn) InitContext(tconf *tls.Config, adapter iface.ConnAdapter, callback ...iface.AsyncCallback) (err error) + func (that *Conn) LocalAddr() net.Addr + func (that *Conn) Open() error + func (that *Conn) PutBufferToPool(buf []byte) + func (that *Conn) Read(p []byte) (n int, err error) + func (that *Conn) ReadFromFd() error + func (that *Conn) RemoteAddr() net.Addr + func (that *Conn) SetConn(co *ConnOpts) + func (that *Conn) SetDeadline(t time.Time) error + func (that *Conn) SetReadDeadline(t time.Time) error + func (that *Conn) SetWriteDeadline(t time.Time) error + func (that *Conn) Write(p []byte) (int, error) + func (that *Conn) WriteToFd() error + func (that *Conn) Writev(bs [][]byte) (int, error) + type ConnOpts struct + Handler iface.IEventHandler + LocalAddr net.Addr + Poller *poll.Poller + RemoteAddr net.Addr + SockAddr syscall.Sockaddr + SocketReadBuffer int + SocketWriteBuffer int + WriteBufferCap int + WritevChunkSize int + type WritevConn struct + func (that *WritevConn) Write(data []byte) (n int, err error)
Go to main page