loki

package
v0.1.12 Latest Latest
Warning

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

Go to latest
Published: Feb 13, 2024 License: Apache-2.0 Imports: 14 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

This section is empty.

Types

type Config added in v0.1.2

type Config struct {
	URL                *url.URL
	StatusURL          *url.URL
	Timeout            time.Duration
	TenantID           string
	TokenPath          string
	SkipTLS            bool
	CAPath             string
	StatusSkipTLS      bool
	StatusCAPath       string
	StatusUserCertPath string
	StatusUserKeyPath  string

	UseMocks         bool
	ForwardUserToken bool
	Labels           map[string]struct{}
	Deduper          Deduper
}

func NewConfig added in v0.1.2

func NewConfig(url *url.URL, statusURL *url.URL, timeout time.Duration, tenantID string, tokenPath string, forwardUserToken bool, skipTLS bool, capath string, statusSkipTLS bool, statusCapath string, statusUserCertPath string, statusUserKeyPath string, useMocks bool, labels []string, deduperMark bool, deduperMerge bool) Config

func (*Config) IsLabel added in v0.1.2

func (c *Config) IsLabel(key string) bool

type Deduper added in v0.1.12

type Deduper struct {
	Mark  bool
	Merge bool
}

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, start, end, limit string, dedup bool,
	recordType constants.RecordType, packetLoss constants.PacketLoss) *FlowQueryBuilder

func NewFlowQueryBuilderWithDefaults added in v0.1.2

func NewFlowQueryBuilderWithDefaults(cfg *Config) *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 Topology added in v0.1.2

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

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, start, end, limit, rateInterval, step string, metricType constants.MetricType,
	metricFunction constants.MetricFunction, recordType constants.RecordType, packetLoss constants.PacketLoss,
	aggregate, groups string) (*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