hybrid

package module

Go to main page

Versions in this module

v0

v0.1.1

Oct 27, 2026

Changes in this version

type SplitConfig

+ ErrorFunc func(error)

type SplitStats

+ NoSource uint64

v0.1.0

Oct 27, 2026

Changes in this version

+ const DefaultSplitAcceptQueueSize

+ const DefaultSplitFallbackQueueSize

+ const DefaultSplitIdleTimeout

+ const DefaultSplitMaxFlows

+ const DefaultSplitReadBufferSize

+ const DefaultSplitReadQueueSize

+ const DefaultSplitWriteQueueSize

+ const DefaultSplitWriteTimeout

+ func BufferedPipe(queueSize int) (StreamConn, StreamConn)

+ func BufferedTrunk(queueSize int, addr1, addr2 net.Addr) (FromToPacketConn, FromToPacketConn)

+ func ControlUDPPacketInfo(network, _ string, c syscall.RawConn) error

+ func NeedPacketInfoUDPConn(conn UDPConn) bool

+ func UnbufferedPipe(semiSync bool) (StreamConn, StreamConn)

+ func UnbufferedTrunk(addr1, addr2 net.Addr) (FromToPacketConn, FromToPacketConn)

+ type Conn interface

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

+ RemoteAddr func() net.Addr

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

+ type Deadline interface

+ Set func(t time.Time)

+ Wait func() <-chan struct{}

+ func HookDeadline(hook func()) Deadline

+ func SimpleDeadline() Deadline

+ type FromToPacketConn interface

+ func PacketToFromToPacketConn(pc PacketConn, tryPacketInfoUDP bool) FromToPacketConn

+ type FromToReader interface

+ ReadFromTo func(p []byte) (n int, src, dst net.Addr, idx int, err error)

+ type FromToUDPConn interface

+ ReadFromToUDP func(b []byte) (n int, src *net.UDPAddr, dst *net.UDPAddr, idx int, err error)

+ ReadFromToUDPAddrPort func(b []byte) (n int, src netip.AddrPort, dst netip.AddrPort, idx int, err error)

+ WriteToFromUDP func(b []byte, dst, src *net.UDPAddr, idx int) (n int, err error)

+ WriteToFromUDPAddrPort func(b []byte, dst, src netip.AddrPort, idx int) (n int, err error)

+ func PacketInfoUDPConn(conn UDPConn) (FromToUDPConn, error)

+ type FromToWriter interface

+ WriteToFrom func(p []byte, dst, src net.Addr, idx int) (n int, err error)

+ type PacketConn = net.PacketConn

+ type PacketListener = net.Listener

+ type PacketOverStreamConn interface

+ func StreamToPacketConn(sc StreamConn) PacketOverStreamConn

+ type SplitConfig struct

+ AcceptQueueSize int

+ FallbackConn bool

+ FallbackQueueSize int

+ IdleTimeout time.Duration

+ MaxFlows int

+ PacketInfo bool

+ ReadBufferSize int

+ ReadQueueSize int

+ WriteQueueSize int

+ WriteTimeout time.Duration

+ type SplitConn interface

+ Release func(pkts ...[]byte) error

+ type SplitListener interface

+ AcceptSplit func() (SplitConn, error)

+ Fallback func() FromToPacketConn

+ Stats func() SplitStats

+ func Split(pc PacketConn, config *SplitConfig) SplitListener

+ type SplitStats struct

+ AcceptQueueFull uint64

+ ConnClosed uint64

+ ConnQueueFull uint64

+ FallbackClosed uint64

+ FallbackQueueFull uint64

+ NoDestination uint64

+ NoFallback uint64

+ TableFull uint64

+ Truncated uint64

+ WriteFailed uint64

+ WriteTimedOut uint64

+ WriteUnsent uint64

+ type StoppablePacketConn interface

+ func IdleTimeoutPacketConn(pc PacketConn, timeout time.Duration) StoppablePacketConn

+ type StoppableStreamConn interface

+ func IdleTimeoutStreamConn(sc StreamConn, timeout time.Duration) StoppableStreamConn

+ type Stopper interface

+ Stop func() error

+ type StreamConn = net.Conn

+ type StreamListener = net.Listener

+ type StreamOverPacketConn interface

+ func PacketToStreamConn(pc PacketConn, remote net.Addr, filter bool) StreamOverPacketConn

+ type UDPConn interface

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

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

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

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

+ SyscallConn func() (syscall.RawConn, error)

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

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

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

+ WriteToUDPAddrPort func(b []byte, addr netip.AddrPort) (int, error)

+ type Wrapper interface

+ Unwrap func() T

+ type WrappingPacketConn interface

+ func FakeAddressPacketConn(pc PacketConn, local, remote net.Addr) WrappingPacketConn

+ func FakeClosePacketConn(pc PacketConn, closeFunc func() error) WrappingPacketConn

+ type WrappingStreamConn interface

+ func FakeAddressStreamConn(sc StreamConn, local, remote net.Addr) WrappingStreamConn

+ func FakeCloseStreamConn(sc StreamConn, closeFunc func() error) WrappingStreamConn

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL