update .gitignore

node_modules/pm2-axon/lib/plugins/queue.js

@@ -0,0 +1,71 @@
+
+/**
+ * Module dependencies.
+ */
+
+var debug = require('debug')('axon:queue');
+
+/**
+ * Queue plugin.
+ *
+ * Provides an `.enqueue()` method to the `sock`. Messages
+ * passed to `enqueue` will be buffered until the next
+ * `connect` event is emitted.
+ *
+ * Emits:
+ *
+ *  - `drop` (msg) when a message is dropped
+ *  - `flush` (msgs) when the queue is flushed
+ *
+ * @param {Object} options
+ * @api private
+ */
+
+module.exports = function(options){
+  options = options || {};
+
+  return function(sock){
+
+    /**
+     * Message buffer.
+     */
+
+    sock.queue = [];
+
+    /**
+     * Flush `buf` on `connect`.
+     */
+
+    sock.on('connect', function(){
+      var prev = sock.queue;
+      var len = prev.length;
+      sock.queue = [];
+      debug('flush %d messages', len);
+
+      for (var i = 0; i < len; ++i) {
+        this.send.apply(this, prev[i]);
+      }
+
+      sock.emit('flush', prev);
+    });
+
+    /**
+     * Pushes `msg` into `buf`.
+     */
+
+    sock.enqueue = function(msg){
+      var hwm = sock.settings.hwm;
+      if (sock.queue.length >= hwm) return drop(msg);
+      sock.queue.push(msg);
+    };
+
+    /**
+     * Drop the given `msg`.
+     */
+
+    function drop(msg) {
+      debug('drop');
+      sock.emit('drop', msg);
+    }
+  };
+};

node_modules/pm2-axon/lib/plugins/round-robin.js

@@ -0,0 +1,55 @@
+
+/**
+ * Deps.
+ */
+
+var slice = require('../utils').slice;
+
+/**
+ * Round-robin plugin.
+ *
+ * Provides a `send` method which will
+ * write the `msg` to all connected peers.
+ *
+ * @param {Object} options
+ * @api private
+ */
+
+module.exports = function(options){
+  options = options || {};
+  var fallback = options.fallback || function(){};
+
+  return function(sock){
+
+    /**
+     * Bind callback to `sock`.
+     */
+
+    fallback = fallback.bind(sock);
+
+    /**
+     * Initialize counter.
+     */
+
+    var n = 0;
+
+    /**
+     * Sends `msg` to all connected peers round-robin.
+     */
+
+    sock.send = function(){
+      var socks = this.socks;
+      var len = socks.length;
+      var sock = socks[n++ % len];
+
+      var msg = slice(arguments);
+
+      if (sock && sock.writable) {
+        sock.write(this.pack(msg));
+      } else {
+        fallback(msg);
+      }
+    };
+
+  };
+};