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
Authorization string
SkipTLS bool
CAPath string
UseMocks bool
ForwardUserToken bool
Labels map[string]struct{}
}
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, reporter constants.Reporter) *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 (m *MatrixMerger) Add(from model.QueryResponseData) (model.ResultValue, error)
func (*MatrixMerger) Get ¶ added in v0.1.3
func (m *MatrixMerger) Get() *model.AggregatedQueryResponse
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 (m *StreamMerger) Add(from model.QueryResponseData) (model.ResultValue, error)
func (*StreamMerger) Get ¶ added in v0.1.3
func (m *StreamMerger) Get() *model.AggregatedQueryResponse
type TopologyQueryBuilder ¶ added in v0.1.2
type TopologyQueryBuilder struct {
*FlowQueryBuilder
// contains filtered or unexported fields
}
func NewTopologyQuery ¶ added in v0.1.2
func (*TopologyQueryBuilder) Build ¶ added in v0.1.2
func (q *TopologyQueryBuilder) Build() string
Click to show internal directories.
Click to hide internal directories.