Directories
¶
| Path | Synopsis |
|---|---|
|
The bloom gateway is a component that can be run as a standalone microserivce target and provides capabilities for filtering ChunkRefs based on a given list of line filter expressions.
|
The bloom gateway is a component that can be run as a standalone microserivce target and provides capabilities for filtering ChunkRefs based on a given list of line filter expressions. |
|
canary
|
|
|
Package columnar provides utilities for working with columnar in-memory arrays.
|
Package columnar provides utilities for working with columnar in-memory arrays. |
|
Package compute implements stateless computational operations over columnar data.
|
Package compute implements stateless computational operations over columnar data. |
|
Package dataobj holds utilities for working with data objects.
|
Package dataobj holds utilities for working with data objects. |
|
consumer/logsobj
Package logsobj provides tooling for creating logs-oriented data objects.
|
Package logsobj provides tooling for creating logs-oriented data objects. |
|
index/indexobj
Package indexobj provides tooling for creating index-oriented data objects.
|
Package indexobj provides tooling for creating index-oriented data objects. |
|
internal/arrowconv
Package arrowconv provides helper utilities for converting between Arrow and dataset values.
|
Package arrowconv provides helper utilities for converting between Arrow and dataset values. |
|
internal/dataset
Package dataset contains utilities for working with datasets.
|
Package dataset contains utilities for working with datasets. |
|
internal/result
Package result provides utilities for dealing with iterators that can fail during iteration.
|
Package result provides utilities for dealing with iterators that can fail during iteration. |
|
internal/streamio
Package streamio defines interfaces shared by other packages for streaming binary data.
|
Package streamio defines interfaces shared by other packages for streaming binary data. |
|
internal/util/bitmask
Package bitmask provides an API for creating and manipulating bitmasks of arbitrary length.
|
Package bitmask provides an API for creating and manipulating bitmasks of arbitrary length. |
|
internal/util/bufpool
Package bufpool offers a pool of *bytes.Buffer objects that are placed into exponentially sized buckets.
|
Package bufpool offers a pool of *bytes.Buffer objects that are placed into exponentially sized buckets. |
|
internal/util/protocodec
Package protocodec provides utilities for encoding and decoding protobuf messages into files.
|
Package protocodec provides utilities for encoding and decoding protobuf messages into files. |
|
internal/util/rangeset
Package rangeset implements a half-open interval set [start, end).
|
Package rangeset implements a half-open interval set [start, end). |
|
internal/util/sliceclear
Package sliceclear provides a way to clear and truncate the length of a slice.
|
Package sliceclear provides a way to clear and truncate the length of a slice. |
|
internal/util/symbolizer
Package symbolizer provides a string interning mechanism to reduce memory usage by reusing identical strings.
|
Package symbolizer provides a string interning mechanism to reduce memory usage by reusing identical strings. |
|
sections/internal/columnar
Package columnar provides a base implementation for sections which store columnar data using github.com/grafana/loki/v3/pkg/dataobj/internal/dataset.
|
Package columnar provides a base implementation for sections which store columnar data using github.com/grafana/loki/v3/pkg/dataobj/internal/dataset. |
|
sections/logs
Package logs defines types used for the data object logs section.
|
Package logs defines types used for the data object logs section. |
|
sections/pointers
Package pointers defines types used for the data object pointers section.
|
Package pointers defines types used for the data object pointers section. |
|
sections/streams
Package streams defines types used for the data object streams section.
|
Package streams defines types used for the data object streams section. |
|
tools
TODO(grobinson): Find a way to move this file into the dataobj package.
|
TODO(grobinson): Find a way to move this file into the dataobj package. |
|
internal/arrowagg
Package arrowagg provides utilities for aggregating Apache Arrow data structures.
|
Package arrowagg provides utilities for aggregating Apache Arrow data structures. |
|
internal/assertions
Assertions package provides a set of runtime assertions for extra safety.
|
Assertions package provides a set of runtime assertions for extra safety. |
|
internal/deletion
package deletion contains utilities for handling deletion requests in query engine.
|
package deletion contains utilities for handling deletion requests in query engine. |
|
internal/executor/matchutil
Package matchutil provides optimized string matching utilities for the query engine.
|
Package matchutil provides optimized string matching utilities for the query engine. |
|
internal/planner/logical
Package logical provides a logical query plan representation for data processing operations.
|
Package logical provides a logical query plan representation for data processing operations. |
|
internal/proto/ulid
Package ulid provides a ULID implementation.
|
Package ulid provides a ULID implementation. |
|
internal/scheduler
Package scheduler provides an implementation of workflow.Runner that works by scheduling tasks to be executed by a set of workers.
|
Package scheduler provides an implementation of workflow.Runner that works by scheduling tasks to be executed by a set of workers. |
|
internal/scheduler/wire
Package wire provides the wire protocol for how peers scheduler peers communicate.
|
Package wire provides the wire protocol for how peers scheduler peers communicate. |
|
internal/util/dag
Package dag provides utilities for working with directed acyclic graphs (DAGs).
|
Package dag provides utilities for working with directed acyclic graphs (DAGs). |
|
internal/util/ewma
Package ewma provides an implementation of an exponentially weighted moving average (EWMA) that can be reported as a Prometheus metric.
|
Package ewma provides an implementation of an exponentially weighted moving average (EWMA) that can be reported as a Prometheus metric. |
|
internal/util/objtest
Package objtest provides support for creating a data object storage directory for testing purposes.
|
Package objtest provides support for creating a data object storage directory for testing purposes. |
|
internal/util/queue/fair
Package fair implements a Hierarchical Fair Queue (HFQ), providing balanced service across a hierarchy of queues.
|
Package fair implements a Hierarchical Fair Queue (HFQ), providing balanced service across a hierarchy of queues. |
|
internal/worker
Package worker provides a mechanism to connect to the [scheduler] for executing tasks.
|
Package worker provides a mechanism to connect to the [scheduler] for executing tasks. |
|
internal/workflow
Package workflow defines how to represent physical plans as distributed workflows.
|
Package workflow defines how to represent physical plans as distributed workflows. |
|
Package expr provides utilities for evaluating expressions against a columnar.RecordBatch with a selection vector.
|
Package expr provides utilities for evaluating expressions against a columnar.RecordBatch with a selection vector. |
|
Package goldfish provides query sampling and comparison functionality for the querytee and Goldfish UI.
|
Package goldfish provides query sampling and comparison functionality for the querytee and Goldfish UI. |
|
index
originally from https://github.com/cortexproject/cortex/blob/868898a2921c662dcd4f90683e8b95c927a8edd8/pkg/ingester/index/index.go but modified to support sharding queries.
|
originally from https://github.com/cortexproject/cortex/blob/868898a2921c662dcd4f90683e8b95c927a8edd8/pkg/ingester/index/index.go but modified to support sharding queries. |
|
Package kafka provides encoding and decoding functionality for Loki's Kafka integration.
|
Package kafka provides encoding and decoding functionality for Loki's Kafka integration. |
|
client
Package client provides gRPC client implementation for limits service.
|
Package client provides gRPC client implementation for limits service. |
|
frontend
Package frontend contains provides a frontend service for ingest limits.
|
Package frontend contains provides a frontend service for ingest limits. |
|
frontend/client
Package client provides gRPC client implementation for limits-frontend.
|
Package client provides gRPC client implementation for limits-frontend. |
|
logcli
|
|
|
Fork of https://raw.githubusercontent.com/cockroachdb/cockroach/065aa74206c9ec9bcd8b9ea2a6c62ddde8aab0a6/pkg/util/treeprinter/tree_printer.go
|
Fork of https://raw.githubusercontent.com/cockroachdb/cockroach/065aa74206c9ec9bcd8b9ea2a6c62ddde8aab0a6/pkg/util/treeprinter/tree_printer.go |
|
bench/cmd/bench
command
|
|
|
bench/cmd/correctness-metrics
command
|
|
|
bench/cmd/generate
command
|
|
|
bench/cmd/generate-k6
command
|
|
|
bench/cmd/stream
command
|
|
|
bench/discover/cmd
command
|
|
|
log/logfmt
Adapted from https://github.com/go-logfmt/logfmt/ but []byte as parameter instead Original license is MIT.
|
Adapted from https://github.com/go-logfmt/logfmt/ but []byte as parameter instead Original license is MIT. |
|
syntax
This file is taken from the golang text/scanner package so `bufLen` can be set to `maxInputSize`.
|
This file is taken from the golang text/scanner package so `bufLen` can be set to `maxInputSize`. |
|
metadata
Package metadata provides primitives for recording metadata across the query path.
|
Package metadata provides primitives for recording metadata across the query path. |
|
stats
Package stats provides primitives for recording metrics across the query path.
|
Package stats provides primitives for recording metrics across the query path. |
|
Package memory provides support for allocating and reusing contiguous [Region]s of memory.
|
Package memory provides support for allocating and reusing contiguous [Region]s of memory. |
|
internal/memalign
Package memalign provides utilities for aligning memory.
|
Package memalign provides utilities for aligning memory. |
|
internal/unsafecast
Package unsafecast provides utilties for performing unsafe type casts.
|
Package unsafecast provides utilties for performing unsafe type casts. |
|
queryrange
Package contains methods to marshal logqmodel types to queryrange Protobuf types.
|
Package contains methods to marshal logqmodel types to queryrange Protobuf types. |
|
goldfish
Package goldfish provides query sampling and comparison functionality for the querytee tool.
|
Package goldfish provides query sampling and comparison functionality for the querytee tool. |
|
storage/cleaner
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics.
|
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics. |
|
storage/instance
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics.
|
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics. |
|
storage/util
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics.
|
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics. |
|
storage/wal
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics.
|
This directory was copied and adapted from https://github.com/grafana/agent/tree/main/pkg/metrics. |
|
Package scratch provides an abstraction for scratch space.
|
Package scratch provides an abstraction for scratch space. |
|
hack
command
|
|
|
stores/shipper/bloomshipper/config
package bloomshipperconfig resides in its own package to prevent circular imports with storage package
|
package bloomshipperconfig resides in its own package to prevent circular imports with storage package |
|
tool
|
|
|
Package ui provides HTTP handlers for the Loki UI and cluster management interface.
|
Package ui provides HTTP handlers for the Loki UI and cluster management interface. |
|
arrowtest
Package arrowtest provides utilities for testing Arrow records.
|
Package arrowtest provides utilities for testing Arrow records. |
|
fakeauth
Package fakeauth provides middlewares thats injects a fake userID, so the rest of the code can continue to be multitenant.
|
Package fakeauth provides middlewares thats injects a fake userID, so the rest of the code can continue to be multitenant. |
|
marshal
Package marshal converts internal objects to loghttp model objects.
|
Package marshal converts internal objects to loghttp model objects. |
|
marshal/legacy
Package marshal converts internal objects to loghttp model objects.
|
Package marshal converts internal objects to loghttp model objects. |
|
rangeio
Package rangeio provides basic interfaces and utilities for reading ranges of data.
|
Package rangeio provides basic interfaces and utilities for reading ranges of data. |
|
Package xcap provides a utility to capture statistical information about the lifetime of a query.
|
Package xcap provides a utility to capture statistical information about the lifetime of a query. |
Click to show internal directories.
Click to hide internal directories.