loki

package
v0.1.4-rc0 Latest Latest
Warning

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

Go to latest
Published: Aug 2, 2022 License: Apache-2.0 Imports: 12 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
	Timeout        time.Duration
	TenantID       string
	SkipTLS        bool
	CAPath         string
	UseMocks       bool
	IngressMatcher string
	Labels         map[string]struct{}
}

func NewConfig added in v0.1.2

func NewConfig(url *url.URL, timeout time.Duration, tenantID string, skipTLS bool, capath string, useMocks bool, ingressMatcher string, labels []string) Config

func (*Config) IsLabel added in v0.1.2

func (c *Config) IsLabel(key string) 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, reporter, layer string) *FlowQueryBuilder

func NewFlowQueryBuilderWithDefaults added in v0.1.2

func NewFlowQueryBuilderWithDefaults(cfg *Config) *FlowQueryBuilder

func (*FlowQueryBuilder) AddFilter added in v0.1.2

func (q *FlowQueryBuilder) AddFilter(key, joinedValues string) error

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(filters [][]string) 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, metricFunction, metricType, reporter, layer, scope, 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