netpoll

Jun 12, 2024

Changes in this version

+ const ErrConcurrentAccess

+ type UnsafeLinkBuffer struct

+ func (b *UnsafeLinkBuffer) Append(w Writer) (err error)

+ func (b *UnsafeLinkBuffer) Bytes() []byte

+ func (b *UnsafeLinkBuffer) Close() (err error)

+ func (b *UnsafeLinkBuffer) Flush() (err error)

+ func (b *UnsafeLinkBuffer) GetBytes(p [][]byte) (vs [][]byte)

+ func (b *UnsafeLinkBuffer) IsEmpty() (ok bool)

+ func (b *UnsafeLinkBuffer) Len() int

+ func (b *UnsafeLinkBuffer) Malloc(n int) (buf []byte, err error)

+ func (b *UnsafeLinkBuffer) MallocAck(n int) (err error)

+ func (b *UnsafeLinkBuffer) MallocLen() (length int)

+ func (b *UnsafeLinkBuffer) Next(n int) (p []byte, err error)

+ func (b *UnsafeLinkBuffer) Peek(n int) (p []byte, err error)

+ func (b *UnsafeLinkBuffer) ReadBinary(n int) (p []byte, err error)

+ func (b *UnsafeLinkBuffer) ReadByte() (p byte, err error)

+ func (b *UnsafeLinkBuffer) ReadString(n int) (s string, err error)

+ func (b *UnsafeLinkBuffer) Release() (err error)

+ func (b *UnsafeLinkBuffer) Skip(n int) (err error)

+ func (b *UnsafeLinkBuffer) Slice(n int) (r Reader, err error)

+ func (b *UnsafeLinkBuffer) Until(delim byte) (line []byte, err error)

+ func (b *UnsafeLinkBuffer) WriteBinary(p []byte) (n int, err error)

+ func (b *UnsafeLinkBuffer) WriteBuffer(buf *LinkBuffer) (err error)

+ func (b *UnsafeLinkBuffer) WriteByte(p byte) (err error)

+ func (b *UnsafeLinkBuffer) WriteDirect(extra []byte, remainLen int) error

+ func (b *UnsafeLinkBuffer) WriteString(s string) (n int, err error)

Mar 4, 2024

Changes in this version

+ func Initialize() — darwin/amd64, js/wasm, linux/amd64

+ func SetRunner(f func(ctx context.Context, f func())) — darwin/amd64, js/wasm, linux/amd64

+ type OnDisconnect func(ctx context.Context, connection Connection)

type Option — darwin/amd64, js/wasm, linux/amd64

+ func WithOnDisconnect(onDisconnect OnDisconnect) Option

type TCPConnection — darwin/amd64, js/wasm, linux/amd64

+ func (c *TCPConnection) SetOnDisconnect(onDisconnect OnDisconnect) error

type UnixConnection — darwin/amd64, js/wasm, linux/amd64

+ func (c *UnixConnection) SetOnDisconnect(onDisconnect OnDisconnect) error

Jun 13, 2023

Changes in this version

type TCPConnection — darwin/amd64, js/wasm, linux/amd64

+ func (c *TCPConnection) Detach() error

type UnixConnection — darwin/amd64, js/wasm, linux/amd64

+ func (c *UnixConnection) Detach() error

Dec 20, 2022

Changes in this version

+ func EpollCreate(flag int) (fd int, err error) — linux/amd64

+ func SetLoggerOutput(w io.Writer) — darwin/amd64, js/wasm, linux/amd64

type FDOperator

+ func (op *FDOperator) Free()

type Poll

+ Alloc func() (operator *FDOperator)

+ Free func(operator *FDOperator)

Oct 31, 2022

Changes in this version

+ const ErrWriteTimeout

type Connection

+ SetWriteTimeout func(timeout time.Duration) error

type Option — darwin/amd64, js/wasm, linux/amd64

+ func WithWriteTimeout(timeout time.Duration) Option

type TCPConnection — darwin/amd64, js/wasm, linux/amd64

+ func (c *TCPConnection) SetWriteTimeout(timeout time.Duration) error

type UnixConnection — darwin/amd64, js/wasm, linux/amd64

+ func (c *UnixConnection) SetWriteTimeout(timeout time.Duration) error

Aug 3, 2022

Changes in this version

+ func GetSysFdPairs() (r, w int) — js/wasm

+ type Conn interface — js/wasm, windows/amd64

+ Fd func() (fd int)

+ type EventLoop interface — js/wasm, windows/amd64

+ Serve func(ln net.Listener) error

+ Shutdown func(ctx context.Context) error

+ func NewEventLoop(onRequest OnRequest, ops ...Option) (EventLoop, error)

+ type Listener interface — js/wasm, windows/amd64

+ Fd func() (fd int)

+ func ConvertListener(l net.Listener) (nl Listener, err error)

+ func CreateListener(network, addr string) (l Listener, err error)

+ type OnConnect func(ctx context.Context, connection Connection) context.Context — js/wasm, windows/amd64

+ type OnPrepare func(connection Connection) context.Context — js/wasm, windows/amd64

+ type OnRequest func(ctx context.Context, connection Connection) error — js/wasm, windows/amd64

Jul 13, 2022

Changes in this version

type TCPConnection

+ func (c *TCPConnection) AddCloseCallback(callback CloseCallback) error

+ func (c *TCPConnection) SetOnConnect(onConnect OnConnect) error

+ func (c *TCPConnection) SetOnRequest(onRequest OnRequest) error

type UnixConnection

+ func (c *UnixConnection) AddCloseCallback(callback CloseCallback) error

+ func (c *UnixConnection) SetOnConnect(onConnect OnConnect) error

+ func (c *UnixConnection) SetOnRequest(onRequest OnRequest) error

Feb 22, 2022

Changes in this version

type LinkBuffer

+ func (b *LinkBuffer) Until(delim byte) (line []byte, err error)

+ type OnConnect func(ctx context.Context, connection Connection) context.Context — darwin/amd64, linux/amd64

type Option

+ func WithOnConnect(onConnect OnConnect) Option

type Reader

+ Until func(delim byte) (line []byte, err error)

type TCPConnection

+ func (c *TCPConnection) Until(delim byte) (line []byte, err error)

type UnixConnection

+ func (c *UnixConnection) Until(delim byte) (line []byte, err error)

Sep 16, 2021

Changes in this version

+ func DisableGopool() error

type Listener — darwin/amd64, linux/amd64

+ func ConvertListener(l net.Listener) (nl Listener, err error)

Jul 14, 2021

Changes in this version

+ const EPOLLET — linux/amd64

Jun 23, 2021

Changes in this version

+ const BinaryInplaceThreshold

+ const ErrConnClosed

+ const ErrDialNoDeadline

+ const ErrDialTimeout

+ const ErrEOF

+ const ErrReadTimeout

+ const ErrUnsupported

+ const ErrnoMask

+ const MSG_ZEROCOPY — linux/amd64

+ const SO_ZEROBLOCKTIMEO — linux/amd64

+ const SO_ZEROCOPY — linux/amd64

+ var LinkBufferCap = block4k

+ func EpollCtl(epfd int, op int, fd int, event *epollevent) (err error) — linux/amd64

+ func EpollWait(epfd int, events []epollevent, msec int) (n int, err error) — linux/amd64

+ func Exception(err error, suffix string) error

+ func GetSysFdPairs() (r, w int) — darwin/amd64, linux/amd64

+ func NewIOReadWriter(rw ReadWriter) io.ReadWriter

+ func NewIOReader(r Reader) io.Reader

+ func NewIOWriter(w Writer) io.Writer

+ func SetKeepAlive(fd, secs int) error — darwin/amd64, linux/amd64

+ func SetLoadBalance(lb LoadBalance) error

+ func SetNumLoops(numLoops int) error

+ type CloseCallback func(connection Connection) error

+ type Conn interface — darwin/amd64, linux/amd64

+ Fd func() (fd int)

+ type Connection interface

+ AddCloseCallback func(callback CloseCallback) error

+ IsActive func() bool

+ Reader func() Reader

+ SetIdleTimeout func(timeout time.Duration) error

+ SetOnRequest func(on OnRequest) error

+ SetReadTimeout func(timeout time.Duration) error

+ Writer func() Writer

+ func DialConnection(network, address string, timeout time.Duration) (connection Connection, err error)

+ type Dialer interface

+ DialConnection func(network, address string, timeout time.Duration) (connection Connection, err error)

+ DialTimeout func(network, address string, timeout time.Duration) (conn net.Conn, err error)

+ func NewDialer() Dialer

+ type EventLoop interface — darwin/amd64, linux/amd64

+ Serve func(ln Listener) error

+ Shutdown func(ctx context.Context) error

+ func NewEventLoop(onRequest OnRequest, ops ...Option) (EventLoop, error)

+ type FDOperator struct

+ FD int

+ InputAck func(n int) (err error)

+ Inputs func(vs [][]byte) (rs [][]byte)

+ OnHup func(p Poll) error

+ OnRead func(p Poll) error

+ OnWrite func(p Poll) error

+ OutputAck func(n int) (err error)

+ Outputs func(vs [][]byte) (rs [][]byte, supportZeroCopy bool)

+ func (op *FDOperator) Control(event PollEvent) error

+ type LinkBuffer struct

+ func NewLinkBuffer(size ...int) *LinkBuffer

+ func (b *LinkBuffer) Append(w Writer) (n int, err error)

+ func (b *LinkBuffer) Book(min int, p [][]byte) (vs [][]byte)

+ func (b *LinkBuffer) BookAck(n int, isEnd bool) (err error)

+ func (b *LinkBuffer) Bytes() []byte

+ func (b *LinkBuffer) Close() (err error)

+ func (b *LinkBuffer) Flush() (err error)

+ func (b *LinkBuffer) GetBytes(p [][]byte) (vs [][]byte)

+ func (b *LinkBuffer) IsEmpty() (ok bool)

+ func (b *LinkBuffer) Len() int

+ func (b *LinkBuffer) Malloc(n int) (buf []byte, err error)

+ func (b *LinkBuffer) MallocAck(n int) (err error)

+ func (b *LinkBuffer) MallocLen() (length int)

+ func (b *LinkBuffer) Next(n int) (p []byte, err error)

+ func (b *LinkBuffer) Peek(n int) (p []byte, err error)

+ func (b *LinkBuffer) ReadBinary(n int) (p []byte, err error)

+ func (b *LinkBuffer) ReadByte() (p byte, err error)

+ func (b *LinkBuffer) ReadString(n int) (s string, err error)

+ func (b *LinkBuffer) Release() (err error)

+ func (b *LinkBuffer) Skip(n int) (err error)

+ func (b *LinkBuffer) Slice(n int) (r Reader, err error)

+ func (b *LinkBuffer) WriteBinary(p []byte) (n int, err error)

+ func (b *LinkBuffer) WriteBuffer(buf *LinkBuffer) (n int, err error)

+ func (b *LinkBuffer) WriteByte(p byte) (err error)

+ func (b *LinkBuffer) WriteDirect(p []byte, remainLen int) error

+ func (b *LinkBuffer) WriteString(s string) (n int, err error)

+ type Listener interface — darwin/amd64, linux/amd64

+ Fd func() (fd int)

+ func CreateListener(network, addr string) (l Listener, err error)

+ type LoadBalance int

+ const Random

+ const RoundRobin

+ type OnPrepare func(connection Connection) context.Context — darwin/amd64, linux/amd64

+ type OnRequest func(ctx context.Context, connection Connection) error — darwin/amd64, linux/amd64

+ type Option struct

+ func WithIdleTimeout(timeout time.Duration) Option

+ func WithOnPrepare(onPrepare OnPrepare) Option

+ func WithReadTimeout(timeout time.Duration) Option

+ type Poll interface

+ Close func() error

+ Control func(operator *FDOperator, event PollEvent) error

+ Trigger func() error

+ Wait func() error

+ type PollEvent int

+ const PollDetach

+ const PollModReadable

+ const PollR2RW

+ const PollRW2R

+ const PollReadable

+ const PollWritable

+ type ReadWriter interface

+ func NewReadWriter(rw io.ReadWriter) ReadWriter

+ type Reader interface

+ Len func() (length int)

+ Next func(n int) (p []byte, err error)

+ Peek func(n int) (buf []byte, err error)

+ ReadBinary func(n int) (p []byte, err error)

+ ReadByte func() (b byte, err error)

+ ReadString func(n int) (s string, err error)

+ Release func() (err error)

+ Skip func(n int) (err error)

+ Slice func(n int) (r Reader, err error)

+ func NewReader(r io.Reader) Reader

+ type TCPAddr struct

+ func ResolveTCPAddr(network, address string) (*TCPAddr, error)

+ type TCPConnection struct

+ func DialTCP(ctx context.Context, network string, laddr, raddr *TCPAddr) (*TCPConnection, error)

+ func (c *TCPConnection) Append(w Writer) (n int, err error)

+ func (c *TCPConnection) Close() error

+ func (c *TCPConnection) Flush() error

+ func (c *TCPConnection) IsActive() bool

+ func (c *TCPConnection) Len() (length int)

+ func (c *TCPConnection) Malloc(n int) (buf []byte, err error)

+ func (c *TCPConnection) MallocAck(n int) (err error)

+ func (c *TCPConnection) MallocLen() (length int)

+ func (c *TCPConnection) Next(n int) (p []byte, err error)

+ func (c *TCPConnection) Peek(n int) (buf []byte, err error)

+ func (c *TCPConnection) Read(p []byte) (n int, err error)

+ func (c *TCPConnection) ReadBinary(n int) (p []byte, err error)

+ func (c *TCPConnection) ReadByte() (b byte, err error)

+ func (c *TCPConnection) ReadString(n int) (s string, err error)

+ func (c *TCPConnection) Reader() Reader

+ func (c *TCPConnection) Release() (err error)

+ func (c *TCPConnection) SetIdleTimeout(timeout time.Duration) error

+ func (c *TCPConnection) SetReadTimeout(timeout time.Duration) error

+ func (c *TCPConnection) Skip(n int) (err error)

+ func (c *TCPConnection) Slice(n int) (r Reader, err error)

+ func (c *TCPConnection) Write(p []byte) (n int, err error)

+ func (c *TCPConnection) WriteBinary(b []byte) (n int, err error)

+ func (c *TCPConnection) WriteByte(b byte) (err error)

+ func (c *TCPConnection) WriteDirect(p []byte, remainCap int) (err error)

+ func (c *TCPConnection) WriteString(s string) (n int, err error)

+ func (c *TCPConnection) Writer() Writer

+ type UnixAddr struct

+ func ResolveUnixAddr(network, address string) (*UnixAddr, error)

+ type UnixConnection struct

+ func DialUnix(network string, laddr, raddr *UnixAddr) (*UnixConnection, error)

+ func (c *UnixConnection) Append(w Writer) (n int, err error)

+ func (c *UnixConnection) Close() error

+ func (c *UnixConnection) Flush() error

+ func (c *UnixConnection) IsActive() bool

+ func (c *UnixConnection) Len() (length int)

+ func (c *UnixConnection) Malloc(n int) (buf []byte, err error)

+ func (c *UnixConnection) MallocAck(n int) (err error)

+ func (c *UnixConnection) MallocLen() (length int)

+ func (c *UnixConnection) Next(n int) (p []byte, err error)

+ func (c *UnixConnection) Peek(n int) (buf []byte, err error)

+ func (c *UnixConnection) Read(p []byte) (n int, err error)

+ func (c *UnixConnection) ReadBinary(n int) (p []byte, err error)

+ func (c *UnixConnection) ReadByte() (b byte, err error)

+ func (c *UnixConnection) ReadString(n int) (s string, err error)

+ func (c *UnixConnection) Reader() Reader

+ func (c *UnixConnection) Release() (err error)

+ func (c *UnixConnection) SetIdleTimeout(timeout time.Duration) error

+ func (c *UnixConnection) SetReadTimeout(timeout time.Duration) error

+ func (c *UnixConnection) Skip(n int) (err error)

+ func (c *UnixConnection) Slice(n int) (r Reader, err error)

+ func (c *UnixConnection) Write(p []byte) (n int, err error)

+ func (c *UnixConnection) WriteBinary(b []byte) (n int, err error)

+ func (c *UnixConnection) WriteByte(b byte) (err error)

+ func (c *UnixConnection) WriteDirect(p []byte, remainCap int) (err error)

+ func (c *UnixConnection) WriteString(s string) (n int, err error)

+ func (c *UnixConnection) Writer() Writer

+ type Writer interface

+ Append func(w Writer) (n int, err error)

+ Flush func() (err error)

+ Malloc func(n int) (buf []byte, err error)

+ MallocAck func(n int) (err error)

+ MallocLen func() (length int)

+ WriteBinary func(b []byte) (n int, err error)

+ WriteByte func(b byte) (err error)

+ WriteDirect func(p []byte, remainCap int) error

+ WriteString func(s string) (n int, err error)

+ func NewWriter(w io.Writer) Writer