diskio

Documentation

Index

• type MeteredReader
  • func NewMeteredReader(r io.Reader, cb MeteredReaderCallback) *MeteredReader
  • func (m *MeteredReader) Read(p []byte) (n int, err error)
• type MeteredReaderCallback

Types

type MeteredReader

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

func NewMeteredReader

func NewMeteredReader(r io.Reader, cb MeteredReaderCallback) *MeteredReader

func (*MeteredReader) Read

func (m *MeteredReader) Read(p []byte) (n int, err error)

Read passes the read through to the underlying reader. On a successful read, it will trigger the attached callback and provide it with metrics. If no callback is set, it will ignore it.

type MeteredReaderCallback

type MeteredReaderCallback func(read int64, nanoseconds int64)