counter

Documentation

Index

• type Counter
  • func (c *Counter) Incr(val int64)
  • func (c *Counter) Reset()
• type RateCounter
  • func NewRateCounter(cb func(int64, int64)) *RateCounter
  • func (cc *RateCounter) Run() *RateCounter
• type Reader
  • func NewReader(r io.Reader, c *RateCounter) *Reader
  • func (r *Reader) Read(p []byte) (n int, err error)
• type Writter
  • func NewWritter(w io.WriteCloser, c *RateCounter) *Writter
  • func (w *Writter) Close() error
  • func (w *Writter) Write(p []byte) (n int, err error)

Types

type Counter

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

A Counter is a thread-safe counter implementation

func (*Counter) Incr

func (c *Counter) Incr(val int64)

Incr method increments the counter by some value

func (*Counter) Reset

func (c *Counter) Reset()

Reset -

type RateCounter

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

RateCounter -

func NewRateCounter

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

NewRateCounter -

func (*RateCounter) Run

func (cc *RateCounter) Run() *RateCounter

Run -

type Reader

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

Reader counts the bytes read through it.

func NewReader

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

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

func (*Reader) Read

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

type Writter

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

Writter -

func NewWritter

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

NewWritter -

func (*Writter) Close

func (w *Writter) Close() error

Close -

func (*Writter) Write

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