compute

package
v0.6.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 1, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func KahanSumInc 

func KahanSumInc(inc, sum, c float64) (newSum, newC float64)

KahanSumInc implements kahan summation, see https://en.wikipedia.org/wiki/Kahan_summation_algorithm.

func Quantile 

func Quantile(q float64, points []float64) float64

Types

type Accumulator 

type Accumulator interface {
	Add(v float64, h *histogram.FloatHistogram) error
	Value() (float64, *histogram.FloatHistogram)
	ValueType() ValueType
	Warnings() warnings.Warnings
	Reset(float64)
}

Accumulators map prometheus behavior for aggregations, either operators or "[...]_over_time" functions. The caller is responsible to add all errors returned by Add as annotations. The Warnings method returns a bitset of warning conditions that occurred during accumulation (e.g., ignored histograms, mixed types).

func NewQuantileAcc 

func NewQuantileAcc() Accumulator

type AvgAcc 

type AvgAcc struct {
	// contains filtered or unexported fields
}

func NewAvgAcc 

func NewAvgAcc() *AvgAcc

func (*AvgAcc) Add 

func (a *AvgAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*AvgAcc) AddVector 

func (a *AvgAcc) AddVector(vs []float64, hs []*histogram.FloatHistogram) error

func (*AvgAcc) Reset 

func (a *AvgAcc) Reset(_ float64)

func (*AvgAcc) Value 

func (a *AvgAcc) Value() (float64, *histogram.FloatHistogram)

func (*AvgAcc) ValueType 

func (a *AvgAcc) ValueType() ValueType

func (*AvgAcc) Warnings added in v0.5.0 

func (a *AvgAcc) Warnings() warnings.Warnings

type CountAcc 

type CountAcc struct {
	// contains filtered or unexported fields
}

func NewCountAcc 

func NewCountAcc() *CountAcc

func (*CountAcc) Add 

func (c *CountAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*CountAcc) AddVector 

func (c *CountAcc) AddVector(vs []float64, hs []*histogram.FloatHistogram) error

func (*CountAcc) Reset 

func (c *CountAcc) Reset(_ float64)

func (*CountAcc) Value 

func (c *CountAcc) Value() (float64, *histogram.FloatHistogram)

func (*CountAcc) ValueType 

func (c *CountAcc) ValueType() ValueType

func (*CountAcc) Warnings added in v0.5.0 

func (c *CountAcc) Warnings() warnings.Warnings

type CounterResetState added in v0.5.0 

type CounterResetState uint8

CounterResetState tracks which counter reset hints have been seen during aggregation. Used to detect collisions between CounterReset and NotCounterReset hints. 

const (
	SeenCounterReset    CounterResetState = 1 << iota // histogram with CounterReset hint was seen
	SeenNotCounterReset                               // histogram with NotCounterReset hint was seen
)

func (CounterResetState) HasCollision added in v0.5.0 

func (s CounterResetState) HasCollision() bool

HasCollision returns true if both CounterReset and NotCounterReset hints were seen.

type GroupAcc 

type GroupAcc struct {
	// contains filtered or unexported fields
}

func NewGroupAcc 

func NewGroupAcc() *GroupAcc

func (*GroupAcc) Add 

func (c *GroupAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*GroupAcc) AddVector 

func (c *GroupAcc) AddVector(vs []float64, hs []*histogram.FloatHistogram) error

func (*GroupAcc) Reset 

func (c *GroupAcc) Reset(_ float64)

func (*GroupAcc) Value 

func (c *GroupAcc) Value() (float64, *histogram.FloatHistogram)

func (*GroupAcc) ValueType 

func (c *GroupAcc) ValueType() ValueType

func (*GroupAcc) Warnings added in v0.5.0 

func (c *GroupAcc) Warnings() warnings.Warnings

type HistogramAvgAcc 

type HistogramAvgAcc struct {
	// contains filtered or unexported fields
}

func NewHistogramAvgAcc 

func NewHistogramAvgAcc() *HistogramAvgAcc

func (*HistogramAvgAcc) Add 

func (acc *HistogramAvgAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*HistogramAvgAcc) Reset 

func (acc *HistogramAvgAcc) Reset(f float64)

func (*HistogramAvgAcc) Value 

func (acc *HistogramAvgAcc) Value() (float64, *histogram.FloatHistogram)

func (*HistogramAvgAcc) ValueType 

func (acc *HistogramAvgAcc) ValueType() ValueType

func (*HistogramAvgAcc) Warnings added in v0.5.0 

func (acc *HistogramAvgAcc) Warnings() warnings.Warnings

type LastAcc added in v0.5.0 

type LastAcc struct {
	// contains filtered or unexported fields
}

LastAcc tracks the last value seen. Used for last_over_time.

func NewLastAcc added in v0.5.0 

func NewLastAcc() *LastAcc

func (*LastAcc) Add added in v0.5.0 

func (l *LastAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*LastAcc) Reset added in v0.5.0 

func (l *LastAcc) Reset(_ float64)

func (*LastAcc) Value added in v0.5.0 

func (l *LastAcc) Value() (float64, *histogram.FloatHistogram)

func (*LastAcc) ValueType added in v0.5.0 

func (l *LastAcc) ValueType() ValueType

func (*LastAcc) Warnings added in v0.5.0 

func (l *LastAcc) Warnings() warnings.Warnings

type MaxAcc 

type MaxAcc struct {
	// contains filtered or unexported fields
}

func NewMaxAcc 

func NewMaxAcc() *MaxAcc

func (*MaxAcc) Add 

func (c *MaxAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*MaxAcc) AddVector 

func (c *MaxAcc) AddVector(vs []float64, hs []*histogram.FloatHistogram) error

func (*MaxAcc) Reset 

func (c *MaxAcc) Reset(_ float64)

func (*MaxAcc) Value 

func (c *MaxAcc) Value() (float64, *histogram.FloatHistogram)

func (*MaxAcc) ValueType 

func (c *MaxAcc) ValueType() ValueType

func (*MaxAcc) Warnings added in v0.5.0 

func (c *MaxAcc) Warnings() warnings.Warnings

type MinAcc 

type MinAcc struct {
	// contains filtered or unexported fields
}

func NewMinAcc 

func NewMinAcc() *MinAcc

func (*MinAcc) Add 

func (c *MinAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*MinAcc) AddVector 

func (c *MinAcc) AddVector(vs []float64, hs []*histogram.FloatHistogram) error

func (*MinAcc) Reset 

func (c *MinAcc) Reset(_ float64)

func (*MinAcc) Value 

func (c *MinAcc) Value() (float64, *histogram.FloatHistogram)

func (*MinAcc) ValueType 

func (c *MinAcc) ValueType() ValueType

func (*MinAcc) Warnings added in v0.5.0 

func (c *MinAcc) Warnings() warnings.Warnings

type QuantileAcc 

type QuantileAcc struct {
	// contains filtered or unexported fields
}

func (*QuantileAcc) Add 

func (q *QuantileAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*QuantileAcc) Reset 

func (q *QuantileAcc) Reset(f float64)

func (*QuantileAcc) Value 

func (q *QuantileAcc) Value() (float64, *histogram.FloatHistogram)

func (*QuantileAcc) ValueType 

func (q *QuantileAcc) ValueType() ValueType

func (*QuantileAcc) Warnings added in v0.5.0 

func (q *QuantileAcc) Warnings() warnings.Warnings

type StdDevAcc 

type StdDevAcc struct {
	// contains filtered or unexported fields
}

func NewStdDevAcc 

func NewStdDevAcc() *StdDevAcc

func (*StdDevAcc) Add 

func (s *StdDevAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*StdDevAcc) Reset 

func (s *StdDevAcc) Reset(_ float64)

func (*StdDevAcc) Value 

func (s *StdDevAcc) Value() (float64, *histogram.FloatHistogram)

func (*StdDevAcc) ValueType 

func (s *StdDevAcc) ValueType() ValueType

func (*StdDevAcc) Warnings added in v0.5.0 

func (s *StdDevAcc) Warnings() warnings.Warnings

type StdVarAcc 

type StdVarAcc struct {
	// contains filtered or unexported fields
}

func NewStdVarAcc 

func NewStdVarAcc() *StdVarAcc

func (*StdVarAcc) Add 

func (s *StdVarAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*StdVarAcc) Reset 

func (s *StdVarAcc) Reset(_ float64)

func (*StdVarAcc) Value 

func (s *StdVarAcc) Value() (float64, *histogram.FloatHistogram)

func (*StdVarAcc) ValueType 

func (s *StdVarAcc) ValueType() ValueType

func (*StdVarAcc) Warnings added in v0.5.0 

func (s *StdVarAcc) Warnings() warnings.Warnings

type SumAcc 

type SumAcc struct {
	// contains filtered or unexported fields
}

func NewSumAcc 

func NewSumAcc() *SumAcc

func (*SumAcc) Add 

func (s *SumAcc) Add(v float64, h *histogram.FloatHistogram) error

func (*SumAcc) AddVector 

func (s *SumAcc) AddVector(float64s []float64, histograms []*histogram.FloatHistogram) error

func (*SumAcc) Reset 

func (s *SumAcc) Reset(_ float64)

func (*SumAcc) Value 

func (s *SumAcc) Value() (float64, *histogram.FloatHistogram)

func (*SumAcc) ValueType 

func (s *SumAcc) ValueType() ValueType

func (*SumAcc) Warnings added in v0.5.0 

func (s *SumAcc) Warnings() warnings.Warnings

type ValueType 

type ValueType int
const (
	NoValue ValueType = iota
	SingleTypeValue
	MixedTypeValue
)

type VectorAccumulator 

type VectorAccumulator interface {
	AddVector(vs []float64, hs []*histogram.FloatHistogram) error
	Value() (float64, *histogram.FloatHistogram)
	ValueType() ValueType
	Warnings() warnings.Warnings
	Reset(float64)
}

VectorAccumulator is like Accumulator but accepts batches of values.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.