Worker pools

.eslintrc

@@ -18,6 +18,9 @@
     "mocha": true
   },
   "parserOptions": {
-    "ecmaVersion": 2017
+    "ecmaVersion": 2017,
+    "ecmaFeatures": {
+      "experimentalObjectRestSpread": true
+    }
   }
 }

bin/luster.js

@@ -1,7 +1,10 @@
 #!/usr/bin/env node
 const /** @type {ClusterProcess} */
     luster = require('../lib/luster'),
-    path = require('path'),
-    configFilePath = path.resolve(process.cwd(), process.argv[2] || 'luster.conf');
+    path = require('path');
+
+// config path is right after this script in process.argv
+const scriptArgvIndex = process.argv.findIndex(arg => arg === __filename || path.resolve(arg) === __filename);
+const configFilePath = path.resolve(process.cwd(), process.argv[scriptArgvIndex + 1] || 'luster.conf');
 
 luster.configure(require(configFilePath), true, path.dirname(configFilePath)).run();

lib/cluster_process.js

@@ -7,6 +7,8 @@ const cluster = require('cluster'),
     LusterClusterProcessError = require('./errors').LusterClusterProcessError,
     LusterConfigurationError = require('./errors').LusterConfigurationError;
 
+const pEvent = require('p-event');
+
 /**
  * @param {Object} context
  * @param {String} propName
@@ -59,9 +61,7 @@ class ClusterProcess extends EventEmitterEx {
          * @type Promise<void>
          * @private
          * */
-        this._initPromise = new Promise(resolve => {
-            this.once('initialized', resolve);
-        });
+        this._initPromise = pEvent(this, 'initialized');
 
         /**
          * @type {Configuration}
@@ -110,6 +110,15 @@ class ClusterProcess extends EventEmitterEx {
      * @public
      */
     configure(config, applyEnv, basedir) {
+        this._setConfig(config, applyEnv, basedir);
+        if (this.config) {
+            this.emit('configured');
+        }
+
+        return this;
+    }
+
+    _setConfig(config, applyEnv, basedir) {
         if (typeof applyEnv === 'undefined' || applyEnv) {
             Configuration.applyEnvironment(config);
         }
@@ -128,11 +137,7 @@ class ClusterProcess extends EventEmitterEx {
             // hack to tweak underlying EventEmitter max listeners
             // if your luster-based app extensively use luster events
             this.setMaxListeners(this.config.get('maxEventListeners', 100));
-
-            this.emit('configured');
         }
-
-        return this;
     }
 
     /**

lib/configuration/index.js

@@ -20,6 +20,10 @@ class Configuration {
         Object.assign(this._rawConfig, config);
     }
 
+    get raw() {
+        return this._rawConfig;
+    }
+
     /**
      * @param {String} path
      * @param {*} [defaultValue]
@@ -93,6 +97,16 @@ class Configuration {
             config;
     }
 
+    extend(config) {
+        return new Configuration(
+            {
+                ...this.raw,
+                ...config,
+            },
+            this._resolveBaseDir,
+        );
+    }
+
     /**
      * Override config properties using `LUSTER_CONF` environment variable.
      *

lib/errors.js

@@ -94,4 +94,26 @@ errors.LusterPortError = LusterError.create('LusterPortError',
             'Can not unlink unix socket "%socketPath%"'
     });
 
+/**
+ * @constructor
+ * @class LusterMasterError
+ * @augments LusterError
+ */
+errors.LusterMasterError = LusterError.create('LusterMasterError',
+    {
+        POOL_KEY_ALREADY_TAKEN:
+            'Pool key "%key%" is already taken'
+    });
+
+/**
+ * @constructor
+ * @class LusterMasterError
+ * @augments LusterError
+ */
+errors.LusterMasterError = LusterError.create('LusterMasterError',
+    {
+        POOL_DOES_NOT_EXIST:
+            'Pool with key "%key%" does not exist'
+    });
+
 module.exports = errors;

lib/event_emitter_ex.js

@@ -17,7 +17,9 @@ if (process.env.NODE_DEBUG && /luster:eex/i.test(process.env.NODE_DEBUG)) {
     EventEmitterEx.prototype.emit = function(...args) {
         const inspectedArgs = args.map(inspect).join(', ');
 
-        console.log('%s(%s).emit(%s)', this.constructor.name || 'EventEmitterEx', this.wid, inspectedArgs);
+        const key = this.eexKey;
+
+        console.log('%s(%s).emit(%s)', this.constructor.name || 'EventEmitterEx', key, inspectedArgs);
 
         return EventEmitter.prototype.emit.apply(this, args);
     };