add LRUCacheOptions (#102)

* add LRUCacheOptions * typo
mcollina · Dec 6, 2024 · 3adb225 · 3adb225
1 parent a09ef9f
commit 3adb225
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 4 deletions.
diff --git a/mqemitter-redis.js b/mqemitter-redis.js
@@ -25,8 +25,8 @@ function MQEmitterRedis (opts) {
   this._topics = {}
 
   this._cache = new LRUCache({
-    max: 10000,
-    ttl: 60 * 1000 // one minute
+    max: opts.maxLRUCache || 10000, // default: 10k
+    ttl: opts.ttlLRUCache || 60 * 1000 // default: one minute
   })
 
   this.state = new EE()

diff --git a/types/index.d.ts b/types/index.d.ts
@@ -10,10 +10,15 @@ export interface MQEmitterOptions {
   connectionString?: string;
 }
 
+export interface LRUCacheOptions {
+  ttlLRUCache?: number;// Time to live for the LRU cache in milliseconds
+  maxLRUCache?: number;// Maximum number of items in the LRU cache
+}
+
 export type Message = Record<string, any> & { topic: string };
 
 export interface MQEmitterRedis extends MQEmitter {
-  new (options?: MQEmitterOptions & RedisOptions): MQEmitterRedis;
+  new (options?: MQEmitterOptions & RedisOptions & LRUCacheOptions): MQEmitterRedis;
   current: number;
   concurrent: number;
   on(
@@ -31,7 +36,7 @@ export interface MQEmitterRedis extends MQEmitter {
 }
 
 declare function MQEmitterRedis(
-  options?: MQEmitterOptions & RedisOptions
+  options?: MQEmitterOptions & RedisOptions & LRUCacheOptions
 ): MQEmitterRedis;
 
 export default MQEmitterRedis;
diff --git a/types/index.test-d.ts b/types/index.test-d.ts
@@ -29,6 +29,13 @@ expectType<MQEmitterRedis>(
   })
 );
 
+expectType<MQEmitterRedis>(
+  mqEmitterRedis({
+    maxLRUCache: 100,
+    ttlLRUCache: 10000,
+  })
+);
+
 function listener(message: Message, done: () => void) {}
 
 expectType<MQEmitterRedis>(mqEmitterRedis().on('topic', listener));