// use mongo for storing tasks
var katarDb = require('katar-mongodb')('localhost/queue');
// initialise a katar server
var katar = require('katar')({ db: katarDb });
// create a data queue that fetches data from a url
var dataQueue = katar.queue('fetch-data');
// create a youtube queue that downloads videos from youtube
    // this queue is persistent - this means once a task is completed, it is retained in the database for historical reasons
var ytQueue = katar.queue('youtube', { persistent: true });
 
// insert a data task
dataQueue.insert({
    data: 'http://api.hawktrack.com/countries'
});
 
// insert a data task with high priority
    // supported values - HIGH, MEDIUM, LOW
dataQueue.insert({
    data: 'http://api.hawktrack.com/carriers',
    priority: katar.constants.priority.HIGH
});
 
// insert a youtube request with an object data type
    // all data types supported by the data adapter are supported as data is passed straight to the adapter
ytQueue.insert({
    data: {
        url: 'https://www.youtube.com/watch?v=fiJm4Zy8i-U',
        res: '720p'
    }
});
 
// create a http server that workers can poll and fetch jobs
    // server is a koa-framework object
var workerServer = require('katar-worker-http')({
    katar: katar,
    port: 3000
});
 
// add any custom routes as needed
    // see koa-framework npm module for usage
workerServer.api.v1.router.get('/hello', function *() {
    this.body = { hello: 'world' };
});