ewhauser

#!/usr/bin/env ruby

require 'rubygems'
require 'getoptlong'
require 'socket'
require 'json'
require 'timeout'
require 'open-uri'

host = "localhost"

ewhauser

package org.apache.flume.kafka;

import com.cloudera.flume.core.Event;
import com.cloudera.flume.core.EventImpl;
import com.cloudera.util.Clock;
import kafka.api.FetchRequest;
import kafka.javaapi.consumer.SimpleConsumer;
import kafka.message.Message;
import kafka.server.KafkaConfig;
import kafka.server.KafkaServer;

ewhauser

package com.exacttarget.bloomin.jedis;

import com.google.common.base.Preconditions;
import com.twitter.common.net.pool.Connection;
import redis.clients.jedis.Jedis;

public class JedisConnection implements Connection<Jedis, Jedis> {

  private final Jedis jedis;

ewhauser

# Use csshX to open terminals on the nodes found in a search
# knife exec csshx.rb 'role:the_role'

abort("usage: knife exec csshx SEARCH_TERM") unless ARGV[2]

nodes = search(:node, "#{ARGV[2].to_s}").collect { |n| n.fqdn }
exec('csshX ' + nodes.join(' ')) unless nodes.length < 1

exit 0