Commit Graph

158 Commits (main)

Author SHA1 Message Date
Assel Meher de092daf0a
feat: Handle state change lock in prepare downscale (#20141) 3 weeks ago
George Robinson 1ac5d1f0d5
fix: revoke partitions if lost (#20030) 1 month ago
George Robinson 3a24f5d291
feat: write to dataobj partitions based on segmentation key (#19946) 1 month ago
George Robinson 7a09c0df45
chore: implement UpdateRates with simple in-memory tracker (#19907) 2 months ago
George Robinson e173cf4fb1
feat: Add UpdateRates RPC, update rates from the frontend, return no-op in the service (#19894) 2 months ago
George Robinson ec2b16a63d
chore: add allZones which returns a sorted iterator over zones (#19888) 2 months ago
George Robinson 82cfafd386
fix: reduce FetchMaxBytes to 10MB (#19883) 2 months ago
George Robinson b8536aaa66
feat: check partition state in parallel (#19884) 2 months ago
George Robinson 0a51ecc321
chore: panic if we consume too many topics (#19885) 2 months ago
George Robinson bda8adb2bb
chore: remove debug logging from HTTP endpoint (#19690) 2 months ago
George Robinson 1e194f808c
chore: use seq.Iter for iterating stream usage (#17957) 2 months ago
George Robinson 5c85081ef9
chore: log when limits pod loses a partition (#19676) 2 months ago
Christian Haudum 73bc30d9a8
perf(engine): Improve regexp expression evaluation (#19644) 2 months ago
George Robinson 7748fc5142
fix: do not validate limits service configuration if service is disabled (#19612) 2 months ago
Salva Corts 8486acb981
feat: support per policy overriden stream limits on limits service (#19403) 2 months ago
George Robinson 7fc404c99e
chore: deleted unused code from OffsetManager (#19256) 3 months ago
George Robinson 6fa4d0d6d4
chore: should use IsZero() instead of comparison to time.Time{} (#19145) 4 months ago
keeghcet 81229effb9
chore: fix inconsistent function name in comment (#19081) 4 months ago
George Robinson 34b6bdc7f7
chore: stop using gatherer as a name (#18144) 6 months ago
George Robinson 05fb19c530
chore: make the default value (iota) an unknown (#18157) 7 months ago
Periklis Tsirakidis a07bee5dc2
fix(limits): Set ready when all partitions ready (#18092) 7 months ago
George Robinson c42ccc3248
feat: return ReasonFailed from ingest-limits frontend (#18123) 7 months ago
George Robinson b15d85da9b
feat: add ReasonFailed (#18055) 7 months ago
renovate[bot] 3cb216c33c
fix(deps): update module github.com/coder/quartz to v0.2.1 (main) (#17922) 7 months ago
Paul Rogers 0b8b1cdb1e
chore(deps): dskit bump (#18079) 7 months ago
George Robinson c69721600c
chore: stop updating rate limits and remove reason as implementation is deferred (#18052) 7 months ago
George Robinson 89c972286c
chore: add metric to track the number of rejected streams (#18048) 7 months ago
George Robinson c33cd3dd4e
chore: remove unused recheck period (#17972) 7 months ago
George Robinson df58b248ae
chore: set limits on buffering from Kafka (#18031) 7 months ago
George Robinson 35f18a162e
feat: quick fix to produce a stream once per minute (#17996) 7 months ago
George Robinson 9dd14ba589
fix: counter variables should not have total at the end (#17982) 7 months ago
George Robinson 4e017eb377
chore: put noun at start of metric (#17979) 7 months ago
Periklis Tsirakidis d27d46d373
chore(limits): Add partition assignment metrics (#17975) 7 months ago
George Robinson 315a0b159b
chore: log the zone when missing instance for partition (#17968) 7 months ago
George Robinson a746f42bdb
feat: add metric that tracks unanswered streams (#17966) 7 months ago
George Robinson 5ba7513d20
chore: move checking of limits and relevant metrics into limit.go (#17949) 7 months ago
George Robinson 7c9bab327a
chore: return just active streams and rate buckets (#17944) 7 months ago
George Robinson 80ee8b2066
chore: add a missing test case where timestamp is not at bucket start (#17946) 7 months ago
George Robinson 3350f32478
chore: remove MetadataTopic as it is unused (#17947) 7 months ago
George Robinson 8566f21e30
chore: remove deprecated config (#17941) 7 months ago
Oleg Zaytsev c8a15f451c
refactor: Use OTel tracing library (#17859) 7 months ago
George Robinson da186e59b9
chore: fix lint again (#17939) 7 months ago
George Robinson 741cda0dc3
chore: fix main branch failing (#17935) 7 months ago
George Robinson 6b66122421
chore: do not count active streams in update cond to make this faster (#17933) 7 months ago
George Robinson ba10bbf25a
chore: MockLimits should be package private (#17934) 7 months ago
George Robinson a13dc0b0ac
chore: move limits into update cond to prepare for optimizing counting active streams (#17932) 7 months ago
George Robinson 3686861f8a
feat: optimize rate buckets to avoid re-allocating slice (#17904) 7 months ago
Periklis Tsirakidis 60c76318e6
fix(limits): Read the consumer group and topic from the ingest-limits config (#17831) 7 months ago
George Robinson 2c2fa896da
chore: remove unused context from partition_manager.go (#17899) 7 months ago
George Robinson efaafd2f6c
feat: add a fast path for consuming records from Kafka (#17858) 7 months ago