kinetik - npm Package Compare versions

Comparing version 0.2.1 to 0.3.0

History.md

 
+0.3.0 / 2012-09-04 
+==================
+
+  * Merge branch 'feature/idris'
+  * remove reference to internal utils
+  * remove ms util
+  * add idris to deps
+  * refactor cli deps into middleware folder
+  * refactor queue._tasks as queue.tasks. Closes #21
+  * update docs
+
 0.2.1 / 2012-07-11 
@@ -3,0 +14,0 @@ ==================

lib/kinetik.js

@@ -30,3 +30,3 @@ /*!
 
-exports.version = '0.2.1';
+exports.version = '0.3.0';
 
@@ -33,0 +33,0 @@ /*!

lib/kinetik/middleware/cli.js

@@ -18,3 +18,3 @@ /*!
 module.exports = function () {
-  var program = require('../cli')
+  var program = require('./cli')
     , path = require('path');
@@ -21,0 +21,0 @@

lib/kinetik/queue.js

@@ -11,6 +11,6 @@ /*!
 
-var Seed = require('seed')
-  , debug = require('debug')('kinetik:queue')
+var debug = require('debug')('kinetik:queue')
+  , idris = require('idris')
+  , Seed = require('seed')
   , util = require('util')
-  , _ = require('./util');
 
@@ -89,6 +89,6 @@ /*!
   // defaults
-  this._tasks = new Seed.Hash(null, { findRoot: '_attributes' });
+  this.tasks = new Seed.Hash(null, { findRoot: '_attributes' });
   this._opts = {
       wait: 0
-    , interval: opts.interval || _.ms('10s')
+    , interval: opts.interval || idris.ms('10s')
   };
@@ -120,3 +120,3 @@ }
       var tags = [];
-      this._tasks.each(function (task) {
+      this.tasks.each(function (task) {
         var tag = task.get('tag');
@@ -201,3 +201,3 @@ if (tag && !~tags.indexOf(tag))
   var task = new Task({ name: name });
-  this._tasks.set(name, task);
+  this.tasks.set(name, task);
   this.emit([ 'task', 'define' ], task);
@@ -260,3 +260,3 @@ debug('new task defined: %s', name);
     if (attrs.status == 'delayed') {
-      attrs.delay = attrs.created + _.ms(delay);
+      attrs.delay = attrs.created + idris.ms(delay);
     }
@@ -321,3 +321,3 @@
     , interval = int
-      ? _.ms(int)
+      ? idris.ms(int)
       : this._opts.interval;
@@ -454,3 +454,3 @@
       if (err) return handleErr(err);
-      var task = self._tasks.get(job.get('task'));
+      var task = self.tasks.get(job.get('task'));
       if (task) task.emit('cancelled', job);
@@ -515,3 +515,3 @@ cb(null);
   var self = this
-    , tasks = this._tasks
+    , tasks = this.tasks
     , jobQuery = Array.isArray(opts.status)
@@ -524,3 +524,3 @@ ? { status: { $in: opts.status } }
     jobQuery.task = { $in: [] };
-    tasks = this._tasks
+    tasks = this.tasks
       .find({ tag: { $in: opts.tags }})
@@ -593,5 +593,5 @@ .each(function (task) {
       store: this._store
-    , tasks: this._tasks
+    , tasks: this.tasks
     , queue: this
   });
 }

lib/kinetik/seed/processor.graph.js

@@ -60,3 +60,3 @@ /*!
       this.queue = opts.queue;
-      this.tasks = opts.tasks || this.queue._tasks;
+      this.tasks = opts.tasks || this.queue.tasks;
       this.define(Job);
@@ -63,0 +63,0 @@ this.define(Log);

lib/kinetik/seed/task.model.js

@@ -11,10 +11,5 @@ /*!
 
-var Seed = require('seed');
+var idris = require('idris')
+  , Seed = require('seed');
 
-/*!
-   * Kinetik dependancies
- */
-
-var _ = require('../util');
-
 /**
@@ -156,3 +151,3 @@ * ## Task API
   , timeout: function (n) {
-      var time = _.ms(n);
+      var time = idris.ms(n);
       this.set('timeout', time);
@@ -243,3 +238,3 @@ return this;
       this.set('maxRetry', maxRetry);
-      this.set('retryDelay', _.ms(retryDelay));
+      this.set('retryDelay', idris.ms(retryDelay));
       return this;
@@ -246,0 +241,0 @@ }

package.json

@@ -5,3 +5,3 @@ {
   , "description": "A storage-agnostic, tag centric job queue for distributed applications."
-  , "version": "0.2.1"
+  , "version": "0.3.0"
   , "repository": {
@@ -19,5 +19,6 @@ "type": "git"
   , "dependencies": {
-        "seed": "0.4.x"
+        "debug": "*"
       , "electron": "0.2.x"
-      , "debug": "*"
+      , "idris": "0.2.x"
+      , "seed": "0.4.x"
     }
@@ -24,0 +25,0 @@ , "devDependencies": {

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

Worsened metrics

Total package byte prevSize

334206

decreased by-0.12%

Dependency count

4

increased by33.33%

Number of package files

61

decreased by-1.61%

Lines of code

2813

decreased by-0.99%

Dependency changes

• + Addedidris@0.2.x

• + Addedidris@0.2.0(transitive)