rio

Mar 16, 2025

Changes in this version

+ func DialContextTimeout(ctx context.Context, network string, address string, timeout time.Duration) (net.Conn, error)

+ func Presets(_ ...aio.Option) — darwin/amd64, js/wasm, windows/amd64

+ func Presets(options ...aio.Option) — linux/amd64

type Dialer — darwin/amd64, js/wasm, windows/amd64

+ AutoFixedFdInstall bool

+ Control func(network, address string, c syscall.RawConn) error

+ ControlContext func(ctx context.Context, network, address string, c syscall.RawConn) error

+ Deadline time.Time

+ FastOpen bool

+ KeepAlive time.Duration

+ KeepAliveConfig net.KeepAliveConfig

+ LocalAddr net.Addr

+ MultipathTCP bool

+ QuickAck bool

+ SendZC bool

+ Timeout time.Duration

+ func (d *Dialer) Dial(network string, address string) (c net.Conn, err error)

+ func (d *Dialer) DialContext(ctx context.Context, network, address string) (c net.Conn, err error)

+ func (d *Dialer) SetAutoFixedFdInstall(auto bool)

+ func (d *Dialer) SetMultipathTCP(use bool)

+ func (d *Dialer) SetQuickAck(use bool)

+ func (d *Dialer) SetSendZC(use bool)

+ type FixedFd interface

+ FixedFdInstalled func() bool

+ InstallFixedFd func() (err error)

+ func ConvertToFixedFd(v any) (fixed FixedFd, ok bool)

type FixedReaderWriter

+ func ConvertToFixedReaderWriter(c net.Conn) (fixed FixedReaderWriter, ok bool)

+ type ListenConfig struct — darwin/amd64, js/wasm, windows/amd64

+ AutoFixedFdInstall bool

+ Control func(network, address string, c syscall.RawConn) error

+ FastOpen bool

+ KeepAlive time.Duration

+ KeepAliveConfig net.KeepAliveConfig

+ MultipathTCP bool

+ MultishotAccept bool

+ QuickAck bool

+ ReusePort bool

+ SendZC bool

+ func (lc *ListenConfig) Listen(ctx context.Context, network string, address string) (ln net.Listener, err error)

+ func (lc *ListenConfig) ListenIP(_ context.Context, network string, addr *net.IPAddr) (*IPConn, error)

+ func (lc *ListenConfig) ListenPacket(ctx context.Context, network, address string) (c net.PacketConn, err error)

+ func (lc *ListenConfig) SetAutoFixedFdInstall(auto bool)

+ func (lc *ListenConfig) SetFastOpen(use bool)

+ func (lc *ListenConfig) SetMultipathTCP(use bool)

+ func (lc *ListenConfig) SetMultishotAccept(multi bool)

+ func (lc *ListenConfig) SetQuickAck(use bool)

+ func (lc *ListenConfig) SetReusePort(use bool)

+ func (lc *ListenConfig) SetSendZC(use bool)

type TCPConn — linux/amd64

+ func (c *TCPConn) FixedFdInstalled() bool

+ func (c *TCPConn) InstallFixedFd() (err error)

+ func (c *TCPConn) SetReadFromFilePolicy(policy int32)

+ func (c *TCPConn) UseSendZC(use bool) bool

type TCPListener — linux/amd64

+ func (ln *TCPListener) FixedFdInstalled() bool

+ func (ln *TCPListener) InstallFixedFd() error

type UDPConn — linux/amd64

+ func (c *UDPConn) FixedFdInstalled() bool

+ func (c *UDPConn) InstallFixedFd() (err error)

+ func (c *UDPConn) UseSendMSGZC(use bool) bool

+ func (c *UDPConn) UseSendZC(use bool) bool

type UnixConn — linux/amd64

+ func (c *UnixConn) FixedFdInstalled() bool

+ func (c *UnixConn) InstallFixedFd() (err error)

+ func (c *UnixConn) UseSendMSGZC(use bool) bool

+ func (c *UnixConn) UseSendZC(use bool) bool

type UnixListener — linux/amd64

+ func (ln *UnixListener) FixedFdInstalled() bool

+ func (ln *UnixListener) InstallFixedFd() error

Mar 7, 2025

Changes in this version

+ type FixedReaderWriter interface

+ AcquireRegisteredBuffer func() *aio.FixedBuffer

+ ReadFixed func(buf *aio.FixedBuffer) (n int, err error)

+ ReleaseRegisteredBuffer func(buf *aio.FixedBuffer)

+ WriteFixed func(buf *aio.FixedBuffer) (n int, err error)

+ func Fixed(c net.Conn) (fixed FixedReaderWriter, ok bool)

type TCPConn — linux/amd64

+ func (c *TCPConn) AcquireRegisteredBuffer() *aio.FixedBuffer

+ func (c *TCPConn) ReadFixed(buf *aio.FixedBuffer) (n int, err error)

+ func (c *TCPConn) ReleaseRegisteredBuffer(buf *aio.FixedBuffer)

+ func (c *TCPConn) WriteFixed(buf *aio.FixedBuffer) (n int, err error)

type UDPConn — linux/amd64

+ func (c *UDPConn) AcquireRegisteredBuffer() *aio.FixedBuffer

+ func (c *UDPConn) ReadFixed(buf *aio.FixedBuffer) (n int, err error)

+ func (c *UDPConn) ReleaseRegisteredBuffer(buf *aio.FixedBuffer)

+ func (c *UDPConn) WriteFixed(buf *aio.FixedBuffer) (n int, err error)

type UnixConn — linux/amd64

+ func (c *UnixConn) AcquireRegisteredBuffer() *aio.FixedBuffer

+ func (c *UnixConn) ReadFixed(buf *aio.FixedBuffer) (n int, err error)

+ func (c *UnixConn) ReleaseRegisteredBuffer(buf *aio.FixedBuffer)

+ func (c *UnixConn) WriteFixed(buf *aio.FixedBuffer) (n int, err error)

Mar 7, 2025

Changes in this version

+ func PrepareIOURingSetupOptions(_ ...aio.Option) — darwin/amd64, js/wasm, windows/amd64

+ func PrepareIOURingSetupOptions(options ...aio.Option) — linux/amd64

Mar 6, 2025

Changes in this version

type Dialer — linux/amd64

+ func (d *Dialer) SetSendZC(use bool)

Mar 3, 2025

Changes in this version

+ func Pin() error — darwin/amd64, js/wasm, windows/amd64

+ func Unpin() error — darwin/amd64, js/wasm, windows/amd64

+ func UseCPUAffinity(use bool) — darwin/amd64, js/wasm, windows/amd64

+ func UseEntries(entries int) — darwin/amd64, js/wasm, windows/amd64

+ func UseFeatures(feats uint32) — darwin/amd64, js/wasm, windows/amd64

+ func UseFlags(flags uint32) — darwin/amd64, js/wasm, windows/amd64

+ func UseLoadBalancer(lb aio.LoadBalancer)

+ func UsePreformMode() — darwin/amd64, js/wasm, windows/amd64

+ func UsePrepareBatchSize(size uint32) — darwin/amd64, js/wasm, windows/amd64

+ func UseVortexNum(n int)

+ func UseWaitTransmissionBuilder(builder aio.TransmissionBuilder) — darwin/amd64, js/wasm, windows/amd64

Mar 3, 2025

Changes in this version

+ func UseCPUAffinity(use bool) — linux/amd64

Mar 1, 2025

Changes in this version

+ const ReadFromFileUseMMapPolicy — linux/amd64

+ const ReadFromFileUseMixPolicy — linux/amd64

+ var DefaultDialer = Dialer — darwin/amd64, js/wasm, windows/amd64

+ var DefaultDialer = Dialer — linux/amd64

+ func Dial(network string, address string) (net.Conn, error)

+ func DialContext(ctx context.Context, network string, address string) (net.Conn, error)

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

+ func Listen(network string, addr string) (ln net.Listener, err error) — linux/amd64

+ func Listen(network string, addr string) (net.Listener, error) — darwin/amd64, js/wasm, windows/amd64

+ func ListenPacket(network string, addr string) (c net.PacketConn, err error) — linux/amd64

+ func ListenPacket(network string, addr string) (net.PacketConn, error) — darwin/amd64, js/wasm, windows/amd64

+ func Pin() — linux/amd64

+ func PinVortexes() error — darwin/amd64, js/wasm, windows/amd64

+ func Unpin() — linux/amd64

+ func UnpinVortexes() error — darwin/amd64, js/wasm, windows/amd64

+ func UseEntries(entries int) — linux/amd64

+ func UseFeatures(feats uint32) — linux/amd64

+ func UseFlags(flags uint32) — linux/amd64

+ func UsePreformMode() — linux/amd64

+ func UsePrepareBatchSize(size uint32) — linux/amd64

+ func UseProcessPriority(level process.PriorityLevel)

+ func UseReadFromFilePolicy(policy int32) — linux/amd64

+ func UseSides(sides int) — linux/amd64

+ func UseSidesLoadBalancer(lb aio.LoadBalancer) — linux/amd64

+ func UseWaitTransmissionBuilder(builder aio.TransmissionBuilder) — linux/amd64

+ type Dialer struct

+ Control func(network, address string, c syscall.RawConn) error

+ ControlContext func(ctx context.Context, network, address string, c syscall.RawConn) error

+ Deadline time.Time

+ FastOpen bool

+ KeepAlive time.Duration

+ KeepAliveConfig net.KeepAliveConfig

+ MultipathTCP bool

+ QuickAck bool

+ Timeout time.Duration

+ UseSendZC bool

+ func (d *Dialer) Dial(network string, address string) (c net.Conn, err error)

+ func (d *Dialer) DialContext(ctx context.Context, network, address string) (c net.Conn, err error)

+ func (d *Dialer) DialIP(_ context.Context, network string, laddr, raddr *net.IPAddr) (*IPConn, error)

+ func (d *Dialer) DialTCP(ctx context.Context, network string, laddr, raddr *net.TCPAddr) (*TCPConn, error)

+ func (d *Dialer) DialUDP(ctx context.Context, network string, laddr, raddr *net.UDPAddr) (*UDPConn, error)

+ func (d *Dialer) DialUnix(ctx context.Context, network string, laddr, raddr *net.UnixAddr) (*UnixConn, error)

+ func (d *Dialer) SetFastOpen(_ int)

+ func (d *Dialer) SetFastOpen(use bool)

+ func (d *Dialer) SetMultipathTCP(use bool)

+ func (d *Dialer) SetQuickAck(use bool)

+ type IPConn struct

+ func DialIP(network string, laddr, raddr *net.IPAddr) (*IPConn, error)

+ func ListenIP(network string, addr *net.IPAddr) (*IPConn, error)

+ type ListenConfig struct — linux/amd64

+ Control func(network, address string, c syscall.RawConn) error

+ FastOpen bool

+ KeepAlive time.Duration

+ KeepAliveConfig net.KeepAliveConfig

+ MultipathTCP bool

+ QuickAck bool

+ ReusePort bool

+ UseSendZC bool

+ func (lc *ListenConfig) Listen(ctx context.Context, network string, address string) (ln net.Listener, err error)

+ func (lc *ListenConfig) ListenIP(_ context.Context, network string, addr *net.IPAddr) (*IPConn, error)

+ func (lc *ListenConfig) ListenMulticastUDP(ctx context.Context, network string, ifi *net.Interface, addr *net.UDPAddr) (*UDPConn, error)

+ func (lc *ListenConfig) ListenPacket(ctx context.Context, network, address string) (c net.PacketConn, err error)

+ func (lc *ListenConfig) ListenTCP(ctx context.Context, network string, addr *net.TCPAddr) (*TCPListener, error)

+ func (lc *ListenConfig) ListenUDP(ctx context.Context, network string, addr *net.UDPAddr) (*UDPConn, error)

+ func (lc *ListenConfig) ListenUnix(ctx context.Context, network string, addr *net.UnixAddr) (*UnixListener, error)

+ func (lc *ListenConfig) ListenUnixgram(ctx context.Context, network string, addr *net.UnixAddr) (*UnixConn, error)

+ func (lc *ListenConfig) SetFastOpen(use bool)

+ func (lc *ListenConfig) SetMultipathTCP(use bool)

+ func (lc *ListenConfig) SetQuickAck(use bool)

+ func (lc *ListenConfig) SetReusePort(use bool)

+ func (lc *ListenConfig) SetSendZC(use bool)

+ type TCPConn struct — darwin/amd64, js/wasm, windows/amd64

+ func DialTCP(network string, laddr, raddr *net.TCPAddr) (*TCPConn, error)

+ type TCPConn struct — linux/amd64

+ func (c *TCPConn) Close() error

+ func (c *TCPConn) CloseRead() error

+ func (c *TCPConn) CloseWrite() error

+ func (c *TCPConn) Context() context.Context

+ func (c *TCPConn) File() (f *os.File, err error)

+ func (c *TCPConn) LocalAddr() net.Addr

+ func (c *TCPConn) MultipathTCP() (bool, error)

+ func (c *TCPConn) Read(b []byte) (n int, err error)

+ func (c *TCPConn) ReadBuffer() (int, error)

+ func (c *TCPConn) ReadFrom(r io.Reader) (int64, error)

+ func (c *TCPConn) RemoteAddr() net.Addr

+ func (c *TCPConn) SetDeadline(t time.Time) error

+ func (c *TCPConn) SetKeepAlive(keepalive bool) error

+ func (c *TCPConn) SetKeepAliveConfig(config net.KeepAliveConfig) error

+ func (c *TCPConn) SetKeepAlivePeriod(period time.Duration) error

+ func (c *TCPConn) SetLinger(sec int) error

+ func (c *TCPConn) SetNoDelay(noDelay bool) error

+ func (c *TCPConn) SetReadBuffer(bytes int) error

+ func (c *TCPConn) SetReadDeadline(t time.Time) error

+ func (c *TCPConn) SetWriteBuffer(bytes int) error

+ func (c *TCPConn) SetWriteDeadline(t time.Time) error

+ func (c *TCPConn) SyscallConn() (syscall.RawConn, error)

+ func (c *TCPConn) Write(b []byte) (n int, err error)

+ func (c *TCPConn) WriteBuffer() (int, error)

+ func (c *TCPConn) WriteTo(w io.Writer) (int64, error)

+ type TCPListener struct — darwin/amd64, js/wasm, windows/amd64

+ func ListenTCP(network string, addr *net.TCPAddr) (*TCPListener, error)

+ type TCPListener struct — linux/amd64

+ func (ln *TCPListener) Accept() (net.Conn, error)

+ func (ln *TCPListener) AcceptTCP() (tc *TCPConn, err error)

+ func (ln *TCPListener) Addr() net.Addr

+ func (ln *TCPListener) Close() error

+ func (ln *TCPListener) File() (f *os.File, err error)

+ func (ln *TCPListener) SetDeadline(t time.Time) error

+ func (ln *TCPListener) SyscallConn() (syscall.RawConn, error)

+ type UDPConn struct — darwin/amd64, js/wasm, windows/amd64

+ type UDPConn struct — linux/amd64

+ func DialUDP(network string, laddr, raddr *net.UDPAddr) (*UDPConn, error)

+ func ListenMulticastUDP(network string, ifi *net.Interface, addr *net.UDPAddr) (*UDPConn, error)

+ func ListenUDP(network string, addr *net.UDPAddr) (*UDPConn, error)

+ func (c *UDPConn) Close() error

+ func (c *UDPConn) Context() context.Context

+ func (c *UDPConn) File() (f *os.File, err error)

+ func (c *UDPConn) LocalAddr() net.Addr

+ func (c *UDPConn) Read(b []byte) (n int, err error)

+ func (c *UDPConn) ReadBuffer() (int, error)

+ func (c *UDPConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)

+ func (c *UDPConn) ReadFromUDP(b []byte) (n int, addr *net.UDPAddr, err error)

+ func (c *UDPConn) ReadFromUDPAddrPort(b []byte) (n int, addr netip.AddrPort, err error)

+ func (c *UDPConn) ReadMsgUDP(b, oob []byte) (n, oobn, flags int, addr *net.UDPAddr, err error)

+ func (c *UDPConn) ReadMsgUDPAddrPort(b, oob []byte) (n, oobn, flags int, addr netip.AddrPort, err error)

+ func (c *UDPConn) RemoteAddr() net.Addr

+ func (c *UDPConn) SetDeadline(t time.Time) error

+ func (c *UDPConn) SetReadBuffer(bytes int) error

+ func (c *UDPConn) SetReadDeadline(t time.Time) error

+ func (c *UDPConn) SetWriteBuffer(bytes int) error

+ func (c *UDPConn) SetWriteDeadline(t time.Time) error

+ func (c *UDPConn) SyscallConn() (syscall.RawConn, error)

+ func (c *UDPConn) Write(b []byte) (n int, err error)

+ func (c *UDPConn) WriteBuffer() (int, error)

+ func (c *UDPConn) WriteMsgUDP(b, oob []byte, addr *net.UDPAddr) (n, oobn int, err error)

+ func (c *UDPConn) WriteMsgUDPAddrPort(b, oob []byte, addr netip.AddrPort) (n, oobn int, err error)

+ func (c *UDPConn) WriteTo(b []byte, addr net.Addr) (n int, err error)

+ func (c *UDPConn) WriteToUDP(b []byte, addr *net.UDPAddr) (n int, err error)

+ func (c *UDPConn) WriteToUDPAddrPort(b []byte, addr netip.AddrPort) (n int, err error)

+ type UnixConn struct — darwin/amd64, js/wasm, windows/amd64

+ type UnixConn struct — linux/amd64

+ func DialUnix(network string, laddr, raddr *net.UnixAddr) (*UnixConn, error)

+ func ListenUnixgram(network string, addr *net.UnixAddr) (*UnixConn, error)

+ func (c *UnixConn) Close() error

+ func (c *UnixConn) Context() context.Context

+ func (c *UnixConn) File() (f *os.File, err error)

+ func (c *UnixConn) LocalAddr() net.Addr

+ func (c *UnixConn) Read(b []byte) (n int, err error)

+ func (c *UnixConn) ReadBuffer() (int, error)

+ func (c *UnixConn) ReadFrom(b []byte) (int, net.Addr, error)

+ func (c *UnixConn) ReadFromUnix(b []byte) (n int, addr *net.UnixAddr, err error)

+ func (c *UnixConn) ReadMsgUnix(b []byte, oob []byte) (n, oobn, flags int, addr *net.UnixAddr, err error)

+ func (c *UnixConn) RemoteAddr() net.Addr

+ func (c *UnixConn) SetDeadline(t time.Time) error

+ func (c *UnixConn) SetReadBuffer(bytes int) error

+ func (c *UnixConn) SetReadDeadline(t time.Time) error

+ func (c *UnixConn) SetWriteBuffer(bytes int) error

+ func (c *UnixConn) SetWriteDeadline(t time.Time) error

+ func (c *UnixConn) SyscallConn() (syscall.RawConn, error)

+ func (c *UnixConn) Write(b []byte) (n int, err error)

+ func (c *UnixConn) WriteBuffer() (int, error)

+ func (c *UnixConn) WriteMsgUnix(b []byte, oob []byte, addr *net.UnixAddr) (n int, oobn int, err error)

+ func (c *UnixConn) WriteTo(b []byte, addr net.Addr) (int, error)

+ func (c *UnixConn) WriteToUnix(b []byte, addr *net.UnixAddr) (int, error)

+ type UnixListener struct — darwin/amd64, js/wasm, windows/amd64

+ func ListenUnix(network string, addr *net.UnixAddr) (*UnixListener, error)

+ type UnixListener struct — linux/amd64

+ func (ln *UnixListener) Accept() (net.Conn, error)

+ func (ln *UnixListener) AcceptUnix() (c *UnixConn, err error)

+ func (ln *UnixListener) Addr() net.Addr

+ func (ln *UnixListener) Close() error

+ func (ln *UnixListener) File() (f *os.File, err error)

+ func (ln *UnixListener) SetDeadline(t time.Time) error

+ func (ln *UnixListener) SetUnlinkOnClose(unlink bool)

+ func (ln *UnixListener) SyscallConn() (syscall.RawConn, error)