kowsik

class RestClient::Request
    Empty = {}.freeze
    def default_headers
        Empty
    end
end

module RestAPI
    Headers = { :content_type => :json }.freeze
    def default_headers

kowsik

map: function(doc) {
    if (something_or_the_other) {
        emit(doc.attribute, doc);
    }
}

kowsik

def update_doc doc
    loop do
        yield doc
        begin
            save_doc doc
            break
        rescue RestClient::RequestFailed => e
            if e.http_code == 409
                doc = get doc['_id']
                next

kowsik

# Assuming the docs have created_at, delete everything older than 
# 5 minutes. We assume an emit like this: 
#
#     emit(Date.parse(doc.created_at), doc._rev)
#
# Notice that the value in emitted kv pair is the doc's current _rev

old = (Time.now - 300).utc.to_i * 1000
opts = { :startkey => old, :descending => true }

kowsik

map: function(doc) {
    if (doc.type === 'queue') {
        emit(null, 1);
    }
},
reduce: '_sum'

kowsik

{"total_rows":0,"offset":0,"rows":[]}

kowsik

loop do
    76.times do |i|
        print " " * i
        print "o"
        print "\r"
        $stdout.flush
        sleep 0.05
    end

    76.times do |i|

kowsik

require 'rubygems'
require 'blitz'
require 'pp'

# Run a sprint        
require 'blitz'
sprint = Blitz::Curl.parse('-r california www.example.com')
result = sprint.execute
pp :duration => result.duration

kowsik

require 'rubygems'
require 'restclient'
require 'blitz'
require 'pp'

TROPO_USER = ENV['TROPO_USER']
TROPO_PASS = ENV['TROPO_PASS']
TROPO_APIK = ENV['TROPO_APIK']
TROPO_CALL = ENV['TROPO_CALL']

kowsik

# Try running a Rush (load test) from california
opts = {
    :region => 'california',
    :url => 'http://www.mudynamics.com',
    :pattern => [{ :start => 1, :end => 10000, :duration => 120 }]
}
result = Blitz::Curl::Rush.execute(opts)
last = result.timeline.last
if last.errors or last.timeouts
    # Do something about this!