riak_test/perf/crdt_team_map.erl

-module(crdt_team_map).
-compile(export_all).
-include_lib("eunit/include/eunit.hrl").

-define(HARNESS, (rt_config:get(rt_harness))).

confirm() ->
    HostList = rt_config:get(rt_hostnames),
    Count = length(HostList),
    BinSize = rt_config:get(perf_bin_size),

    Config = rtperf:standard_config(Count),
    lager:info("Generated configuration is: ~p", [Config]),

    [Nodes] = rt:build_clusters([Count]),
    lager:info("Built cluster: ~p", [Nodes]),

    SetSize = rtperf:target_size(rt_config:get(perf_target_pct),
                                 BinSize,
                                 rt_config:get(perf_ram_size),
                                 Count),
    [Node | _] = Nodes,
    rt:create_and_activate_bucket_type(Node,
                                       <<"maps">>,
                                       [{datatype, map}]),

    TestConfig =
        rt_bench:config(
          max,
          rt_config:get(perf_duration),
          [{Host, 10017} || Host <- HostList],
          {uniform_int, 100},
          {uniform_int, 1000},
          [{{game, completed}, 10},
           {{team, player, addition}, 3},
           {{team, player, removal}, 3},
           {{team, read}, 100},
           {{team, write}, 1}],
          {<<"maps">>, <<"testbucket">>},
          riakc_pb),

    ok = rtperf:maybe_prepop(Nodes, BinSize, SetSize),

    ok = rtperf:run_test(Nodes, TestConfig, []),
    pass.