@cubejs-backend/query-orchestrator - npm Package Compare versions

Comparing version 0.0.8 to 0.0.21

orchestrator/PreAggregations.js

@@ -49,3 +49,3 @@ const crypto = require('crypto');
     this.redisPrefix = redisPrefix;
-    this.clientFactory = clientFactory;
+    this.driverFactory = clientFactory;
     this.queryCache = queryCache;
@@ -60,3 +60,3 @@ this.preAggregations = preAggregations;
     if (!tables) {
-      const client = await this.clientFactory();
+      const client = await this.driverFactory();
       tables = await client.getTablesQuery(schema);
@@ -129,3 +129,3 @@ await this.redisClient.setAsync(this.tablesRedisKey(), JSON.stringify(tables), 'EX', 120);
     this.redisPrefix = redisPrefix;
-    this.clientFactory = clientFactory;
+    this.driverFactory = clientFactory;
     this.logger = logger;
@@ -173,3 +173,3 @@ this.queryCache = queryCache;
     if (!versionEntries.length) {
-      const client = await this.clientFactory();
+      const client = await this.driverFactory();
       await client.createSchemaIfNotExists(this.preAggregation.preAggregationsSchema);
@@ -311,5 +311,6 @@ }
 class PreAggregations {
-  constructor(redisPrefix, clientFactory, logger, queryCache) {
+  constructor(redisPrefix, clientFactory, logger, queryCache, options) {
+    this.options = options || {};
     this.redisPrefix = redisPrefix;
-    this.clientFactory = clientFactory;
+    this.driverFactory = clientFactory;
     this.logger = logger;
@@ -324,3 +325,3 @@ this.queryCache = queryCache;
     const preAggregations = queryBody.preAggregations || [];
-    const loadCache = new PreAggregationLoadCache(this.redisPrefix, this.clientFactory, this.queryCache, this);
+    const loadCache = new PreAggregationLoadCache(this.redisPrefix, this.driverFactory, this.queryCache, this);
     return preAggregations.map(p =>
@@ -330,3 +331,3 @@ (preAggregationsTablesToTempTables) => {
           this.redisPrefix,
-          this.clientFactory,
+          this.driverFactory,
           this.logger,
@@ -353,7 +354,7 @@ this.queryCache,
     if (!this.queue) {
-      this.queue = QueryCache.createQueue(`SQL_PRE_AGGREGATIONS_${this.redisPrefix}`, this.clientFactory, (client, q) => {
+      this.queue = QueryCache.createQueue(`SQL_PRE_AGGREGATIONS_${this.redisPrefix}`, this.driverFactory, (client, q) => {
         const { preAggregation, preAggregationsTablesToTempTables, newVersionEntry } = q;
         const loader = new PreAggregationLoader(
           this.redisPrefix,
-          this.clientFactory,
+          this.driverFactory,
           this.logger,
@@ -364,6 +365,6 @@ this.queryCache,
           preAggregationsTablesToTempTables,
-          new PreAggregationLoadCache(this.redisPrefix, this.clientFactory, this.queryCache, this)
+          new PreAggregationLoadCache(this.redisPrefix, this.driverFactory, this.queryCache, this)
         );
         return loader.refresh(newVersionEntry)(client);
-      }, { concurrency: 1, logger: this.logger });
+      }, { concurrency: 1, logger: this.logger, ...this.options.queueOptions });
     }
@@ -370,0 +371,0 @@ return this.queue;

orchestrator/QueryCache.js

@@ -7,5 +7,6 @@ const redis = require('redis');
 class QueryCache {
-  constructor(redisPrefix, clientFactory, logger) {
+  constructor(redisPrefix, clientFactory, logger, options) {
+    this.options = options || {};
     this.redisPrefix = redisPrefix;
-    this.clientFactory = clientFactory;
+    this.driverFactory = clientFactory;
     this.logger = logger;
@@ -94,5 +95,5 @@ this.redisClient = redis.createClient(process.env.REDIS_URL);
         `SQL_QUERY_${this.redisPrefix}`,
-        this.clientFactory,
+        this.driverFactory,
         (client, q) => client.query(q.query, q.values),
-        { logger: this.logger }
+        { logger: this.logger, ...this.options.queueOptions }
       );
@@ -99,0 +100,0 @@ }

orchestrator/QueryOrchestrator.js

@@ -5,8 +5,13 @@ const QueryCache = require('./QueryCache');
 class QueryOrchestrator {
-  constructor(redisPrefix, clientFactory, logger) {
+  constructor(redisPrefix, driverFactory, logger, options) {
+    options = options || {};
     this.redisPrefix = redisPrefix;
-    this.clientFactory = clientFactory;
+    this.driverFactory = driverFactory;
     this.logger = logger;
-    this.queryCache = new QueryCache(this.redisPrefix, this.clientFactory, this.logger);
-    this.preAggregations = new PreAggregations(this.redisPrefix, this.clientFactory, this.logger, this.queryCache);
+    this.queryCache = new QueryCache(
+      this.redisPrefix, this.driverFactory, this.logger, options.queryCacheOptions
+    );
+    this.preAggregations = new PreAggregations(
+      this.redisPrefix, this.driverFactory, this.logger, this.queryCache, options.preAggregationsOptions
+    );
   }
@@ -13,0 +18,0 @@

package.json

@@ -5,3 +5,3 @@ {
   "author": "Statsbot, Inc.",
-  "version": "0.0.8",
+  "version": "0.0.21",
   "engines": {
@@ -8,0 +8,0 @@ "node": ">=8.11.1"

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

No README

Quality

Package does not have a README. This may indicate a failed publish or a low quality package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

96619

increased by14.13%

Number of package files

12

increased by20%

Lines of code

1076

increased by0.65%

Number of medium quality alerts

0

decreased by-100%

Number of lines in readme file

10

increased byInfinity%

Published versions last week

1

increased byInfinity%

Worsened metrics

Number of downloads

16487

decreased by-4.45%

No dependency changes