bench

May 25, 2023

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, cli *client.Client) *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