Skip to content
This repository has been archived by the owner on Dec 5, 2018. It is now read-only.

Commit

Permalink
feat(server): enable work queue priority levels
Browse files Browse the repository at this point in the history
Most of the work for this was done in #363, just wrapping it up.
  • Loading branch information
jaredhirsch committed Mar 2, 2015
1 parent 3a31ac3 commit 443cc07
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
3 changes: 1 addition & 2 deletions server/controllers/visits.js
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ var visitsController = {
var p = request.payload;
var userId = request.auth.credentials;

var created = visitsController._create(userId, p.url, p.title, p.visitedAt, p.visitId);
var created = visitsController._create(userId, p.url, p.title, p.visitedAt, p.visitId, p.priority);
reply(visitsView.render(created));
},
bulk: function(request, reply) {
Expand All @@ -62,7 +62,6 @@ var visitsController = {
},
_create: function(userId, url, title, visitedAt, visitId, priority) {
visitId = visitId || uuid.v4();
priority = priority || 'regular';
var urlHash = crypto.createHash('sha1').update(url).digest('hex').toString();
var data = {
userId: userId,
Expand Down
10 changes: 6 additions & 4 deletions server/work-queue/queue.js
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,9 @@ _queue.on('job progress', onJobProgress);


// TODO allow job creation to set priorities; we're setting priority here for the moment
// opts := job data object
// opts := { priority, data }
// priority := 'low' | 'normal' | 'medium' | 'high' | 'critical'
// data := data passed to the worker to run the job
var exported = {
enqueue: function(job, data, priority) {
log.debug(job + '.called');
Expand All @@ -129,13 +131,13 @@ var exported = {
.save();
},
createVisit: function(opts) {
exported.enqueue('createVisit', opts, 'high');
exported.enqueue('createVisit', opts.data, opts.priority || 'high');
},
extractPage: function(opts) {
exported.enqueue('extractPage', opts, 'medium');
exported.enqueue('extractPage', opts.data, opts.priority || 'medium');
},
sendWelcomeEmail: function(opts) {
exported.enqueue('sendWelcomeEmail', opts, 'low');
exported.enqueue('sendWelcomeEmail', opts.data, opts.priority || 'low');
}
};

Expand Down

0 comments on commit 443cc07

Please sign in to comment.