netstack2

Jul 2, 2026

Changes in this version

type Net

+ func (net *Net) ReplaceProxySubnetRules(rules []SubnetRule)

type ProxyHandler

+ func (p *ProxyHandler) ReplaceAllSubnetRules(rules []SubnetRule)

type SubnetLookup

+ func (sl *SubnetLookup) ReplaceAll(rules []SubnetRule)

Jun 10, 2026

Changes in this version

type ProxyHandler

+ func (p *ProxyHandler) IsBlocked() bool

+ func (p *ProxyHandler) SetBlocked(v bool)

Apr 28, 2026

Changes in this version

+ type HTTPHandler struct

+ func NewHTTPHandler(s *stack.Stack, ph *ProxyHandler) *HTTPHandler

+ func (h *HTTPHandler) Close() error

+ func (h *HTTPHandler) HandleConn(conn net.Conn, rule *SubnetRule)

+ func (h *HTTPHandler) SetRequestLogger(rl *HTTPRequestLogger)

+ func (h *HTTPHandler) Start() error

+ type HTTPRequestLog struct

+ Host string

+ Method string

+ Path string

+ RawQuery string

+ RequestID string

+ ResourceID int

+ Scheme string

+ SourceAddr string

+ TLS bool

+ Timestamp time.Time

+ UserAgent string

+ type HTTPRequestLogger struct

+ func NewHTTPRequestLogger() *HTTPRequestLogger

+ func (rl *HTTPRequestLogger) Close()

+ func (rl *HTTPRequestLogger) LogRequest(log HTTPRequestLog)

+ func (rl *HTTPRequestLogger) SetSendFunc(fn SendFunc)

+ type HTTPTarget struct

+ DestAddr string

+ DestPort uint16

+ Scheme string

type Net

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

type ProxyHandler

+ func (p *ProxyHandler) GetHTTPRequestLogger() *HTTPRequestLogger

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

type SubnetRule

+ HTTPTargets []HTTPTarget

+ Protocol string

+ TLSCert string

+ TLSKey string

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

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