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 ¶
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 (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 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, in *TopologyInput) (*TopologyQueryBuilder, error)
func (*TopologyQueryBuilder) Build ¶ added in v0.1.2
func (q *TopologyQueryBuilder) Build() string
Click to show internal directories.
Click to hide internal directories.