(feature) add redis options with leader election over redis for CronJob

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+.DS_Store

.travis.yml

@@ -0,0 +1,3 @@
+language: nodejs
+nodejs:
+  - iojs

index.js

@@ -0,0 +1 @@
+require('./lib/cron-cluster')

lib/cron-cluster.js

@@ -0,0 +1,27 @@
+
+var _ = require('lodash')
+var OriginCronJob = require('cron').CronJob
+var Leader = require('redis-leader')
+
+module.exports = function (redis) {
+  var leader = new Leader(redis)
+
+  return {
+    CronJob: CronJob
+  }
+
+  function CronJob (cronTime, onTick) {
+    if (typeof cronTime !== 'string' && arguments.length === 1) {
+      onTick = cronTime.onTick
+    }
+
+    onTick = _.wrap(onTick, function (fn) {
+      leader.isLeader(function (isLeader) {
+        if (!isLeader) return
+        fn()
+      })
+    })
+
+    return new (OriginCronJob.bind.apply(OriginCronJob, arguments))
+  }
+}

package.json

@@ -0,0 +1,23 @@
+{
+  "name": "cron-cluster",
+  "version": "0.0.1",
+  "description": "A Cluster plugin for cron using redis",
+  "main": "index.js",
+  "directories": {
+    "test": "test"
+  },
+  "scripts": {
+    "test": "tap test/*.js | faucet"
+  },
+  "author": "Andy Vanbutsele <[email protected]>",
+  "license": "ISC",
+  "dependencies": {
+    "cron": "^1.0.9",
+    "lodash": "^3.10.1",
+    "redis-leader": "^0.1.0"
+  },
+  "devDependencies": {
+    "faucet": "0.0.1",
+    "tap": "^1.4.0"
+  }
+}

test/cron-cluster.js

@@ -0,0 +1,6 @@
+var test = require('tap').test
+
+test('Should do something', function (t) {
+  t.plan(1)
+  t.equal(1, 1, '1 == 1')
+})