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
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 (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 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
Click to show internal directories.
Click to hide internal directories.