core

type Barrier[T any] struct {
	// contains filtered or unexported fields
}

type ConnMapper interface {
	Clear() []string
	Track(t ConnTuple, x ...net.Conn) int
	TrackDest(t ConnTuple, x netip.AddrPort) int
	Find(dst string) (t []ConnTuple)
	FindAll(csvips, port string) (t []ConnTuple)
	Get(cid string) []net.Conn
	Untrack(cid string) int
	UntrackBatch(cids []string) []string
}

type ConnTuple struct {
	CID string // conn id
	UID string // proc id
}

type ExpMap struct {
	sync.Mutex // guards ExpMap.
	// contains filtered or unexported fields
}

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

type P2QuantileEstimator interface {
	// Add a sample to the estimator.
	Add(float64)
	// Get the estimation for p.
	Get() int64
	// Get the percentile, p.
	P() float64
}

type PcapHeader struct {
	MagicNumber  uint32
	VersionMajor uint16
	VersionMinor uint16
	Thiszone     int32
	Sigfigs      uint32
	Snaplen      uint32
	Network      uint32
}

type TCPConn interface {
	// RemoteAddr returns the destination network address.
	RemoteAddr() net.Addr

	// LocalAddr returns the local client network address.
	LocalAddr() net.Addr

	// confirms to protect.Conn
	Write(data []byte) (int, error)
	Read(data []byte) (int, error)
	Close() error

	// CloseWrite closes the writing side by sending a FIN
	// segment to local peer. That means we can write no further
	// data to TUN.
	CloseWrite() error

	// CloseRead closes the reading side. That means we can no longer
	// read more from TUN.
	CloseRead() error

	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type UDPConn interface {
	// LocalAddr returns the local client network address.
	LocalAddr() net.Addr
	RemoteAddr() net.Addr

	// confirms to protect.Conn
	Write(data []byte) (int, error)
	Read(data []byte) (int, error)

	// confirms to net.PacketConn
	WriteTo(data []byte, addr net.Addr) (int, error)
	ReadFrom(data []byte) (int, net.Addr, error)

	// Close closes the connection.
	Close() error

	// Implements net.Conn
	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type V[T any] struct {
	Val T
	Err error
	N   atomic.Uint32
	// contains filtered or unexported fields
}

type Volatile[T any] atomic.Value

type Work[T any] func() (T, error)