replication_ssce.erl

-module(replication_ssce).


-export([test/0]).

test() ->
		DBS = [<<"50c84cda-e011-49d3-889a-0b2ad8206e6c">>,
					 <<"774129ae-db15-431e-9ded-fbfb924b33b2">>],
		[S,T] = DBS,
		[begin
				 lager:info("Create Database ~s", [D]),
				 {ok,#{<<"database_id">> := D}} = create_database(D)
		 end
		 || D <-DBS],
		
		{ok, #{id := Id}} = barrel:start_replication(#{source => S,
																									 target => T,
																									 options => #{metrics_freq => 100}}),
		ok = barrel:stop_replication(Id),
		[begin
				 barrel:delete_database(D)
		 end
		 || D <-DBS],
		ok.



create_database(DB) ->
    case barrel:database_infos(DB) of
        {ok, _} -> barrel:delete_database(DB);
        _ -> ok
    end,
    barrel:create_database(#{<<"database_id">> => DB}).