flowrate

Jul 2, 2018

Changes in this version

+ var ErrLimit = errors.New("flowrate: flow rate limit exceeded")

+ type Limiter interface

+ Done func() int64

+ SetBlocking func(new bool) (old bool)

+ SetLimit func(new int64) (old int64)

+ SetTransferSize func(bytes int64)

+ Status func() Status

+ type Monitor struct

+ func New(sampleRate, windowSize time.Duration) *Monitor

+ func (m *Monitor) Done() int64

+ func (m *Monitor) IO(n int, err error) (int, error)

+ func (m *Monitor) Limit(want int, rate int64, block bool) (n int)

+ func (m *Monitor) SetREMA(rEMA float64)

+ func (m *Monitor) SetTransferSize(bytes int64)

+ func (m *Monitor) Status() Status

+ func (m *Monitor) Update(n int) int

+ type Percent uint32

+ func (p Percent) Float() float64

+ func (p Percent) String() string

+ type Reader struct

+ func NewReader(r io.Reader, limit int64) *Reader

+ func (r *Reader) Close() error

+ func (r *Reader) Read(p []byte) (n int, err error)

+ func (r *Reader) SetBlocking(new bool) (old bool)

+ func (r *Reader) SetLimit(new int64) (old int64)

+ type Status struct

+ Active bool

+ AvgRate int64

+ Bytes int64

+ BytesRem int64

+ CurRate int64

+ Duration time.Duration

+ Idle time.Duration

+ InstRate int64

+ PeakRate int64

+ Progress Percent

+ Samples int64

+ Start time.Time

+ TimeRem time.Duration

+ type Writer struct

+ func NewWriter(w io.Writer, limit int64) *Writer

+ func (w *Writer) Close() error

+ func (w *Writer) SetBlocking(new bool) (old bool)

+ func (w *Writer) SetLimit(new int64) (old int64)

+ func (w *Writer) Write(p []byte) (n int, err error)