query

Documentation

Index

• Constants
• func GetObjectClient(conf loki.Config, cm storage.ClientMetrics) (chunk.ObjectClient, error)
• func LoadSchemaUsingObjectClient(oc chunk.ObjectClient, name string) (*config.SchemaConfig, error)
• type Query
  • func (q *Query) DoLocalQuery(out output.LogOutput, statistics bool, orgID string, useRemoteSchema bool) error
  • func (q *Query) DoQuery(c client.Client, out output.LogOutput, statistics bool)
  • func (q *Query) SetInstant(time time.Time)
  • func (q *Query) TailQuery(delayFor time.Duration, c client.Client, out output.LogOutput)

Constants

const SchemaConfigFilename = "schemaconfig.yaml"

Functions

func GetObjectClient

func GetObjectClient(conf loki.Config, cm storage.ClientMetrics) (chunk.ObjectClient, error)

func LoadSchemaUsingObjectClient

func LoadSchemaUsingObjectClient(oc chunk.ObjectClient, name string) (*config.SchemaConfig, error)

Types

type Query

type Query struct {
	QueryString            string
	Start                  time.Time
	End                    time.Time
	Limit                  int
	BatchSize              int
	Forward                bool
	Step                   time.Duration
	Interval               time.Duration
	Quiet                  bool
	NoLabels               bool
	IgnoreLabelsKey        []string
	ShowLabelsKey          []string
	FixedLabelsLen         int
	ColoredOutput          bool
	LocalConfig            string
	FetchSchemaFromStorage bool
}

Query contains all necessary fields to execute instant and range queries and print the results.

func (*Query) DoLocalQuery

func (q *Query) DoLocalQuery(out output.LogOutput, statistics bool, orgID string, useRemoteSchema bool) error

DoLocalQuery executes the query against the local store using a Loki configuration file.

func (*Query) DoQuery

func (q *Query) DoQuery(c client.Client, out output.LogOutput, statistics bool)

DoQuery executes the query and prints out the results

func (*Query) SetInstant

func (q *Query) SetInstant(time time.Time)

SetInstant makes the Query an instant type

func (*Query) TailQuery

func (q *Query) TailQuery(delayFor time.Duration, c client.Client, out output.LogOutput)

TailQuery connects to the Loki websocket endpoint and tails logs