indexing job data

Automattic · Jul 28, 2011 · 0efb444 · 0efb444
1 parent 7b39bdf
commit 0efb444
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/lib/queue/job.js b/lib/queue/job.js
@@ -12,6 +12,7 @@
 var EventEmitter = require('events').EventEmitter
   , events = require('./events')
   , pool = require('./pool')
+  , reds = require('reds')
   , noop = function(){};
 
 /**
@@ -20,6 +21,12 @@ var EventEmitter = require('events').EventEmitter
 
 exports = module.exports = Job;
 
+/**
+ * Search instance.
+ */
+
+var search = reds.createSearch('q:search');
+
 /**
  * Default job priority map.
  */
@@ -542,4 +549,7 @@ Job.prototype.update = function(fn){
 
   // data
   this.set('data', json, fn);
+
+  // search data
+  search.index(json, this.id);
 };