netstack

type GConnHandler interface {
	TCP() GTCPConnHandler         // TCP returns the TCP handler.
	UDP() GUDPConnHandler         // UDP returns the UDP handler.
	ICMP() GICMPHandler           // ICMP returns the ICMP handler.
	CloseConns(csv string) string // CloseConns closes the connections with the given IDs, or all if empty.
	Close() error                 // Close closes TCP, UDP, ICMP handlers and its resources.
}

type GICMPHandler interface {
	// Multi ping handler
	Ping(source, destination netip.AddrPort, msg []byte, pong Pong) bool
	// Single ping handler
	PingOnce(source, destination netip.AddrPort, msg []byte) bool
	// CloseConns closes all connections
	CloseConns([]string) []string
	// End closes the handler and all its connections
	End() error
}

type GTCPConn struct {
	// contains filtered or unexported fields
}

type GTCPConnHandler interface {
	// Proxy copies data between src and dst.
	Proxy(conn *GTCPConn, src, dst netip.AddrPort) bool
	// CloseConns closes conns by cids, or all conns if cids is empty.
	CloseConns([]string) []string
	// End closes all conns and releases resources.
	End() error
}

type GUDPConn struct {
	// contains filtered or unexported fields
}

type GUDPConnHandler interface {
	// Proxy proxies data between conn (src) and dst.
	Proxy(conn *GUDPConn, src, dst netip.AddrPort) bool
	// ProxyMux proxies data between conn and multiple destinations.
	ProxyMux(conn *GUDPConn, src netip.AddrPort) bool
	// CloseConns closes conns by ids, or all if ids is empty.
	CloseConns([]string) []string
	// End closes the handler and all its connections.
	End() error
}

type Options struct {
	// FDs is a set of FDs used to read/write packets.
	FDs []int

	// MTU is the mtu to use for this endpoint.
	MTU uint32

	// EthernetHeader if true, indicates that the endpoint should read/write
	// ethernet frames instead of IP packets.
	EthernetHeader bool

	// Address is the link address for this endpoint. Only used if
	// EthernetHeader is true.
	Address tcpip.LinkAddress

	// SaveRestore if true, indicates that this NIC capability set should
	// include CapabilitySaveRestore
	SaveRestore bool

	// DisconnectOk if true, indicates that this NIC capability set should
	// include CapabilityDisconnectOk.
	DisconnectOk bool

	// TXChecksumOffload if true, indicates that this endpoints capability
	// set should include CapabilityTXChecksumOffload.
	TXChecksumOffload bool

	// RXChecksumOffload if true, indicates that this endpoints capability
	// set should include CapabilityRXChecksumOffload.
	RXChecksumOffload bool

	// If MaxSyscallHeaderBytes is non-zero, it is the maximum number of bytes
	// of struct iovec, msghdr, and mmsghdr that may be passed by each host
	// system call.
	MaxSyscallHeaderBytes int
}

type Pong func(reply []byte) error

type SeamlessEndpoint interface {
	stack.LinkEndpoint
	Swapper
}

type Swapper interface {
	// Swap closes existing FDs; uses new fd and mtu.
	Swap(fd, mtu int) error
}