Documentation ¶
Index ¶
- type Counter
- func (c *Counter) Annotation() []byte
- func (c *Counter) Close()
- func (c *Counter) Count() int64
- func (c *Counter) LastAt() time.Time
- func (c *Counter) Max() int64
- func (c *Counter) Mean() float64
- func (c *Counter) Min() int64
- func (c *Counter) Stdev() float64
- func (c *Counter) Sum() int64
- func (c *Counter) SumSq() int64
- func (c *Counter) Update(timestamp time.Time, value int64, annotation []byte)
- func (c *Counter) ValueOf(aggType aggregation.Type) float64
- type CounterMetrics
- type Gauge
- func (g *Gauge) Annotation() []byte
- func (g *Gauge) Close()
- func (g *Gauge) Count() int64
- func (g *Gauge) Last() float64
- func (g *Gauge) LastAt() time.Time
- func (g *Gauge) Max() float64
- func (g *Gauge) Mean() float64
- func (g *Gauge) Min() float64
- func (g *Gauge) Stdev() float64
- func (g *Gauge) Sum() float64
- func (g *Gauge) SumSq() float64
- func (g *Gauge) Update(timestamp time.Time, value float64, annotation []byte)
- func (g *Gauge) UpdatePrevious(timestamp time.Time, value float64, prevValue float64)
- func (g *Gauge) ValueOf(aggType aggregation.Type) float64
- type GaugeMetrics
- type Metrics
- type Options
- type Timer
- func (t *Timer) Add(timestamp time.Time, value float64, annotation []byte)
- func (t *Timer) AddBatch(timestamp time.Time, values []float64, annotation []byte)
- func (t *Timer) Annotation() []byte
- func (t *Timer) Close()
- func (t *Timer) Count() int64
- func (t *Timer) LastAt() time.Time
- func (t *Timer) Max() float64
- func (t *Timer) Mean() float64
- func (t *Timer) Min() float64
- func (t *Timer) Quantile(q float64) float64
- func (t *Timer) Stdev() float64
- func (t *Timer) Sum() float64
- func (t *Timer) SumSq() float64
- func (t *Timer) ValueOf(aggType aggregation.Type) float64
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Counter ¶
type Counter struct { Options // contains filtered or unexported fields }
Counter aggregates counter values.
func (*Counter) Annotation ¶ added in v1.2.0
Annotation returns the annotation associated with the counter.
type CounterMetrics ¶ added in v0.15.0
type CounterMetrics struct {
// contains filtered or unexported fields
}
CounterMetrics is a set of counter metrics can be used by all counters.
func (CounterMetrics) IncValuesOutOfOrder ¶ added in v0.15.0
func (m CounterMetrics) IncValuesOutOfOrder()
IncValuesOutOfOrder increments value or if not initialized is a no-op.
type Gauge ¶
type Gauge struct { Options // contains filtered or unexported fields }
Gauge aggregates gauge values.
func (*Gauge) Annotation ¶ added in v1.2.0
Annotation returns the annotation associated with the gauge.
func (*Gauge) UpdatePrevious ¶ added in v1.2.0
UpdatePrevious removes the prevValue from the aggregation and updates with the new value. This does not update min/max since it's not possible to recalculate those.
type GaugeMetrics ¶ added in v0.15.0
type GaugeMetrics struct {
// contains filtered or unexported fields
}
GaugeMetrics is a set of gauge metrics can be used by all gauges.
func (GaugeMetrics) IncValuesOutOfOrder ¶ added in v0.15.0
func (m GaugeMetrics) IncValuesOutOfOrder()
IncValuesOutOfOrder increments value or if not initialized is a no-op.
type Metrics ¶ added in v0.15.0
type Metrics struct { Counter CounterMetrics Gauge GaugeMetrics }
Metrics is a set of metrics that can be used by elements.
func NewMetrics ¶ added in v0.15.0
NewMetrics is a set of aggregation metrics.
type Options ¶
type Options struct { // Metrics is as set of aggregation metrics. Metrics Metrics // HasExpensiveAggregations means expensive (multiplication/division) // aggregation types are enabled. HasExpensiveAggregations bool }
Options is the options for aggregations.
func NewOptions ¶
func NewOptions(instrumentOpts instrument.Options) Options
NewOptions creates a new aggregation options.
func (*Options) ResetSetData ¶
func (o *Options) ResetSetData(aggTypes aggregation.Types)
ResetSetData resets the aggregation options.
type Timer ¶
type Timer struct {
// contains filtered or unexported fields
}
Timer aggregates timer values. Timer APIs are not thread-safe.
func (*Timer) Annotation ¶ added in v1.2.0
Annotation returns the annotation associated with the timer.
Directories ¶
Path | Synopsis |
---|---|
quantile
|
|
cm
Package cm implements the Cormode-Muthukrishnan algorithm for computing biased quantiles over data streams from "Effective Computation of Biased Quantiles over Data Streams" and is largely based on statsite's implementation in C: https://github.com/statsite/statsite/blob/master/src/cm_quantile.c
|
Package cm implements the Cormode-Muthukrishnan algorithm for computing biased quantiles over data streams from "Effective Computation of Biased Quantiles over Data Streams" and is largely based on statsite's implementation in C: https://github.com/statsite/statsite/blob/master/src/cm_quantile.c |