add LRUCacheOptions

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()

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;

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));