bwlimit

Nov 29, 2024

Changes in this version

+ type ContextDialer interface

+ DialContext func(ctx context.Context, network, address string) (conn net.Conn, err error)

Nov 20, 2024

Changes in this version

type Limiter

+ func (l *Limiter) Stop()

type Operation

+ func (op *Operation) Stop()

type Ticker

+ var DefaultTicker *Ticker

+ func (ot *Ticker) NewLimiter(limits ...int64) (l *Limiter)

+ func (ot *Ticker) WaitCh() (ch <-chan struct{})

Nov 20, 2024

Changes in this version

type Operation

+ Count atomic.Int64

+ type OperationTicker struct

+ var Ticker *OperationTicker

+ func (ot *OperationTicker) GetOnTick() (fn func())

+ func (ot *OperationTicker) SetOnTick(fn func())

+ func (ot *OperationTicker) TickCh() (ch <-chan struct{})

Nov 19, 2024

Changes in this version

+ var DefaultNetDialer = &net.Dialer

+ type DialFn func(network string, address string) (net.Conn, error)

type Limiter

+ func (l *Limiter) Wrap(fn DialContextFn) DialContextFn

Nov 18, 2024

Changes in this version

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

Nov 18, 2024

Changes in this version

+ type Conn struct

+ func (c *Conn) Read(b []byte) (n int, err error)

+ func (c *Conn) Write(b []byte) (n int, err error)

+ type Dialer struct

+ func (d *Dialer) Dial(network string, address string) (net.Conn, error)

+ func (d *Dialer) DialContext(ctx context.Context, network, address string) (conn net.Conn, err error)

+ type Limiter struct

+ Reads *Operation

+ Writes *Operation

+ func NewLimiter(ctx context.Context) *Limiter

+ type Listener struct

+ func (l *Listener) Accept() (conn net.Conn, err error)

+ type Operation struct

+ Limit atomic.Int32

+ Rate atomic.Int32

+ func NewOperation(ctx context.Context, reader bool) (op *Operation)