util

type CongestionManager interface {
	Start()
	Stop()
	Consumed(c ErlClient, t time.Time)
	Served(t time.Time)
	ShouldDrop(c ErlClient) bool
}

type ElasticRateLimiter struct {
	MaxCapacity            int
	CapacityPerReservation int
	// contains filtered or unexported fields
}

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

type ErlClient interface {
	OnClose(func())
}

type IncludeFilter func(name string, info os.FileInfo) bool

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

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

type Set[T comparable] map[T]struct{}

type TCPInfo struct {
	RTT            uint32 `json:",omitempty"` // smoothed RTT
	RTTVar         uint32 `json:",omitempty"` // RTT variance
	RTTMin         uint32 `json:",omitempty"` // smallest observed RTT on the connection
	SndMSS, RcvMSS uint32 `json:",omitempty"` // send and receive maximum segment size
	SndCwnd        uint32 `json:",omitempty"` // sender congestion window
	SndWnd         uint32 `json:",omitempty"` // send window advertised to receiver
	RcvWnd         uint32 `json:",omitempty"` // receive window advertised to sender
	//  tcpi_delivery_rate: The most recent goodput, as measured by
	//    tcp_rate_gen(). If the socket is limited by the sending
	//    application (e.g., no data to send), it reports the highest
	//    measurement instead of the most recent. The unit is bytes per
	//    second (like other rate fields in tcp_info).
	Rate uint64 `json:",omitempty"`
	//  tcpi_delivery_rate_app_limited: A boolean indicating if the goodput
	//    was measured when the socket's throughput was limited by the
	//    sending application.
	AppLimited bool `json:",omitempty"`
}

type WatchdogStreamReader interface {
	Reset() error
	Read(p []byte) (n int, err error)
	Close()
}