counter

package

v0.0.1 Latest Latest Go to latest Published: Dec 7, 2021 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

A Counter is a thread-safe counter implementation

func (c *Counter) Incr(val int64)

Incr method increments the counter by some value

func (c *Counter) Reset()

Reset -

type RateCounter struct {
	Reader   *Counter
	Writer   *Counter
	Callback func(int64, int64)
}

RateCounter -

func NewRateCounter(cb func(int64, int64)) *RateCounter

NewRateCounter -

func (cc *RateCounter) Run() *RateCounter

Run -

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

Reader counts the bytes read through it.

func NewReader(r io.Reader, c *RateCounter) *Reader

NewReader makes a new Reader that counts the bytes read through it.

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

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

Writter -

func NewWritter(w io.WriteCloser, c *RateCounter) *Writter

NewWritter -

func (w *Writter) Close() error

Close -

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