reporter

package
v0.0.0-...-12b6520 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 15, 2018 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CSVCounter

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

func (*CSVCounter) Close

func (fw *CSVCounter) Close() error

func (*CSVCounter) Write

func (csv *CSVCounter) Write(now int64) error

type CSVHistogram

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

func (*CSVHistogram) Close

func (fw *CSVHistogram) Close() error

func (*CSVHistogram) Write

func (csv *CSVHistogram) Write(now int64) error

type CSVIntGauge

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

func (*CSVIntGauge) Close

func (fw *CSVIntGauge) Close() error

func (*CSVIntGauge) Write

func (csv *CSVIntGauge) Write(now int64) error

type CSVIntGaugeSet

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

func (*CSVIntGaugeSet) Close

func (fw *CSVIntGaugeSet) Close() error

func (*CSVIntGaugeSet) Write

func (csv *CSVIntGaugeSet) Write(now int64) error

type Collector

type Collector interface {
	Name() string
	Collect(context.Context) error
}

type PerRequestReport

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

PerRequestReport that tracks and keeps metrics for each request across the whole load test.

func NewPerRequestReport

func NewPerRequestReport(path string) (*PerRequestReport, error)

func (*PerRequestReport) Finish

func (p *PerRequestReport) Finish()

func (*PerRequestReport) RequestProcessed

func (p *PerRequestReport) RequestProcessed(ts int64, code int, tookInMillis, latency int64, id int)

func (*PerRequestReport) Start

func (p *PerRequestReport) Start()

type ReportOption

type ReportOption func(*Reporter) error

func AddCollector

func AddCollector(c Collector) ReportOption

func MetricToCSV

func MetricToCSV(metric interface{}, path string) ReportOption

type Reporter

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

func New

func New(interval time.Duration, timeout time.Duration, opts ...ReportOption) (*Reporter, error)

func (*Reporter) Finish

func (r *Reporter) Finish()

func (*Reporter) Start

func (r *Reporter) Start()

type Store

type Store interface {
	io.Closer
	Write(now int64) error
}

func CSVStore

func CSVStore(i interface{}, path string) (Store, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL