devdave

import argparse

import sys
from importlib import import_module
from backtype.storm import Config, LocalCluster, StormSubmitter
#from tsync.examples.exclamation import get_topology_builder


def main(run_local=False):
    parser = argparse.ArgumentParser(description="Generate a single jar for Storm")

devdave

from uuid import uuid1
from time import time

def main():
    test = dict()
    limit = 10 ** 10
    while limit:
        limit -= 1
        x = {n:uuid1().hex for n in range(15)}
        if len(set(x.values())) != len(x.keys()):

devdave

#!/usr/bin/sh

set -e

sudo apt-get install openjdk-7-jdk git-core curl -y # Ubuntu 12.04 meets no problem

mkdir -p ~/bin
curl https://raw.github.com/technomancy/leiningen/preview/bin/lein > ~/bin/lein 
chmod 755 ~/bin/lein
# Add ~/bin to your $PATH, it has been done if in Ubuntu 12.04

devdave

tmux shortcuts & cheatsheet

start new:

tmux

start new with session name:

tmux new -s myname

devdave

"""
    requires the AWS ec2 command line tools are setup

    run this from the base directory of the ec2-tools install directory

    security groups provided by DotCloud
"""

groups = """admin-282171928639, gateway-282171928639, lxc-282171928639
admin-557344332487, gateway-557344332487, lxc-557344332487

devdave

/* 
 * File:   main.cpp
 * Author: dward
 *
 * Created on March 8, 2013, 8:13 AM
 */

#include <cstdlib>
#include <iostream>

devdave

if (!Function.prototype.bind) {
  Function.prototype.bind = function (oThis) {
    if (typeof this !== "function") {
      // closest thing possible to the ECMAScript 5 internal IsCallable function
      throw new TypeError("Function.prototype.bind - what is trying to be bound is not callable");
    }

    var aArgs = Array.prototype.slice.call(arguments, 1),
        fToBind = this,
        fNOP = function () {},

devdave

message KickStartRequest {
    enum WHOTYPE {
        CLIENT = 0;
        PRODUCER = 1;
        HUB = 2;
        CLIHUB = 3;
    }
    optional WHOTYPE whoami = 1 [default = CLIENT];
}

devdave

import time
import zmq
from zmq.eventloop import ioloop
from zmq.eventloop.zmqstream import ZMQStream

from dgbase.messages.kickstart import RequestKickstart
from dgbase.messages.kickstart import RespondWithKickstart

from functools import wraps, partial

devdave

class ReloaderEventHandler(FileSystemEventHandler):
    """
    Listen for changes to modules within the Django project
    On change, reload the module in the Python Shell

    Custom logic required to reload django models.py modules
    Due to the singleton AppCache, which caches model references.
    For those models files, we must clear and repopulate the AppCache
    """
    def __init__(self, *args, **kwargs):