Versions in this module Expand all Collapse all v0 v0.0.4 Sep 14, 2020 Changes in this version + const PtrSize + type AtomicBucketWrapArray struct + func NewAtomicBucketWrapArray(len int, bucketLengthInMs uint32, generator BucketGenerator) *AtomicBucketWrapArray + func NewAtomicBucketWrapArrayWithTime(len int, bucketLengthInMs uint32, now uint64, generator BucketGenerator) *AtomicBucketWrapArray + type BucketGenerator interface + NewEmptyBucket func() interface{} + ResetBucketTo func(bw *BucketWrap, startTime uint64) *BucketWrap + type BucketLeapArray struct + func NewBucketLeapArray(sampleCount uint32, intervalInMs uint32) *BucketLeapArray + func (bla *BucketLeapArray) AddCount(event base.MetricEvent, count int64) + func (bla *BucketLeapArray) BucketLengthInMs() uint32 + func (bla *BucketLeapArray) Count(event base.MetricEvent) int64 + func (bla *BucketLeapArray) CountWithTime(now uint64, event base.MetricEvent) int64 + func (bla *BucketLeapArray) DataType() string + func (bla *BucketLeapArray) GetIntervalInSecond() float64 + func (bla *BucketLeapArray) IntervalInMs() uint32 + func (bla *BucketLeapArray) MinRt() int64 + func (bla *BucketLeapArray) NewEmptyBucket() interface{} + func (bla *BucketLeapArray) ResetBucketTo(bw *BucketWrap, startTime uint64) *BucketWrap + func (bla *BucketLeapArray) SampleCount() uint32 + func (bla *BucketLeapArray) Values(now uint64) []*BucketWrap + func (bla *BucketLeapArray) ValuesConditional(now uint64, predicate base.TimePredicate) []*BucketWrap + type BucketWrap struct + BucketStart uint64 + Value atomic.Value + type LeapArray struct + func NewLeapArray(sampleCount uint32, intervalInMs uint32, generator BucketGenerator) (*LeapArray, error) + func (la *LeapArray) CurrentBucket(bg BucketGenerator) (*BucketWrap, error) + func (la *LeapArray) Values() []*BucketWrap + func (la *LeapArray) ValuesConditional(now uint64, predicate base.TimePredicate) []*BucketWrap + type MetricBucket struct + func NewMetricBucket() *MetricBucket + func (mb *MetricBucket) Add(event base.MetricEvent, count int64) + func (mb *MetricBucket) AddRt(rt int64) + func (mb *MetricBucket) Get(event base.MetricEvent) int64 + func (mb *MetricBucket) MinRt() int64 + type SlidingWindowMetric struct + func NewSlidingWindowMetric(sampleCount, intervalInMs uint32, real *BucketLeapArray) *SlidingWindowMetric + func (m *SlidingWindowMetric) AvgRT() float64 + func (m *SlidingWindowMetric) GetMaxOfSingleBucket(event base.MetricEvent) int64 + func (m *SlidingWindowMetric) GetPreviousQPS(event base.MetricEvent) float64 + func (m *SlidingWindowMetric) GetQPS(event base.MetricEvent) float64 + func (m *SlidingWindowMetric) GetSum(event base.MetricEvent) int64 + func (m *SlidingWindowMetric) MinRT() float64 + func (m *SlidingWindowMetric) SecondMetricsOnCondition(predicate base.TimePredicate) []*base.MetricItem
Go to main page