anchor.diff:  -export([start/1]).
   
   -required_variable({'NUMBER_OF_NODE_CREATORS', <<"Specifies how many users will create node"/utf8>>}).
  +-required_variable({'PUBLISHERS_RATIO', <<"Specifies the number of publishers per 10 users"/utf8>>}).
   
   -spec init() -> ok.
   init() ->
  +    init_metrics(),
  +    ok.
  +
  +-spec start(amoc_scenario:user_id()) -> any().
  +start(Id) ->
  +    pg2:create(?GROUPNAME),
  +    CreatorsNumber = amoc_config:get('NUMBER_OF_NODE_CREATORS', 3),
  +    Client = connect_amoc_user(Id),
  +    lager:info("~p~p", [Id, Client]),
  +    case assign_role(Id, CreatorsNumber) of
  +        creator ->
  +            creator_start(Client);
  +        publisher ->
  +            publisher_start(Client);
  +        subscriber ->
  +            subscriber_start(Client)
  +    end.
  +
  +%% --- Metrics ---------------------------------------------------------------------------------------------
  +
  +init_metrics() ->
       Stats =
       [
           {?NODE_CREATE_FAILS_COUTER, spiral},
  
positive.code: item_content() ->
      #xmlel{name = <<"entry">>,
             attrs = [{<<"xmlns">>, <<"http://www.w3.org/2005/Atom">>}]}.
  
negative.code:         {?SUBSCRIBE_TIME, histogram},
          {?PUBLISH_TIME, histogram}
      ],
      [create_stat(Path, GraphType) ||  {Path, GraphType} <- Stats].
  
  create_stat(Path, spiral) ->
      exometer:new(Path, spiral),
  