Versions in this module Expand all Collapse all v1 v1.2.2 Oct 26, 2016 Changes in this version + func HumanBytes(bytes float64, si bool) string + func MsgsPerClient(numMsgs, numClients int) []int + type Benchmark struct + Name string + Pubs *SampleGroup + RunID string + Subs *SampleGroup + func NewBenchmark(name string, subCnt, pubCnt int) *Benchmark + func (bm *Benchmark) AddPubSample(s *Sample) + func (bm *Benchmark) AddSubSample(s *Sample) + func (bm *Benchmark) CSV() string + func (bm *Benchmark) Close() + func (bm *Benchmark) Report() string + type Sample struct + End time.Time + IOBytes uint64 + JobMsgCnt int + MsgBytes uint64 + MsgCnt uint64 + Start time.Time + func NewSample(jobCount int, msgSize int, start, end time.Time, nc *nats.Conn) *Sample + func (s *Sample) Duration() time.Duration + func (s *Sample) Rate() int64 + func (s *Sample) Seconds() float64 + func (s *Sample) String() string + func (s *Sample) Throughput() float64 + type SampleGroup struct + Samples []*Sample + func NewSampleGroup() *SampleGroup + func (sg *SampleGroup) AddSample(e *Sample) + func (sg *SampleGroup) AvgRate() int64 + func (sg *SampleGroup) HasSamples() bool + func (sg *SampleGroup) MaxRate() int64 + func (sg *SampleGroup) MinRate() int64 + func (sg *SampleGroup) Statistics() string + func (sg *SampleGroup) StdDev() float64
Go to main page