Eric Allam bf43fd4f8e Use priority offsets in MarQS and schedule future messages using redis worker (#1720) ...

* Improve the MarQS priority system by moving future messages into the LRE worker and using a priority timestamp offset to define priority in messages

* Add a test to make sure priority offsets don't unfairly favor environments

* requeuing should clear concurrency sets

* Heartbeats should only reschedule existing heartbeat jobs

* Fix type error

2025-02-20 14:06:32 +00:00

..

utils

MarQS reserve concurrency system & queue priority for resuming/retrying (#1715)

2025-02-19 11:43:34 +00:00

authorization.test.ts

Use one-time use tokens when triggering or batch triggering from the frontend (#1515)

2024-11-29 20:16:37 +00:00

authorizationRateLimitMiddleware.test.ts

Upgrades and fixes to Realtime and Realtime streams (#1549)

2024-12-13 11:42:50 +00:00

fairDequeuingStrategy.test.ts

Use priority offsets in MarQS and schedule future messages using redis worker (#1720)

2025-02-20 14:06:32 +00:00

GCRARateLimiter.test.ts

Rate limit alerts by channel for task run alerts using generic cell rate algo (#1679)

2025-02-07 13:36:37 +00:00

marqsKeyProducer.test.ts

Use priority offsets in MarQS and schedule future messages using redis worker (#1720)

2025-02-20 14:06:32 +00:00

realtimeClient.test.ts

Upgrade local dev to use electric beta.15 (#1699)

2025-02-13 11:02:01 +00:00

setup-test-env.ts

Initial commit of the mono repo

2022-12-06 12:28:16 +00:00