Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + func GetObjectClient(conf loki.Config, cm storage.ClientMetrics) (chunk.ObjectClient, error) + func LoadSchemaUsingObjectClient(oc chunk.ObjectClient, names ...string) (*config.SchemaConfig, error) + type PartFile struct + func NewPartFile(filename string) *PartFile + func (f *PartFile) Close() error + func (f *PartFile) CreateTempFile() error + func (f *PartFile) Exists() (bool, error) + func (f *PartFile) Finalize() error + func (f *PartFile) Write(b []byte) (int, error) + type Query struct + BatchSize int + ColoredOutput bool + End time.Time + FetchSchemaFromStorage bool + FixedLabelsLen int + Forward bool + IgnoreLabelsKey []string + Interval time.Duration + KeepParts bool + Limit int + LocalConfig string + MergeParts bool + NoLabels bool + OverwriteCompleted bool + ParallelDuration time.Duration + ParallelMaxWorkers int + PartPathPrefix string + QueryString string + Quiet bool + ShowLabelsKey []string + Start time.Time + Step time.Duration + 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) DoQueryParallel(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)
Go to main page