Documentation ¶
Index ¶
- type LossStats
- type PerfLog
- type PerfLogs
- type ResourceMetrics
- type Sample
- type Statistics
- func (stats *Statistics) GenericMean(f func(l *PerfLog) float64) float64
- func (stats *Statistics) Max() float64
- func (stats *Statistics) Mean() float64
- func (stats *Statistics) MeanBloat() float64
- func (stats *Statistics) Median() float64
- func (stats *Statistics) Min() float64
- func (stats *Statistics) TotMessages() int
- type StreamLossStats
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LossStats ¶
type LossStats struct {
// contains filtered or unexported fields
}
func NewLossStats ¶
func (*LossStats) LossStatsFor ¶
func (l *LossStats) LossStatsFor(stream string) (*StreamLossStats, error)
type PerfLog ¶
type PerfLog struct { Stream string types.Timing SequenceId int // contains filtered or unexported fields }
func NewPerfLog ¶
NewPerfLog creates a PerfLog from a line parsing it or returning nil if there is an error
func (*PerfLog) ElapsedEpoc ¶
type ResourceMetrics ¶
type ResourceMetrics struct {
Samples []Sample
}
func NewResourceMetrics ¶
func NewResourceMetrics() *ResourceMetrics
func (*ResourceMetrics) AddSample ¶
func (rm *ResourceMetrics) AddSample(sample *Sample)
type Statistics ¶
type Statistics struct { Logs PerfLogs MsgSize int TimeDiffs []float64 Elapsed time.Duration Losses LossStats }
func NewStatisics ¶
func NewStatisics(logs PerfLogs, msgSize int, elapsed time.Duration) *Statistics
func (*Statistics) GenericMean ¶
func (stats *Statistics) GenericMean(f func(l *PerfLog) float64) float64
func (*Statistics) Max ¶
func (stats *Statistics) Max() float64
func (*Statistics) Mean ¶
func (stats *Statistics) Mean() float64
func (*Statistics) MeanBloat ¶
func (stats *Statistics) MeanBloat() float64
func (*Statistics) Median ¶
func (stats *Statistics) Median() float64
func (*Statistics) Min ¶
func (stats *Statistics) Min() float64
func (*Statistics) TotMessages ¶
func (stats *Statistics) TotMessages() int
type StreamLossStats ¶
type StreamLossStats struct { MinSeqId int MaxSeqId int Collected int Purged int Entries []PerfLog }
func (*StreamLossStats) PercentCollected ¶
func (l *StreamLossStats) PercentCollected() float64
func (*StreamLossStats) Range ¶
func (s *StreamLossStats) Range() int
Range is difference between the first and last collected sequence ids
Click to show internal directories.
Click to hide internal directories.