statistics

Documentation

Index

• Constants
• func NewBandwidthStatistics(output *os.File) *bandwidth
• func WithStatistics(rwc io.ReadWriteCloser, output *os.File) io.ReadWriteCloser
• type BandwidthIO
  • func (b *BandwidthIO) Close() error
  • func (b *BandwidthIO) Read(p []byte) (n int, err error)
  • func (b *BandwidthIO) Write(p []byte) (n int, err error)
• type CompressWrap
  • func NewCompressWrap(c compression.Compressor, output *os.File) *CompressWrap
  • func (cw *CompressWrap) Compress(s []byte) (d []byte)
• type LatencyStatistics
  • func NewLatencyStatistics(output *os.File) *LatencyStatistics
  • func (ls *LatencyStatistics) AddLatency(latency time.Duration)
  • func (ls *LatencyStatistics) CalcAndPrintLatency()
  • func (ls *LatencyStatistics) SetOutputFile(file *os.File)

Constants

const (
	UNO  = 1
	KILO = 1000
	MEGA = 1000 * 1000
	GIGA = 1000 * 1000 * 1000
	TERA = 1000 * 1000 * 1000 * 1000
)

Functions

func NewBandwidthStatistics

func NewBandwidthStatistics(output *os.File) *bandwidth

func WithStatistics

func WithStatistics(rwc io.ReadWriteCloser, output *os.File) io.ReadWriteCloser

Types

type BandwidthIO

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

func (*BandwidthIO) Close

func (b *BandwidthIO) Close() error

func (*BandwidthIO) Read

func (b *BandwidthIO) Read(p []byte) (n int, err error)

func (*BandwidthIO) Write

func (b *BandwidthIO) Write(p []byte) (n int, err error)

type CompressWrap

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

func NewCompressWrap

func NewCompressWrap(c compression.Compressor, output *os.File) *CompressWrap

func (*CompressWrap) Compress

func (cw *CompressWrap) Compress(s []byte) (d []byte)

type LatencyStatistics

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

func NewLatencyStatistics

func NewLatencyStatistics(output *os.File) *LatencyStatistics

func (*LatencyStatistics) AddLatency

func (ls *LatencyStatistics) AddLatency(latency time.Duration)

func (*LatencyStatistics) CalcAndPrintLatency

func (ls *LatencyStatistics) CalcAndPrintLatency()

func (*LatencyStatistics) SetOutputFile

func (ls *LatencyStatistics) SetOutputFile(file *os.File)