import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Override
public void updateImpl(List<Metric> metrics) {
    // The statsd client doesn't do any checks on the underlying socket's state
    // and the socket connects only once, so we cannot trust the socket to stay
    // open over a period of time.  If this is changed/fixed we could reuse the
    // client but until then it cannot be safely reused.
    StatsDClient statsd = createClient();
    LOGGER.debug("sending data");
    try {
        for (Metric metric : metrics) {
            String aspect = namingConvention.getName(metric);

            if (metric.getConfig().getTags().getTag(DataSourceType.COUNTER.getValue()) != null) {
                statsd.count(aspect, metric.getNumberValue().longValue());
            } else if (metric.hasNumberValue()) {
                statsd.gauge(aspect, metric.getNumberValue().longValue());
            } else {
                statsd.set(aspect, metric.getValue().toString());
            }

            statsd.time(aspect, metric.getTimestamp() / 1000);
        }
    } finally {
        statsd.stop();
    }
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
public GaugeMetric(MonitorConfig config) {
  super(config.withAdditionalTag(DataSourceType.GAUGE));
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
public InformationalMetric(MonitorConfig config) {
  super(config.withAdditionalTag(DataSourceType.INFORMATIONAL));
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "latencyIndexDelete95", type = DataSourceType.GAUGE)
public double getLatencyIndexDelete95() {
    return nodeIndicesStatsBean.get().latencyIndexDelete95;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "free_percent", type = DataSourceType.GAUGE)
public short getFreePercent() {
    return osStatsBean.get().freePercent;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
private static boolean isGauge(Metric m) {
    final TagList tags = m.getConfig().getTags();
    final String value = tags.getValue(DataSourceType.KEY);
    return value != null && value.equals(DataSourceType.GAUGE.name());
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "latencyIndexing99", type = DataSourceType.GAUGE)
public double getLatencyIndexing99() {
    return nodeIndicesStatsBean.get().latencyIndexing99;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "getThreads", type = DataSourceType.GAUGE)
public long getGetThreads() {
    return threadPoolBean.get().getThreads;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
public EstimatedHistogramBasedCounter(final String name, final String opName, final String tagName, final EstimatedHistogram histogram) {
	super(MonitorConfig.builder(name).build()
			.withAdditionalTag(DataSourceType.GAUGE)
			.withAdditionalTag(new BasicTag(tagName, opName)));
	this.estHistogram = histogram;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "OperationSuccess", type = DataSourceType.COUNTER)
@Override
public long getOperationSuccessCount() {
	return super.getOperationSuccessCount();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "OperationFailure", type = DataSourceType.COUNTER)
@Override
public long getOperationFailureCount() {
	return super.getOperationFailureCount();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "ConnectionCreated", type = DataSourceType.COUNTER)
@Override
public long getConnectionCreatedCount() {
	return super.getConnectionCreatedCount();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "server_open", type = DataSourceType.GAUGE)
public long getServerOpen() {
    return transportStatsBean.get().serverOpen;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "ConnectionCreateFailed", type = DataSourceType.COUNTER)
@Override
public long getConnectionCreateFailedCount() {
	return super.getConnectionCreateFailedCount();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "search_fetch_current", type = DataSourceType.GAUGE)
public long getSearchFetchCurrent() {
    return nodeIndicesStatsBean.get().searchFetchCurrent;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "ConnectionBorrowedAvgLat", type = DataSourceType.GAUGE)
@Override
public long getConnectionBorrowedLatMean() {
    return super.getConnectionBorrowedLatMean();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "ConnectionBorrowedLatP50", type = DataSourceType.GAUGE)
@Override
public long getConnectionBorrowedLatP50() {
    return super.getConnectionBorrowedLatP50();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "merges_total_size", type = DataSourceType.GAUGE)
public long getMergesTotalSize() {
    return nodeIndicesStatsBean.get().mergesTotalSize;
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "ConnectionReturned", type = DataSourceType.COUNTER)
@Override
public long getConnectionReturnedCount() {
	return super.getConnectionReturnedCount();
}
 

import com.netflix.servo.annotations.DataSourceType; //导入依赖的package包/类
@Monitor(name = "PoolExhausted", type = DataSourceType.COUNTER)
@Override
public long getPoolExhaustedTimeoutCount() {
	return super.getPoolExhaustedTimeoutCount();
}