feat: add trimEvents method to queue client

taskforcesh · Sep 29, 2019 · b7da7c4 · b7da7c4
1 parent dbb66cd
commit b7da7c4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/classes/queue.ts b/src/classes/queue.ts
@@ -171,4 +171,9 @@ export class Queue extends QueueGetters {
     this.emit('cleaned', jobs, type);
     return jobs;
   }
+
+  async trimEvents(maxLength: number) {
+    await this.waitUntilReady();
+    return this.client.xtrim(this.keys.events, 'MAXLEN', '~', maxLength);
+  }
 }