vjache

operator fun <T,T1> ((T) -> T1).unaryPlus(): (T.()->T1) {
    val f = this
    return {
        f(this)
    }
}

fun mkStr(t:Int) : String {
    return ""
}

vjache

-module(codec).

-export([encode/1, decode/1]).


encode(Ss) ->
    encode(Ss, "").

encode([], Enc) ->
    lists:reverse(Enc);   

vjache

appendBatch(SomeDir, Events) ->
   ProtoFile = filename:join(SomeDir, "flume.avpr"),
   {ok, P} = eavro_rpc_fsm:start_link(Host, Port, ProtoFile),
   AvroEvents = encode_events_to_eavro_api_events(Events),
   {ok, Result} = eavro_rpc_fsm:call(Conn, appendBatch, _Args = [ AvroEvents ]).


encode_events_to_eavro_api_events(Events) ->
    [ 
      [ [ {<<"timestamp">>, 

vjache

%% Shared Ring Buffer
-module(srb).

-export([new/2, push/2, pop/2, pop/1]).

-compile(export_all).

-record(counters, 
	{ clock    :: non_neg_integer(), 
	  max_size :: non_neg_integer() }).