boltzj

var fs = require('fs');
var StringDecoder = require('string_decoder').StringDecoder;
var Transform = require('stream').Transform;
var util = require('util');

util.inherits(DatasetParser, Transform);

function DatasetParser(options) {
    if (!(this instanceof DatasetParser))
        return new DatasetParser(options);

boltzj

var AWS = require('aws-sdk');
var _ = require('lodash');

AWS.config.update({
  accessKeyId: 'FIXME',
  secretAccessKey: 'FIXME'
});

var route53 = new AWS.Route53();

boltzj

var zmq = require('zmq');

/**
 * Publish Message to Subscriber
 */
var publisher = zmq.socket('pub');
publisher.bind('tcp://*:8688', function(err) {
    if (err) {
        return console.log(err);
    }