Elliott Wood ewoodh2o

Design Goals

Scribe has a single listener, with multiple clients sending it data (multiple Tabs unicorns, etc)
If Scribe goes down temporarily, messages should queue on the client and be delivered when it comes back.
If Scribe is down for a long time, the client should throw away messages rather than exhausting its RAM.
If Scribe is down and the client terminates, it shouldn't wait around forever trying to deliver messages.

In the code below, pub.rb goes in the Scribe client gem and gets installed in Tabs, etc, with a similar thing in Deejay. The sub.rb piece is part of Scribe.

Bash-Style Curly Brace Expansion

Expands the curly-brace notation as supported by Bash.

expand "ab{c,d}e"
  => [ "abce", "abde" ]

expand "ab{c,d}e{1,2}"
 =&gt; [ "abce1", "abce2", "abde1", "abde2" ]

Loading Metrics from a Database

Given the following database schema:

| page_metrics                                         |
+------------------------------------------------------+
| id | page_id | date       | fans | comments | clicks |
+----+---------+------------+------+----------+--------+
| 11 |     123 | 2012-08-01 | 1750 |       23 |    103 |

	SIZING_METHODS = {:enable_images? => :resize, :enable_videos? => :encode}

	def size_upload
	result = {:export => {use: []}}

	return result unless self.uploads_enabled?

	['', '_thumb'].each do \|insert\|
	w = "upload#{insert}_width".to_sym
	w? = "#{w}?".to_sym

	def upload_sizing
	result = {}

	if uploads_enabled?
	dims = lambda {\|size\| send("upload#{size}_width?") && send("upload#{size}_width?") ?
	{ width: send("upload#{size}_width"), height: send("upload#{size}_width") } : nil
	}

	{:enable_images? => :resize, :enable_videos? => :encode}.each do \|method, result_key\|
	['', '_thumb'].each do \|size\|

	module ChronicleClient
	class FirstMock < ChronicleClient::Mock
	def self.response_for(query)
	return nil if query.client != '0'

	if query.params[:tags].include?("page_active_users")
	return ChronicleClient::Response.mock(
	:highcharts_array => [[1307592000000, 10000000], [1307678400000, 10014000], [1307764800000, 10027000], [1307851200000, 10035000], [1307937600000, 10059000], [1308024000000, 10078000], [1308110400000, 10087000]]
	)
	end

	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
	;; emacs configuration
	;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
	(nconc load-path (list "~/.emacs.d/el-get/el-get"))

	(require 'package)
	(setq exec-path (cons "/usr/local/git/bin/" exec-path))

	(unless (require 'el-get nil t)
	(with-current-buffer

	# Solves Stanford's SAAS anagram question
	# http://spark-university.s3.amazonaws.com/berkeley-saas/homework/hw1.pdf
	# Question 3

	def combine_anagrams(words)

	# Set up a hash to hold the groups:
	# Keys will be the sorted anagram string
	# Values will be the array of anagrams for that string
	# Hash works well here because it's a fast lookup on

	source 'http://rubygems.org'

	gem 'rails', '3.0.10'

	# ... include whatever you need, but the following is pertinent
	gem 'fb_graph'

	require 'rubygems'
	require 'zmq'

	context = ZMQ::Context.new

	# Start listening
	pull = context.socket(ZMQ::PULL)
	pull.bind("tcp://127.0.0.1:5555")

	# Get updates, exit on ^C