loki

package
v1.8.0-community Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package loki provides functionalities for interacting with Loki

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetFunctionWithQuantile

func GetFunctionWithQuantile(metricFunction constants.MetricFunction) (string, string)

func GetLabelsAndFilter

func GetLabelsAndFilter(kl map[string][]string, aggregate, groups string) ([]string, string)

Types

type FlowQueryBuilder added in v0.1.2

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

FlowQueryBuilder stores a state to build a LogQL query

func NewFlowQueryBuilder added in v0.1.2

func NewFlowQueryBuilder(cfg *config.Loki, start, end, limit string, dedup bool,
	recordType constants.RecordType, packetLoss constants.PacketLoss) *FlowQueryBuilder

func NewFlowQueryBuilderWithDefaults added in v0.1.2

func NewFlowQueryBuilderWithDefaults(cfg *config.Loki) *FlowQueryBuilder

func (*FlowQueryBuilder) Build added in v0.1.2

func (q *FlowQueryBuilder) Build() string

func (*FlowQueryBuilder) Filters added in v0.1.2

func (q *FlowQueryBuilder) Filters(queryFilters filters.SingleQuery) error

type MatrixMerger added in v0.1.2

type MatrixMerger struct {
	Merger
	// contains filtered or unexported fields
}

MatrixMerger stores a state to build unique Matrix from multiple ones

func NewMatrixMerger added in v0.1.2

func NewMatrixMerger(reqLimit int) *MatrixMerger

func (*MatrixMerger) Add added in v0.1.3

func (*MatrixMerger) Get added in v0.1.3

type Merger added in v0.1.3

type Merger interface {
	Add(from model.QueryResponseData) (model.ResultValue, error)
	Get() *model.AggregatedQueryResponse
}

type StreamMerger added in v0.1.2

type StreamMerger struct {
	Merger
	// contains filtered or unexported fields
}

func NewStreamMerger added in v0.1.2

func NewStreamMerger(reqLimit int) *StreamMerger

func (*StreamMerger) Add added in v0.1.3

func (*StreamMerger) Get added in v0.1.3

type TopologyInput

type TopologyInput struct {
	Start          string
	End            string
	Top            string
	RateInterval   string
	Step           string
	DataField      string
	MetricFunction constants.MetricFunction
	RecordType     constants.RecordType
	DataSource     constants.DataSource
	PacketLoss     constants.PacketLoss
	Aggregate      string
	Groups         string
	DedupMark      bool
}

type TopologyQueryBuilder added in v0.1.2

type TopologyQueryBuilder struct {
	*FlowQueryBuilder
	// contains filtered or unexported fields
}

func NewTopologyQuery added in v0.1.2

func NewTopologyQuery(cfg *config.Loki, kl map[string][]string, in *TopologyInput) (*TopologyQueryBuilder, error)

func (*TopologyQueryBuilder) Build added in v0.1.2

func (q *TopologyQueryBuilder) Build() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL