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() }).