Job Queue

Work in progress. The API should look like:

queue.register { step: 'postproc' },
  # attributes that comprise the job ID; requests with identical IDs are merged into a single job
  id: ['project', 'step']

  # merge oldRequest into newRequest; by default, all array attributes are merged;
  # ID attributes are guaranteed to be equal
  merge: (newRequest, oldRequest) ->

  execute: (request, emit) ->
    @add type: 'warning', file: '/foo'
    @done null

queue.add { project: @project.id, step: 'postproc', paths: paths }

# value triggering (remove existing jobs with this scope, then add new ones)
queue.update { project: @project.id, step: 'postproc' }, { paths: [paths] }
queue.update { project: @project.id, step: 'compile' }, [{src: '/path/to/src'}, {src: '/another/src'}]

queue.cancel { project: @project.id }

Work in progress.

License

Copyright 2012, Andrey Tarantsov. Distributed under the MIT license.