Like Prometheus, but for logs.
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 
loki/pkg/ingester
Assel Meher 6d74050e63
chore: update dskit to include LRU cache for partition ring shuffle sharding (#20270)
1 week ago
..
client refactor: Use OTel tracing library (#17859) 7 months ago
index fix(deps): update module github.com/prometheus/prometheus to v0.308.0 (main) (#20131) 3 weeks ago
wal chore: replace pkg/errors with errors (#13583) 1 year ago
checkpoint.go fix(deps): update module github.com/apache/arrow-go/v18 to v18.4.1 (main) (#19750) 2 months ago
checkpoint.pb.go chore: update loki modules for 3.0 release (#12433) 2 years ago
checkpoint.proto chore: update loki modules for 3.0 release (#12433) 2 years ago
checkpoint_test.go fix(ingester): Add WAL cleanup code (#19607) 2 months ago
chunk_test.go chore: Clarify compression package (#14257) 1 year ago
downscale.go feat: Handle state change lock in prepare downscale (#20141) 2 weeks ago
encoding_test.go chore: Clarify compression package (#14257) 1 year ago
flush.go fix(deps): update module golang.org/x/net to v0.47.0 (main) (#19850) 1 month ago
flush_test.go fix(deps): update module golang.org/x/net to v0.47.0 (main) (#19850) 1 month ago
ingester.go feat: Add partition state to consumption lag metric (#19912) 1 month ago
ingester_test.go fix(deps): update module golang.org/x/net to v0.47.0 (main) (#19850) 1 month ago
instance.go fix: Pass ingestion policy set through header to ingesters via grpc (#19630) 2 months ago
instance_test.go feat: Resolve ingestion policy via a header (#19548) 2 months ago
kafka_consumer.go fix: fix context canceled stops reader from cleaning up (#19210) 3 months ago
kafka_consumer_test.go chore: parallel kafka consumer (#17262) 7 months ago
limiter.go feat: support per policy overriden stream limits on limits service (#19403) 2 months ago
limiter_test.go chore: update dskit to include LRU cache for partition ring shuffle sharding (#20270) 1 week ago
mapper.go refactor(stringlabels): Support stringlabels in ingester (#17243) 8 months ago
mapper_test.go refactor(stringlabels): Support stringlabels ingester tests (#17121) 9 months ago
metrics.go feat(ingester): Add WAL throttling for partition ingesters (#19538) 2 months ago
owned_streams.go feat: per policy overridable stream limits (#18994) 4 months ago
owned_streams_test.go feat: per policy overridable stream limits (#18994) 4 months ago
recalculate_owned_streams.go refactor: replace experimental `maps` and `slices` with stdlib (#15051) 1 year ago
recalculate_owned_streams_test.go chore: update dskit to include LRU cache for partition ring shuffle sharding (#20270) 1 week ago
recovery.go fix(deps): update module golang.org/x/net to v0.47.0 (main) (#19850) 1 month ago
recovery_test.go chore: consistently use new labels.Labels API (#18490) 5 months ago
replay_controller.go refactor(ingestor): WAL Replay controller: Use singleflight to ensure only one inflight flush is happening (#19831) 1 month ago
replay_controller_test.go refactor(ingestor): WAL Replay controller: Use singleflight to ensure only one inflight flush is happening (#19831) 1 month ago
stream.go feat: per policy overridable stream limits (#18994) 4 months ago
stream_rate_calculator.go chore: update loki modules for 3.0 release (#12433) 2 years ago
stream_rate_calculator_test.go Stream Sharding amortize push payloads across the observed rate. (#9414) 3 years ago
stream_test.go feat: per policy overridable stream limits (#18994) 4 months ago
streams_map.go Upgrade `golangci-lint` and fix linting errors (#9601) 3 years ago
streams_map_test.go feat: per policy overridable stream limits (#18994) 4 months ago
tailer.go fix(deps): update module golang.org/x/net to v0.47.0 (main) (#19850) 1 month ago
tailer_test.go refactor(stringlabels): Support stringlabels in `logql/log` package (#17838) 7 months ago
wal.go fix(wal): Move WAL disk check to platform-specific code (#19619) 2 months ago
wal_disk_throttle_test.go feat(ingester): Add WAL throttling for partition ingesters (#19538) 2 months ago
wal_unix.go fix(wal): Move WAL disk check to platform-specific code (#19619) 2 months ago
wal_windows.go fix(wal): Move WAL disk check to platform-specific code (#19619) 2 months ago