Upon a casual reading, it appears that I'm unnecessarily re-wrapping objects in the w3 wire format for cascading replication.
|
%% Timeseries data is an encoded tagged tuple |
|
rtq_push(_Binary, {ts, PartIdx, Batch}, Meta) -> |
|
riak_repl2_rtq:push(length(Batch), |
|
riak_repl_util:to_wire(w3, {PartIdx, Batch}), Meta). |
I suspect the first parameter, Binary, is equivalent to the result from riak_repl_util:to_wire(w3, {PartIdx, Batch}).
Upon a casual reading, it appears that I'm unnecessarily re-wrapping objects in the
w3wire format for cascading replication.riak_repl/src/riak_repl2_rtsink_conn.erl
Lines 305 to 308 in 23915a3
I suspect the first parameter,
Binary, is equivalent to the result fromriak_repl_util:to_wire(w3, {PartIdx, Batch}).