@Test public void histogramShardTest() { registry.histogram( MetricId.build("X").tagged("what", "balls", "status", "tripping"), ImmutableList.of("what", "status")).update(3); verify(remote).post(anyString(), eq("what:balls,status:tripping"), anyMap()); }
@Override public RemoteHistogram histogram(final MetricId name) { return histogram(name, ImmutableList.of("what")); }
SemanticAggregatorMetricRegistry implements RemoteSemanticMetricRegistry { @Override public RemoteHistogram histogram(final MetricId name) { return histogram(name, ImmutableList.of("what")); } }
SemanticAggregatorMetricRegistry implements RemoteSemanticMetricRegistry { @Override public RemoteHistogram histogram(final MetricId name) { return histogram(name, ImmutableList.of("what")); } SemanticAggregatorMetricRegistry(
        String remoteHost,
        int port,
        int maxConcurrency,
        int hwm); @VisibleForTesting  SemanticAggregatorMetricRegistry(Remote remote); }
SemanticAggregatorMetricRegistry implements RemoteSemanticMetricRegistry { @Override public RemoteHistogram histogram(final MetricId name) { return histogram(name, ImmutableList.of("what")); } SemanticAggregatorMetricRegistry(
        String remoteHost,
        int port,
        int maxConcurrency,
        int hwm); @VisibleForTesting  SemanticAggregatorMetricRegistry(Remote remote); T getOrAdd(
        final MetricId name,
        final List<String> shardKey,
        final SemanticAggregatorMetricBuilder<T> builder
    ); @Override RemoteCounter counter(MetricId name); @Override RemoteCounter counter(MetricId name, List<String> shardKey); @Override RemoteTimer timer(MetricId name); @Override RemoteTimer timer(MetricId name, List<String> shardKey); @Override RemoteDerivingMeter derivingMeter(MetricId name, List<String> shardKey); @Override RemoteDerivingMeter derivingMeter(MetricId name); @Override RemoteHistogram histogram(final MetricId name); @Override RemoteHistogram histogram(final MetricId name, final List<String> shardKey); @Override RemoteMeter meter(final MetricId name); @Override RemoteMeter meter(final MetricId name, final List<String> shardKey); @Override boolean shutdown(long timeout, TimeUnit timeUnit); }
SemanticAggregatorMetricRegistry implements RemoteSemanticMetricRegistry { @Override public RemoteHistogram histogram(final MetricId name) { return histogram(name, ImmutableList.of("what")); } SemanticAggregatorMetricRegistry(
        String remoteHost,
        int port,
        int maxConcurrency,
        int hwm); @VisibleForTesting  SemanticAggregatorMetricRegistry(Remote remote); T getOrAdd(
        final MetricId name,
        final List<String> shardKey,
        final SemanticAggregatorMetricBuilder<T> builder
    ); @Override RemoteCounter counter(MetricId name); @Override RemoteCounter counter(MetricId name, List<String> shardKey); @Override RemoteTimer timer(MetricId name); @Override RemoteTimer timer(MetricId name, List<String> shardKey); @Override RemoteDerivingMeter derivingMeter(MetricId name, List<String> shardKey); @Override RemoteDerivingMeter derivingMeter(MetricId name); @Override RemoteHistogram histogram(final MetricId name); @Override RemoteHistogram histogram(final MetricId name, final List<String> shardKey); @Override RemoteMeter meter(final MetricId name); @Override RemoteMeter meter(final MetricId name, final List<String> shardKey); @Override boolean shutdown(long timeout, TimeUnit timeUnit);  }