macintux

I pledge subservience
To the government
Of the United States of America
And to the police state to which we kneel
One Nation under surveillance
unconstitutional
with paranoia and insecurity for all

macintux

#!/usr/bin/perl -w

use strict;
use warnings;

## Running this script:
##  1  Set $datadir to whatever folder you'd like to store the new files
##  2  Run this script with your cluster info file as input
##     $ ./split.pl < cluster-info.out
##

macintux

#!/usr/bin/perl -w

use strict;
use warnings;

sub usage {
    my ($errmsg) = @_;
    my $msg = <<END;
Usage: split-info <info file> <output directory>

macintux

%%% @author John Daily
%%% @copyright (C) 2013, John Daily
%%% @doc
%%%
%%% @end
%%% Created :  3 Aug 2013 by John Daily

-module(etude51).
-compile(export_all).

macintux

#!/usr/local/bin/python

import riak

Riak = riak.RiakClient(pb_port=10017, protocol='pbc')
TweetsBucket = Riak.bucket('tweets')

results = TweetsBucket.get_index("hashtags_bin", "android",
                                 "androie", return_terms=True)

macintux

#!/usr/local/bin/python

import riak

Riak = riak.RiakClient(pb_port=10017, protocol='pbc')
TweetsBucket = Riak.bucket('tweets')

results = TweetsBucket.get_index("hashtags_bin", "android",
                                 "androie", return_terms=False)

macintux

curl -XPOST http://localhost:8098/mapred
  -H"Content-Type: application/json"
  -d  '{"inputs":"notifications","query":[{"map":{"language":"erlang","source":"fun(O,_,_) when element(1,O) == r_object -> S=byte_size(term_to_binary(riak_object:get_values(O))), if (S>1048576) -> {ok,C}=riak:local_client(),C:delete(riak_object:bucket(O),riak_object:key(O)),[riak_object:key(O)]; true -> [] end;(_,_,_) -> [] end."}}]}'

macintux

Doc: http://www.erlang.org/doc/reference_manual/typespec.html

-type square() :: tuple(pos_integer(), pos_integer()).
-type side() :: 'white'|'black'.
-type movefun() :: fun((square(), square(), side()) -> tuple(square(), list(square()))).
-type movedef() :: tuple(atom(), movefun()).

-record(move, { piece,
 start,

macintux

I started working on some missing documentation in the Erlang stdlib, and found one particularly confusing rabbit hole.

gen_server.xml

In the documentation for gen_server, I found debug options for start_link which lacked type information:

    Dbg = trace | log | statistics | {logfile,FileName} | {install,{Func,FuncState}}</v>
        SOpts = [term()]

FileName isn't defined, Func and FuncState aren't defined, so I decided to dig into the source to document their types.

macintux

Put

API

• Starting: https://github.com/basho/riak_kv/blob/1.4.2/src/riak_kv_wm_object.erl#L619
• We create a new riak_object and populate the various fields with the headers, metadata supplied by the client.
• Big suprise, we eventually call riak_client:put: https://github.com/basho/riak_kv/blob/1.4.2/src/riak_client.erl#L143
• If/when the client returns any errors these are handled in handle_common_errors and it is nice to return human readable errors to client :)

Riak_client