Documentation
¶
Overview ¶
Package merger provides interfaces and implementations for aggregating query responses from multiple storage backends (Loki, Prometheus).
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MatrixMerger ¶
type MatrixMerger struct {
// contains filtered or unexported fields
}
MatrixMerger aggregates multiple Matrix results from Loki or Prometheus queries.
func NewMatrixMerger ¶
func NewMatrixMerger(reqLimit int) *MatrixMerger
NewMatrixMerger creates a new MatrixMerger with the given per-query result limit.
func (*MatrixMerger) Add ¶
func (m *MatrixMerger) Add(from model.QueryResponseData) (model.ResultValue, error)
Add merges a new QueryResponseData (Matrix result) into the aggregated result.
func (*MatrixMerger) Get ¶
func (m *MatrixMerger) Get() *model.AggregatedQueryResponse
Get returns the final aggregated AggregatedQueryResponse.
type Merger ¶
type Merger interface {
Add(from model.QueryResponseData) (model.ResultValue, error)
Get() *model.AggregatedQueryResponse
}
Merger aggregates multiple storage query responses into a single result.
Source Files
Click to show internal directories.
Click to hide internal directories.