log

Documentation

Index

• func Mode(m string) string
• func NewFake(t *testing.T, expectedTime time.Time, expectedLines ...string) *fake
• func StdOut(mode string) (output.LogOutput, error)
• type Client
  • func NewClient(address, token, orgID string, insecure bool) (*Client, error)
  • func (c *Client) QueryRange(ctx context.Context, out output.LogOutput, q Query) error
  • func (c *Client) QueryRangeWithRetry(ctx context.Context, out output.LogOutput, q Query) error
  • func (c *Client) TailQuery(ctx context.Context, delayFor time.Duration, out output.LogOutput, q Query) error
• type Query

Functions

func Mode

func Mode(m string) string

Mode translates the mode to lokis terminology.

func NewFake

func NewFake(t *testing.T, expectedTime time.Time, expectedLines ...string) *fake

func StdOut

func StdOut(mode string) (output.LogOutput, error)

StdOut sets up an stdout log output with the specified mode.

Types

type Client

type Client struct {
	logclient.Client
	StdOut output.LogOutput
}

func NewClient

func NewClient(address, token, orgID string, insecure bool) (*Client, error)

NewClient returns a new log API client.

func (*Client) QueryRange

func (c *Client) QueryRange(ctx context.Context, out output.LogOutput, q Query) error

QueryRange queries logs within a specific time range.

func (*Client) QueryRangeWithRetry

func (c *Client) QueryRangeWithRetry(ctx context.Context, out output.LogOutput, q Query) error

QueryRangeWithRetry queries logs within a specific time range with a retry in case of an error or not finding any logs.

func (*Client) TailQuery

func (c *Client) TailQuery(ctx context.Context, delayFor time.Duration, out output.LogOutput, q Query) error

TailQuery tails logs using the loki websocket endpoint. This has been adapted from https://github.com/grafana/loki/blob/v2.8.2/pkg/logcli/query/tail.go#L22 as it directly prints out messages using builtin log, which we don't want.

type Query

type Query struct {
	QueryString string
	Start       time.Time
	End         time.Time
	Limit       int
	Step        time.Duration
	Interval    time.Duration
	Quiet       bool
	Direction   logproto.Direction
}