loki

type Config ¶ added in v0.1.2

type Config struct {
	URL      *url.URL
	Timeout  time.Duration
	TenantID string
	Labels   map[string]struct{}
}

func NewConfig(url *url.URL, timeout time.Duration, tenantID string, labels []string) Config

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(cfg *Config, start, end, limit, reporter string) *FlowQueryBuilder

func NewFlowQueryBuilderWithDefaults(cfg *Config) *FlowQueryBuilder

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

func (q *FlowQueryBuilder) Build() string

func (q *FlowQueryBuilder) Filters(filters [][]string) error

type MatrixMerger ¶ added in v0.1.2

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

MatrixMerger stores a state to build unique Matrix from multiple ones

func NewMatrixMerger() *MatrixMerger

func (m *MatrixMerger) AddMatrix(from model.Matrix) model.Matrix

func (m *MatrixMerger) GetMatrix() model.Matrix

type StreamMerger ¶ added in v0.1.2

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

func NewStreamMerger() *StreamMerger

func (m *StreamMerger) AddStreams(from model.Streams) model.Streams

func (m *StreamMerger) GetStreams() model.Streams

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(cfg *Config, start, end, limit, metricFunction, metricType, reporter string) (*TopologyQueryBuilder, error)

func (q *TopologyQueryBuilder) Build() string