feat: add ability to run commands on the RedisManager class

adonisjs · Jul 28, 2023 · 7dd89a0 · 7dd89a0
1 parent 8300ac1
commit 7dd89a0
Show file tree

Hide file tree

Showing 7 changed files with 710 additions and 69 deletions.
diff --git a/src/connections/abstract_connection.ts b/src/connections/abstract_connection.ts
@@ -73,6 +73,14 @@ export abstract class AbstractConnection<T extends Redis | Cluster> extends Even
     return this.ioSubscriberConnection?.status
   }
 
+  /**
+   * Get the number of commands queued in automatic pipelines.
+   * This is not available (and returns 0) until the cluster is connected and slots information have been received.
+   */
+  get autoPipelineQueueSize() {
+    return this.ioConnection.autoPipelineQueueSize
+  }
+
   /**
    * Parent class must implement makeSubscriberConnection
    */