calvinfo

var helenus = require('helenus');

pool = new helenus.ConnectionPool({
  hosts      : ['localhost:9160'],
  keyspace   : 'segmentio',
  timeout    : 3000
});

pool.on('error', function(err){
  console.error(err.name, err.message);

calvinfo

var _       = require('underscore'),
    rabbit  = require('rabbit-pool'),
    logging = require('logging')(module);


var exchange,
    handlers = {},
    messages = [];

calvinfo

{
	"alignment_chars":
	[
		"=",
		":"
	],
	"alignment_prefix_chars":
	[
		"+",
		"-",

calvinfo

{

    "sublimelinter": "load-save",

   "jshint_options":
    {
        "browser": true,
        "eqeqeq": true,
        "evil": true,
        "expr": true,

calvinfo

error_handler = Proc.new { |status, msg| print status, msg }

Analytics.init(secret: "mysecret", on_error: error_handler)

calvinfo

(function () {
  var traits  = analytics.user.traits()
    , session = traits.session
    , now     = +(new Date); // shim for Date.now in older browsers

  if (!session || (now - session) > 60*60*1000) {

    // Track things which happen once a session
    analytics.track('Once a session');

calvinfo

analytics.ready(function() {
  if ($("#mixpanel_distinct_id").length > 0) {
    var interval = setInterval(function () {
      if (window.mixpanel.get_distinct_id) {
        $("#mixpanel_distinct_id").val(window.mixpanel.get_distinct_id());
        clearInterval(interval);
      }
    }, 300);
  }
});

calvinfo

function subscribe(queue) {
  logger.info('API logger queue created.');
  queue.bind('ingestion', '#');

  var options = { ack : true, prefetchCount : 1000 };

  queue.subscribe(options, function (payload, headers, deliveryInfo, message) {
    importer.log(payload, function (err) {
      try {
        if (err) message.reject(true); // requeue the message

calvinfo

var columnName = ['prefix', 'suffix']
  , value      = 'val'
  , timestamp  = new Date()
  , column     = new helenus.Column(columName, value, timestamp);

cf.insert(rowKey, column, options, callback);

calvinfo

var fs = require('fs')
  , stream = require('stream');


function Through () {
  this.processed = 0;
}
Through.prototype = new stream.Transform();

function End () {}