in concurrency-loadbalancer-m3/src/main/java/com/uber/concurrency/loadbalancer/TallyMetricsTaskListener.java [122:131]
public void onComplete(T t, boolean succeed) {
String name = taskNameMapper.apply(t);
Scope taskScope = scope.tagged(ImmutableMap.of(TAG_TASK, name));
if (succeed) {
taskScope.counter(METRIC_NAME_SUCCESS_RATE).inc(1);
} else {
taskScope.counter(METRIC_NAME_FAILURE_RATE).inc(1);
}
}