logqlmetric

type AggregatedLabels interface {
	// By returns new set of labels containing only given list of labels.
	By(...logql.Label) AggregatedLabels
	// Without returns new set of labels without given list of labels.
	Without(...logql.Label) AggregatedLabels
	// Key computes grouping key from set of labels.
	Key() GroupingKey
	// Replace replaces labels using given regexp.
	Replace(dstLabel, replacement, srcLabel string, re *regexp.Regexp) AggregatedLabels

	// AsLokiAPI returns API structure for label set.
	AsLokiAPI() lokiapi.LabelSet
}

type Aggregator interface {
	Reset()
	Apply(v float64)
	Result() float64
}

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

type AvgOverTime = batchApplier[AvgAggregator, *AvgAggregator]

type BatchAggregator interface {
	Aggregate(points []FPoint) float64
}

type BytesRate = Rate[SumOverTime]

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

type CountOverTime struct{}

type EvalParams struct {
	Start, End time.Time
	Step       time.Duration
}

type FPoint struct {
	Timestamp otelstorage.Timestamp
	Value     float64
}

type FirstOverTime struct{}

type GroupingKey = uint64

type LastOverTime struct{}

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

type MaxOverTime = batchApplier[MaxAggregator, *MaxAggregator]

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

type MinOverTime = batchApplier[MinAggregator, *MinAggregator]

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

type Rate[A BatchAggregator] struct {
	// contains filtered or unexported fields
}

type Sample struct {
	Data float64
	Set  AggregatedLabels
}

type SampleOp = func(left, right Sample) (Sample, bool)

type SampleSelector = func(expr *logql.RangeAggregationExpr, start, end time.Time) (iterators.Iterator[SampledEntry], error)

type SampledEntry struct {
	Sample    float64
	Timestamp otelstorage.Timestamp
	Set       AggregatedLabels
}

type Series struct {
	Data []FPoint
	Set  AggregatedLabels
}

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

type StddevOverTime = batchApplier[StddevAggregator, *StddevAggregator]

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

type StdvarOverTime = batchApplier[StdvarAggregator, *StdvarAggregator]

type Step struct {
	Timestamp otelstorage.Timestamp
	Samples   []Sample
}

type StepIterator = iterators.Iterator[Step]

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

type SumOverTime = batchApplier[SumAggregator, *SumAggregator]

type UnsupportedError struct {
	Msg string
}