anchor.diff:  -export([
       initial_state/0,
       metrics/0,
  -    execute/3
  +    execute/3,
  +    statsd_opts/3,
  +    declare_metric/6,
  +    statsd/1
   ]).
   
  -initial_state() -> "".
  +-define(DEFAULT_STATSD_PORT, 8125).
  +
  +initial_state() ->
  +    #{
  +        statsd_spawned => false,
  +        statsd_opts => []
  +    }.
   
   metrics() ->
       [
  
positive.code:         ]}
      ].
  
  execute(State, Meta, Command) ->
      WorkerId = proplists:get_value(worker_id, Meta, undefined),
      lager:info("Executing ~p... on ~p~n", [Command, WorkerId]),
      TimeStart = os:timestamp(),
  
negative.code:     end,
      TimeFinish = os:timestamp(),
      mzb_metrics:notify({"latency", histogram}, timer:now_diff(TimeFinish, TimeStart)),
      {nil, NewState}.
  
  run(Command, _Opts, WorkerId) ->
      {ok, Pid, _OsPid} = exec:run(Command, [monitor, stdout, stderr,
  