lokihandler

Documentation

Overview

Package lokihandler provides Loki API implementation.

Index

• func ParseDuration[S ~string](param S) (time.Duration, error)
• func ParseTimestamp[S ~string](lt S, def time.Time) (time.Time, error)
• type LokiAPI
  • func NewLokiAPI(q logstorage.Querier, engine *logqlengine.Engine) *LokiAPI
  • func (h *LokiAPI) IndexStats(context.Context, lokiapi.IndexStatsParams) (*lokiapi.IndexStats, error)
  • func (h *LokiAPI) LabelValues(ctx context.Context, params lokiapi.LabelValuesParams) (*lokiapi.Values, error)
  • func (h *LokiAPI) Labels(ctx context.Context, params lokiapi.LabelsParams) (*lokiapi.Labels, error)
  • func (h *LokiAPI) NewError(_ context.Context, err error) *lokiapi.ErrorStatusCode
  • func (h *LokiAPI) Push(context.Context, lokiapi.PushReq) error
  • func (h *LokiAPI) Query(ctx context.Context, params lokiapi.QueryParams) (*lokiapi.QueryResponse, error)
  • func (h *LokiAPI) QueryRange(ctx context.Context, params lokiapi.QueryRangeParams) (*lokiapi.QueryResponse, error)
  • func (h *LokiAPI) Series(ctx context.Context, params lokiapi.SeriesParams) (*lokiapi.Maps, error)

Functions

func ParseDuration

func ParseDuration[S ~string](param S) (time.Duration, error)

ParseDuration parses Loki API duration from given string.

func ParseTimestamp

func ParseTimestamp[S ~string](lt S, def time.Time) (time.Time, error)

ParseTimestamp parses Loki API timestamp from given string.

If string is empty, def is returned.

Types

type LokiAPI

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

LokiAPI implements lokiapi.Handler.

func NewLokiAPI

func NewLokiAPI(q logstorage.Querier, engine *logqlengine.Engine) *LokiAPI

NewLokiAPI creates new LokiAPI.

func (*LokiAPI) IndexStats

func (h *LokiAPI) IndexStats(context.Context, lokiapi.IndexStatsParams) (*lokiapi.IndexStats, error)

IndexStats implements indexStats operation.

Get index stats.

GET /loki/api/v1/index/stats

func (*LokiAPI) LabelValues

func (h *LokiAPI) LabelValues(ctx context.Context, params lokiapi.LabelValuesParams) (*lokiapi.Values, error)

LabelValues implements labelValues operation. Get values of label.

GET /loki/api/v1/label/{name}/values

func (*LokiAPI) Labels

func (h *LokiAPI) Labels(ctx context.Context, params lokiapi.LabelsParams) (*lokiapi.Labels, error)

Labels implements labels operation.

Get labels. Used by Grafana to test connection to Loki.

GET /loki/api/v1/labels

func (*LokiAPI) NewError

func (h *LokiAPI) NewError(_ context.Context, err error) *lokiapi.ErrorStatusCode

NewError creates *ErrorStatusCode from error returned by handler.

Used for common default response.

func (*LokiAPI) Push

func (h *LokiAPI) Push(context.Context, lokiapi.PushReq) error

Push implements push operation.

Push data.

POST /loki/api/v1/push

func (*LokiAPI) Query

func (h *LokiAPI) Query(ctx context.Context, params lokiapi.QueryParams) (*lokiapi.QueryResponse, error)

Query implements query operation.

Query.

GET /loki/api/v1/query

func (*LokiAPI) QueryRange

func (h *LokiAPI) QueryRange(ctx context.Context, params lokiapi.QueryRangeParams) (*lokiapi.QueryResponse, error)

QueryRange implements queryRange operation.

Query range.

GET /loki/api/v1/query_range

func (*LokiAPI) Series

func (h *LokiAPI) Series(ctx context.Context, params lokiapi.SeriesParams) (*lokiapi.Maps, error)

Series implements series operation.

Get series.

GET /loki/api/v1/series