Bryan Hunt binarytemple

sample

timeout(sec) : 5
message count: 2

(riak1@127.0.0.1)14> redbug:start(5000, 2, {riak_kv_keys_fsm,'_'}).
ok

16:23:32 <{riak_core_coverage_fsm,init,1}> {riak_kv_keys_fsm,init,

Erlang Tracing: more than you wanted to know

Rough Outline

What can be traced?
How can trace events be specified?
"match specifications": twisty passages, all alike
WTF, can I just use DTrace and drink my coffee/beer/whisky in peace?
Trace delivery mechanisms: pick one of two

10 Erlang one liners to impress your friends

Multiple Each Item in a List by 2:

[X * 2 || X <- lists:seq(1, 11)].

https://gist.github.com/0acc83b3db29dc78dde4

Geting status for a named process

{_,Pid,_,_} = sys:get_status(riak_repl2_rtq).
rp(process_info(Pid, [backtrace])).

Get full stack trace, prevent truncating of the map

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

Example of using Riak local client to PUT

Creating the Object

21: O = riak_object:new(<<"bucketfoo">>,
                        <<"bar">>,
                        "baz",
                        dict:from_list([{<<"content-type">>,
 "text/plain"}]))

Riak Source Code Reading #27: Riak KV backend API and storage

The Riak KV backend store API

behaviour_info(callbacks) ->
    [
     {api_version,0},

+#### Embed the hostname into all the logfiles from a ZD ticket
+This only works with ZSH and relies on glob substitution trick discussed [here](http://serverfault.com/questions/618812/zsh-substitution-cant-do-regex-with-repetition/618822#618822)
+### First, get the list of files.
+```
+errors=(**/*console.log*)
+```

	package com.company;

	import java.util.Arrays;
	import java.util.List;
	import java.util.function.Supplier;
	import java.util.stream.Stream;

	import static java.lang.System.*;

	/**