anchor.diff:      latency_connect_50_resolver/0,
       latency_connect_95_resolver/0,
       latency_connect_99_resolver/0,
  -    latency_connect_max_resolver/0
  +    latency_connect_max_resolver/0,
  +    pkts_in_resolver/0,
  +    pkts_out_resolver/0
   ]).
   
   -define(Timeout, 5000).
  
positive.code:                                   {"tcpkali.latency.connect.95", derived, #{resolver => latency_connect_95_resolver}},
                                    {"tcpkali.latency.connect.99", derived, #{resolver => latency_connect_99_resolver}},
                                    {"tcpkali.latency.connect.max", derived, #{resolver => latency_connect_max_resolver}}
                                   ]}}
          ]}
      ].
  
negative.code:     aggregate_mean(Metric, "tcpkali.traffic.msgs.rcvd.");
  aggregate_percentile("tcpkali.latency.connect." ++ _ = Metric, _Percentile) ->
      aggregate_mean(Metric, "tcpkali.connections.opened.").
  
  pkts_in_resolver() ->
      lists:sum([V || {_, V} <- mzb_metrics:get_by_wildcard("systemload.netrx.pkts.*.*")]).
  
  pkts_out_resolver() ->
      lists:sum([V || {_, V} <- mzb_metrics:get_by_wildcard("systemload.nettx.pkts.*.*")]).
  
  aggregate_mean(Name, WeightMetric) ->
      {Time, Messages} = metric_fold(
  