bwlimit

type Conn struct {
	net.Conn // underlying net.Conn
	*Limiter // Limiter to use
}

type DialContextFn func(ctx context.Context, network string, address string) (net.Conn, error)

type Dialer struct {
	DialContextFn // DialContext function we wrap, if nil use net.Dialer.DialContext
	*Limiter      // Limiter to use
}

type Limiter struct {
	Reads  *Operation
	Writes *Operation
}

type Listener struct {
	net.Listener // underlying net.Listener
	*Limiter     // Limiter to use
}

type Operation struct {
	Limit atomic.Int32 // bandwith limit in bytes/sec
	Rate  atomic.Int32 // current rate in bytes/sec
	// contains filtered or unexported fields
}