Versions in this module Expand all Collapse all v2 v2.4.3 Mar 21, 2022 Changes in this version + var QueryParallelism = 100 + func DoParallelQueries(ctx context.Context, doSingleQuery DoSingleQuery, queries []chunk.IndexQuery, ...) error + func EnsureDirectory(dir string) error + func GetParallelChunks(ctx context.Context, maxParallel int, chunks []chunk.Chunk, ...) ([]chunk.Chunk, error) + func NewReadCloserWithContextCancelFunc(readCloser io.ReadCloser, cancel context.CancelFunc) io.ReadCloser + func QueryFilter(callback chunk.QueryPagesCallback) chunk.QueryPagesCallback + type DoSingleQuery func(context.Context, chunk.IndexQuery, chunk.QueryPagesCallback) error + type ReadCloserWithContextCancelFunc struct + func (r ReadCloserWithContextCancelFunc) Close() error Other modules containing this package github.com/pao214/loki/v3
Go to main page