keuss - npm Package Compare versions

Comparing version 0.0.3 to 0.0.4

AsyncQueue.js

@@ -43,3 +43,2 @@ 'use strict';
     this._stats.incr ('put', 0);
-//    this._stats.incr ('consumers', 0);
   }
@@ -206,8 +205,7 @@
       consumer_data.cleanup_timeout = setTimeout (function () {
-        self._verbose  ('get: timed out %d msecs on consumer %s', opts.timeout, cid);
+        self._verbose ('get: timed out %d msecs on consumer %s', opts.timeout, cid);
 
         consumer_data.callback = null;
         self._consumers_by_tid.delete (consumer_data.tid);
-//        self._stats.decr ('consumers');
-        
+
         callback ({
@@ -224,3 +222,2 @@ timeout: true,
     this._consumers_by_tid.set (tid, consumer_data);
-//    this._stats.incr ('consumers');
     
@@ -281,3 +278,2 @@ this._verbose  ('get: added consumer %s (tid %s)', consumer_data.cid, consumer_data.tid);
       this._consumers_by_tid.delete (tid);
-//      this._stats.decr ('consumers');
       
@@ -284,0 +280,0 @@ this._verbose  ('cancel: cancelled %s. consumers left waiting: %d, total consumers: %d', tid, this._consumers_by_order.length, this.nConsumers ());

backends/redis-oq.js

@@ -93,2 +93,5 @@ 'use strict';
         var pl = JSON.parse (res[2]);
+
+        // TODO check res has 2, and parses as json
+
         pl.mature = new Date (parseInt (res[1]));
@@ -95,0 +98,0 @@ pl._id = res[0];

package.json

 {
   "name": "keuss",
-  "version": "0.0.3",
+  "version": "0.0.4",
   "keywords": ["queue", "job"],
@@ -5,0 +5,0 @@ "homepage":"https://github.com/pepmartinez/keuss",

public/javascripts/base.js

@@ -5,9 +5,3 @@
 
-/////////////////////////////////////////
-function load_last_refresh (){
-/////////////////////////////////////////
-  $('#last-refresh').html (new Date().toTimeString());
-}
 
-
 function getTimeDelta (ts) {
@@ -56,14 +50,2 @@ if ((ts == null) || (ts == undefined)) {
 /////////////////////////////////////////
-function autoRefresh() {
-/////////////////////////////////////////
-  window.setTimeout(function() {
-    if (autorefresh) {
-      refresh()
-    }
-    autoRefresh();
-    }, 15000);
-}
-
-
-/////////////////////////////////////////
 $(function() {
@@ -80,14 +62,2 @@ /////////////////////////////////////////
   
-  $('#autorefresh-btn').click(function( eventObject ) {
-    console.log ('autorefresh-btn clicked');
-    var btn = $('#autorefresh-btn');
-    if (autorefresh) {
-      autorefresh = false;
-      btn.html ('Enable Autorefresh');
-    } else {
-      autorefresh = true;
-      btn.html ('Disable Autorefresh');
-    }
-  });
-  
   $('#qtable')
@@ -99,4 +69,2 @@ .on ('error.dt', function ( e, settings, techNote, message ) {
   .on ('xhr.dt', function (e, settings, json, xhr ) {
-    load_last_refresh();
-    
     if (xhr.status != 200) {
@@ -122,3 +90,2 @@ var xhr_txt = 'readyState: ' + xhr.readyState +
     columns: [
-      {data: 'type'},
       {data: 'id'},
@@ -125,0 +92,0 @@ {data: 'stats.put', defaultContent: '-'},

test/WithLog.js

@@ -47,3 +47,3 @@ 'use strict';
     
-    fl.called().should.equal(3);
+    fl.called().should.equal(4);
   });
@@ -104,3 +104,3 @@
     
-    fl.called().should.equal(3);
+    fl.called().should.equal(4);
   });
@@ -118,4 +118,4 @@
     
-    fl.called().should.equal(3);
+    fl.called().should.equal(4);
   });
 });

utils/WithLog.js

@@ -16,3 +16,3 @@ 'use strict';
     this._logger = this._opts.logger;
-    this._level = this._opts.level || LEVELS.info;
+    this._level = this._opts.level || LEVELS.verbose;
   }
@@ -19,0 +19,0 @@

No alert changes

Improved metrics

Total package byte prevSize

143019

increased by0.5%

Number of package files

38

increased by5.56%

Lines of code

3179

increased by1.08%

No dependency changes