logs

func Query ¶

func Query(
	ctx context.Context,
	l log.Logger,
	endpoint *url.URL,
	t auth.TokenProvider,
	q options.Query,
	tls options.TLS,
	defaultStep time.Duration,
) (int, promapiv1.Warnings, error)

func Read ¶

func Read(
	ctx context.Context,
	endpoint *url.URL,
	tp auth.TokenProvider,
	labels []prompb.Label,
	ago, latency time.Duration,
	m instr.Metrics,
	l log.Logger,
	tls options.TLS,
) (int, error)

Read executes query against Loki with the same labels to retrieve the written logs back.

func Write ¶

func Write(ctx context.Context, endpoint *url.URL, t auth.TokenProvider, wreq *PushRequest, l log.Logger, tls options.TLS) (int, error)

Write executes a push against Loki sending a set of labels and log entries to store.