Add setQueueRateLimit

src/actions/set-queue-rate-limit.ts

@@ -0,0 +1,21 @@
+import { Redis } from 'ioredis';
+import { set } from '../utils/redis';
+import { getQueueRateLimitKey } from '../utils/keys';
+
+export const setQueueRateLimit = async ({
+  amount,
+  interval,
+  queue,
+  client,
+}: {
+  amount: number;
+  interval: number;
+  queue: string;
+  client: Redis;
+}) => {
+  await set({
+    key: getQueueRateLimitKey({ queue }),
+    value: JSON.stringify({ amount, interval }),
+    client,
+  });
+};

src/utils/keys.ts

@@ -2,6 +2,10 @@
   Data structure keys:
 */
 
+export const getQueueRateLimitKey = ({ queue }: { queue: string }) => {
+  return `${queue}:rate-limit`;
+};
+
 export const getQueuePausedKey = ({ queue }: { queue: string }) => {
   return `${queue}:is-paused`;
 };