README.md

@@ -14,48 +14,29 @@ Install
 =======
 
 ```
-npm install --save cluster-store@2.x
+npm install --save memstore-cluster@2.x
 ```
 
 v1.x vs v2.x
 ------------
 
-The [old v1](https://github.com/coolaj86/cluster-store/tree/v1.x)
+The old v1 used `ws` which makes it usable when clustering node processes without using `cluster`.
-used `ws` which makes it usable when clustering node processes without using `cluster`.
 
-If you need that functionaliy, use v1 instead of v2.
+If you need that functionaliy, use it.
 
 Usage
 =====
 
-In its simplest form, you use this module nearly exactly the way you would
-the any other storage module, with the exception that you must wait for
-the inter-process initialization to complete.
-
-When not using any of the options the usage is the same for the master and the worker:
-
-```javascript
-require('cluster-store').create().then(function (store) {
-  // initialization is now complete
-  store.set('foo', 'bar');
-});
-```
-
 ### standalone (non-cluster)
 --------------
 
-There is no disadvantage to using this module standalone.
+The usage is exactly the same as **master**, no changes necessary.
-The additional overhead of inter-process communication is only added when
-a worker is added.
-
-As such, the standalone usage is identical to usage in master process, as seen below.
 
 ### master
 
-In the **master** process you will create the real store instance.
+In the **master**/**standalone** process you will create the real store instance
-
+and then in the you must pass each worker via `addWorker()` so that it signals
-If you need to manually specify which worker will be enabled for this funcitonality
+the worker to create its own rpc-wrapped instance.
-you must set `addOnFork` to `false` and call `addWorker()` manually.
 
 ```javascript
 'use strict';
@@ -63,25 +44,16 @@ you must set `addOnFork` to `false` and call `addWorker()` manually.
 var cluster = require('cluster');
 
 var cstore = require('cluster-store/master').create({
-  name: 'foo-store'       // necessary when using multiple instances
+  name: 'foo-store'
-, store: null             // use default in-memory store
-, addOnFork: true         // default
 });
 
-// if you addOnFork is set to false you can add specific forks manually
+cstore.addWorker(cluster.fork());
-//cstore.addWorker(cluster.fork());
 
 cstore.then(function (store) {
   store.set('foo', 'bar');
 });
 ```
 
-Note: `store` can be replaced with any `express/session`-compatible store, such as:
-
-  * `new require('express-session/session/memory')()`
-  * `require('level-session-store')(session)`
-  * and others
-
 ### worker
 
 ```javascript
@@ -131,21 +103,46 @@ Example
 'use strict';
 
 var cluster = require('cluster');
+var cstore;
 
-require('cluster-store').create({
-  name: 'foo-store'
-}).then(function (store) {
-  if (cluster.isMaster) {
-    store.set('foo', 'bar');
-  }
-
-  store.get('foo', function (err, result) {
-    console.log(result);
-  });
-});
 
 if (cluster.isMaster) {
-  cluster.fork();
+
-  cluster.fork();
+
+  cstore = require('./master').create({
+    name: 'foo-level'
+  });
+  cstore.addWorker(cluster.fork());
+  cstore.then(function (store) {
+    store.put('foo', 'bar');
+  });
+
+
 }
+else {
+
+
+  cstore = require('./worker').create({
+    name: 'foo-level'
+  });
+
+
+}
+
+
+cstore.then(function (store) {
+  setTimeout(function () {
+    store.get('foo', function (err, result) {
+      console.log(cluster.isMaster && '0' || cluster.worker.id.toString(), "store.get('foo')", result);
+
+      if (!cluster.isMaster) {
+        process.exit(0);
+      }
+    });
+  }, 250);
+});
+
+process.on('unhandledRejection', function (err) {
+  console.log('unhandledRejection', err);
+});
 ```

index.js

@@ -1,9 +1,12 @@
 'use strict';
 
-var cluster = require('cluster');
+console.error("");
+console.error("One does not simply require('memstore-cluster');");
+console.error("");
+console.error("Usage:");
+console.error("\trequire('memstore-cluster/master').create({ name: ... });");
+console.error("\trequire('memstore-cluster/worker').create({ name: ... });");
+console.error("");
+console.error("");
 
-if (cluster.isMaster) {
+process.exit(1);
-  module.exports = require('./master');
-} else {
-  module.exports = require('./worker');
-}

master.js

@@ -14,6 +14,5 @@ module.exports.create = function (opts) {
     ]
   , name: 'memstore.' + (opts.name || '')
   , master: opts.master
-  , addOnFork: opts.addOnFork
   });
 };

package.json

@@ -1,8 +1,7 @@
 {
   "name": "cluster-store",
-  "version": "2.0.8",
+  "version": "2.0.0",
   "description": "A wrapper to enable the use of any in-process store with node cluster via cluster process and worker messages (i.e. for Raspberry Pi servers).",
-  "homepage": "https://git.coolaj86.com/coolaj86/cluster-store.js",
   "main": "index.js",
   "scripts": {
     "test": "node test-cluster.js",
@@ -10,10 +9,8 @@
   },
   "repository": {
     "type": "git",
-    "url": "git+https://git.coolaj86.com/coolaj86/cluster-store.js.git"
+    "url": "git+https://github.com/coolaj86/cluster-store.git"
   },
-  "bundleDependencies": false,
-  "deprecated": false,
   "keywords": [
     "store",
     "session",
@@ -23,16 +20,13 @@
     "cluster",
     "rpi2"
   ],
-  "author": {
+  "author": "AJ ONeal <coolaj86@gmail.com> (http://coolaj86.com/)",
-    "name": "AJ ONeal",
-    "email": "coolaj86@gmail.com",
-    "url": "https://coolaj86.com/"
-  },
   "license": "Apache-2.0",
   "bugs": {
-    "url": "https://git.coolaj86.com/coolaj86/cluster-store.js/issues"
+    "url": "https://github.com/coolaj86/cluster-store/issues"
   },
+  "homepage": "https://github.com/coolaj86/cluster-store#readme",
   "dependencies": {
-    "cluster-rpc": "^v1.0.6"
+    "cluster-rpc": "^1.0.3"
   }
 }

simplest.js

@@ -1,26 +0,0 @@
-'use strict';
-
-var cluster = require('cluster');
-var cstore;
-
-require('./').create({
-  name: 'foo-store'
-}).then(function (store) {
-  if (cluster.isMaster) {
-    cluster.fork();
-    cluster.fork();
-
-    store.set('foo', 'bar');
-  }
-
-  store.get('foo', function (err, result) {
-    console.log(cluster.isMaster && '0' || cluster.worker.id.toString(), 'foo', result);
-    if (!cluster.isMaster) {
-      process.exit(0);
-    }
-  });
-});
-
-process.on('unhandledRejection', function (err) {
-  console.log('unhandledRejection', err);
-});

test.js

@@ -11,13 +11,11 @@ if (cluster.isMaster) {
   cstore = require('./master').create({
     name: 'foo-level'
   });
+  cstore.addWorker(cluster.fork());
   cstore.then(function (db) {
     db.set('foo', 'bar');
   });
 
-  cluster.fork();
-  cluster.fork();
-
 
 }
 else {