netstack2

package

Go to main page

Versions in this module

v1

v1.11.0

Apr 3, 2026

Changes in this version

+ type AccessLogger struct

+ func NewAccessLogger(udpTimeout time.Duration) *AccessLogger

+ func (al *AccessLogger) Close()

+ func (al *AccessLogger) EndTCPSession(sessionID string)

+ func (al *AccessLogger) EndUDPSession(sessionID string)

+ func (al *AccessLogger) SetSendFunc(fn SendFunc)

+ func (al *AccessLogger) StartTCPSession(resourceID int, srcAddr, dstAddr string) string

+ func (al *AccessLogger) TrackUDPSession(resourceID int, srcAddr, dstAddr string) string

+ type AccessSession struct

+ BytesRx int64

+ BytesTx int64

+ ConnectionCount int

+ DestAddr string

+ EndedAt time.Time

+ Protocol string

+ ResourceID int

+ SessionID string

+ SourceAddr string

+ StartedAt time.Time

type Net

+ func (net *Net) GetProxySubnetRules() []SubnetRule

+ func (net *Net) SetAccessLogSender(fn SendFunc)

type ProxyHandler

+ func (p *ProxyHandler) GetAccessLogger() *AccessLogger

+ func (p *ProxyHandler) GetAllRules() []SubnetRule

+ func (p *ProxyHandler) LookupResourceId(srcIP, dstIP string, dstPort uint16, proto uint8) int

+ func (p *ProxyHandler) SetAccessLogSender(fn SendFunc)

+ type SendFunc func(data string) error

type SubnetLookup

+ func (sl *SubnetLookup) GetAllRules() []SubnetRule

type SubnetRule

+ ResourceId int

v1.10.3

Mar 12, 2026

v1.10.2

Mar 4, 2026

v1.10.1

Feb 27, 2026

v1.10.0

Feb 23, 2026

v1.9.0

Jan 21, 2026

v1.8.1

Dec 24, 2025

v1.8.0

Dec 23, 2025

Changes in this version

+ type ICMPHandler struct

+ func NewICMPHandler(s *stack.Stack, ph *ProxyHandler) *ICMPHandler

+ func (h *ICMPHandler) InstallICMPHandler() error

+ type Net netTun

+ func CreateNetTUN(localAddresses, dnsServers []netip.Addr, mtu int) (tun.Device, *Net, error)

+ func CreateNetTUNWithOptions(localAddresses, dnsServers []netip.Addr, mtu int, options NetTunOptions) (tun.Device, *Net, error)

+ func (net *Net) AddProxySubnetRule(sourcePrefix, destPrefix netip.Prefix, rewriteTo string, ...)

+ func (net *Net) DialContextTCP(ctx context.Context, addr *net.TCPAddr) (*gonet.TCPConn, error)

+ func (net *Net) DialContextTCPAddrPort(ctx context.Context, addr netip.AddrPort) (*gonet.TCPConn, error)

+ func (net *Net) DialPing(laddr, raddr *PingAddr) (*PingConn, error)

+ func (net *Net) DialPingAddr(laddr, raddr netip.Addr) (*PingConn, error)

+ func (net *Net) DialTCP(addr *net.TCPAddr) (*gonet.TCPConn, error)

+ func (net *Net) DialTCPAddrPort(addr netip.AddrPort) (*gonet.TCPConn, error)

+ func (net *Net) DialUDP(laddr, raddr *net.UDPAddr) (*gonet.UDPConn, error)

+ func (net *Net) DialUDPAddrPort(laddr, raddr netip.AddrPort) (*gonet.UDPConn, error)

+ func (net *Net) GetProxyHandler() *ProxyHandler

+ func (net *Net) ListenPing(laddr *PingAddr) (*PingConn, error)

+ func (net *Net) ListenPingAddr(laddr netip.Addr) (*PingConn, error)

+ func (net *Net) ListenTCP(addr *net.TCPAddr) (*gonet.TCPListener, error)

+ func (net *Net) ListenTCPAddrPort(addr netip.AddrPort) (*gonet.TCPListener, error)

+ func (net *Net) ListenUDP(laddr *net.UDPAddr) (*gonet.UDPConn, error)

+ func (net *Net) ListenUDPAddrPort(laddr netip.AddrPort) (*gonet.UDPConn, error)

+ func (net *Net) LookupHost(host string) (addrs []string, err error)

+ func (net *Net) RemoveProxySubnetRule(sourcePrefix, destPrefix netip.Prefix)

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

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

+ func (tnet *Net) LookupContextHost(ctx context.Context, host string) ([]string, error)

+ type NetTunOptions struct

+ EnableICMPProxy bool

+ EnableTCPProxy bool

+ EnableUDPProxy bool

+ type PingAddr struct

+ func PingAddrFromAddr(addr netip.Addr) *PingAddr

+ func (ia PingAddr) Addr() netip.Addr

+ func (ia PingAddr) Network() string

+ func (ia PingAddr) String() string

+ type PingConn struct

+ func (pc *PingConn) Close() error

+ func (pc *PingConn) LocalAddr() net.Addr

+ func (pc *PingConn) Read(p []byte) (n int, err error)

+ func (pc *PingConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

+ func (pc *PingConn) RemoteAddr() net.Addr

+ func (pc *PingConn) SetDeadline(t time.Time) error

+ func (pc *PingConn) SetReadDeadline(t time.Time) error

+ func (pc *PingConn) SetWriteDeadline(t time.Time) error

+ func (pc *PingConn) Write(p []byte) (n int, err error)

+ func (pc *PingConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

+ type PortRange struct

+ Max uint16

+ Min uint16

+ Protocol string

+ type ProxyHandler struct

+ func NewProxyHandler(options ProxyHandlerOptions) (*ProxyHandler, error)

+ func (p *ProxyHandler) AddSubnetRule(sourcePrefix, destPrefix netip.Prefix, rewriteTo string, ...)

+ func (p *ProxyHandler) Close() error

+ func (p *ProxyHandler) HandleIncomingPacket(packet []byte) bool

+ func (p *ProxyHandler) Initialize(notifiable channel.Notification) error

+ func (p *ProxyHandler) LookupDestinationRewrite(srcIP, dstIP string, dstPort uint16, proto uint8) (netip.Addr, bool)

+ func (p *ProxyHandler) QueueICMPReply(packet []byte) bool

+ func (p *ProxyHandler) ReadOutgoingPacket() *buffer.View

+ func (p *ProxyHandler) RemoveSubnetRule(sourcePrefix, destPrefix netip.Prefix)

+ type ProxyHandlerOptions struct

+ EnableICMP bool

+ EnableTCP bool

+ EnableUDP bool

+ MTU int

+ type SubnetLookup struct

+ func NewSubnetLookup() *SubnetLookup

+ func (sl *SubnetLookup) AddSubnet(sourcePrefix, destPrefix netip.Prefix, rewriteTo string, ...)

+ func (sl *SubnetLookup) Match(srcIP, dstIP netip.Addr, port uint16, proto tcpip.TransportProtocolNumber) *SubnetRule

+ func (sl *SubnetLookup) RemoveSubnet(sourcePrefix, destPrefix netip.Prefix)

+ type SubnetRule struct

+ DestPrefix netip.Prefix

+ DisableIcmp bool

+ PortRanges []PortRange

+ RewriteTo string

+ SourcePrefix netip.Prefix

+ type TCPHandler struct

+ func NewTCPHandler(s *stack.Stack, ph *ProxyHandler) *TCPHandler

+ func (h *TCPHandler) InstallTCPHandler() error

+ type UDPHandler struct

+ func NewUDPHandler(s *stack.Stack, ph *ProxyHandler) *UDPHandler

+ func (h *UDPHandler) InstallUDPHandler() error

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