Tomás Farías Santana 1e94d8e138 feat(ingestion-slowlane): Re-route events in plugin-server on capacity exceeded (#14211) ... * feat(ingestion-slowlane): Add token-bucket utility * feat(ingestion-slowlane): Re-route overflow events * fix: Import missing stringToBoolean * fix(ingestion-slowlane): Flip around kafka topics according to mode * refactor(ingestion-slowlane): Use dash instead of underscore in filename * fix(ingestion-slowlane): Do not increase tokens beyond bucket capacity * feat(ingestion-slowlane): Add ingestion-overflow mode/capability/consumer * feat(ingestion-slowlane): Add ingestion warning for capacity overflow * test(ingestion-slowlane): Add test for ingestion of overflow events * fix(ingestion-slowlane): Rate limit warnings to 1 per hour * test(ingestion-slowlane): Add a couple more tests for overflow re-route * fix(slowlane-ingestion): Look at batch topic to determine message topic * refactor(slowlane-ingestion): Use refactored consumer model * fix(slowlane-ingestion): Undo topic requirement in eachMessageIngestion * refactor(slowlane-ingestion): Only produce events if ingestionOverflow is also enabled * refactor(slowlane-ingestion): Use an env variable to determine if ingestionOverflow is enabled * chore(slowlane-ingestion): Add a comment explaining env variable		2023-02-16 14:30:13 +01:00
..
db
event.test.ts
retries.test.ts
token-bucket.test.ts	feat(ingestion-slowlane): Re-route events in plugin-server on capacity exceeded (#14211)	2023-02-16 14:30:13 +01:00