Bernd Ahlers bernd

Actors

This is a proof-of-concept of a couple of concurrent data structures written in Ruby.

The implementations are heavily commented for those interested. There are benchmarks (with results) included below. The results are interesting, but, as always, take with a grain of salt.

Data structures

AtomicLinkedQueue is a lock-free queue, built on atomic CAS operations.

logstash queries graphed with graphite.

Operation: Decouple whisper from graphite.

Method: Create a graphite function that does a date histogram facet query against elasticsearch for a given query string for the time period viewed in the current graph.

Reason: graphite has some awesome math functions. Wouldn't it be cool if we could use those on logstash results?

The screenshot below is using logstash to watch the twitter stream of keywords "iphone" "apple" and "samsung" - then I graph them each, so we get an idea of popularity. As a bonus, I also do a movingAverage() on the iphone curve to show you why this is awesome.

Locate the section for your github remote in the .git/config file. It looks like this:

[remote "origin"]
	fetch = +refs/heads/*:refs/remotes/origin/*
	url = [email protected]:joyent/node.git

Now add the line fetch = +refs/pull/*/head:refs/remotes/origin/pr/* to this section. Obviously, change the github url to match your project's URL. It ends up looking like this:

	require 'simplecov'
	SimpleCov.command_name "acceptance"

	ENV["RAILS_ENV"] \|\|= 'test'
	require File.expand_path("../../config/environment", __FILE__)
	require 'rspec/rails'
	require 'rspec/autorun'

	require 'capybara/rails'
	require 'capybara/poltergeist'

	# unicorn

	description "unicorn ruby app server"

	start on (local-filesystems and net-device-up IFACE=lo and runlevel [2345])
	stop on runlevel [!2345]

	env WORKDIR=/data
	env PIDFILE=/data/tmp/pids/unicorn.pid
	env CFGFILE=/data/config/unicorn.rb

	require 'connection_pool'
	require 'redis'
	require 'metriks'

	class RedisClientWrapper
	def initialize(options)
	@options = options.delete(:pool)
	@pool = ConnectionPool.new(@options) do
	::Redis.new(options)
	end

	#!/usr/bin/env sh

	if ! which md5sum > /dev/null; then
	echo Install md5sum
	exit 1
	fi

	if ! which curl > /dev/null; then
	echo Install curl
	exit 1

	class Form
	include ActiveModel::Validations
	extend ActiveModel::Naming

	def self.wraps(model)
	@wraps = model
	end

	def self.model_name
	ActiveModel::Name.new(@wraps.to_s.classify.constantize)

	# Returns value from hash based on the path
	#
	# @param hash [Hash] - hash to retrieve values from
	# @param path [Array] - non-empty array representing recursive path
	#
	# @returns [Object] - an object located within an array on the given path
	#
	# Examples:
	#
	# get_in({:a => {:b => {:c => 2}}}, [:a, :b, :c]) # => 2