import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
public NginxAgent(String name, String statusUrl) throws ConfigurationException {
    super(GUID, VERSION);
    try {
        this.name = name;
        this.url = new URL(statusUrl);
        this.connectionsAccepted = new EpochCounter();
        this.connectionsDropped  = new EpochCounter();
        this.requestsTotal       = new EpochCounter();
    } catch (MalformedURLException e) {
        throw new ConfigurationException("Status URL could not be parsed", e);
    }
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
public Processor getProcessorForNode(String id, String nodeName)
{
    String key = getProcessorKey(id, nodeName);
    if (!processors.containsKey(key)) {
        processors.put(key, new EpochCounter());
    }

    return processors.get(key);
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
public Processor getProcessor(String key)
{
    if (!processors.containsKey(key)) {
        processors.put(key, new EpochCounter());
    }

    return processors.get(key);
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
/**
 * Constructor for Wikipedia Agent.
 * Uses name for Component Human Label and host for building Wikipedia's Metric service.
 * @param name
 * @param host
 * @throws ConfigurationException if URL for Wikipedia's metric service could not be built correctly from provided host
 */
public WikipediaAgent(String name, String host) throws ConfigurationException {
    super(GUID, VERSION);
    try {
        this.name = name;
        this.url = new URL(HTTP, host, WIKIPEDIA_URL);
        this.articleCreationRate = new EpochCounter();
    } catch (MalformedURLException e) {
        throw new ConfigurationException("Wikipedia metric URL could not be parsed", e);
    }
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
public MemcachedAgent(String name, String host, Integer port) {
    super(GUID, VERSION);

    this.name = name;
    this.host = host;
    this.port = port;

    // Initialize Counters
    this.userCpuUsageCounter = new EpochCounter();
    this.systemCpuUsageCounter = new EpochCounter();
    this.totalConnectionsCounter = new EpochCounter();
    this.cmdGetCounter = new EpochCounter();
    this.cmdSetCounter = new EpochCounter();
    this.cmdFlushCounter = new EpochCounter();
    this.getHitsCounter = new EpochCounter();
    this.getMissesCounter = new EpochCounter();
    this.deleteHitsCounter = new EpochCounter();
    this.deleteMissesCounter = new EpochCounter();
    this.incrHitsCounter = new EpochCounter();
    this.incrMissesCounter = new EpochCounter();
    this.decrHitsCounter = new EpochCounter();
    this.decrMissesCounter = new EpochCounter();
    this.casHitsCounter = new EpochCounter();
    this.casMissesCounter = new EpochCounter();
    this.casBadValCounter = new EpochCounter();
    this.bytesReadCounter = new EpochCounter();
    this.bytesWrittenCounter = new EpochCounter();
    this.totalItemsCounter = new EpochCounter();
    this.evictionsCounter = new EpochCounter();
    this.reclaimsCounter = new EpochCounter();

    logger.debug("Memcached Agent initialized: " + formatAgentParams(name, host, port));
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
private void reportCacheUseMetrics(String name, Float hits, Float misses, EpochCounter hitCounter, EpochCounter missCounter) {
    Float processedHits = (Float)hitCounter.process(hits);
    Float processedMisses = (Float)missCounter.process(misses);

    reportMetric(String.format("CacheUse/%s/Actions/Hits", name), "commands/seconds", processedHits);
    reportMetric(String.format("CacheUse/%s/Actions/Misses", name), "commands/seconds", processedMisses);

    if(processedHits != null && processedMisses != null) {
        Float percentMisses = (processedHits > 0 || processedMisses > 0) ? (processedMisses / (processedHits + processedMisses)) * 100 : 0;
        reportMetric(String.format("CacheUse/Summary/%s/Missed", name), "percent", percentMisses);
    }
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
public MetricMeta(boolean isCounter, String unit) {
    this.unit = unit;
    if (isCounter) {
        this.counter = new EpochCounter();
    }
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
public EpochCounter getCounter() {
    return this.counter;
}
 

import com.newrelic.metrics.publish.processors.EpochCounter; //导入依赖的package包/类
private Metric getMetric(Element n) throws ParseException {
	String type = n.getElementsByTagName("type").item(0) != null ? n.getElementsByTagName("type").item(0).getTextContent() : null;
	String ident = n.getElementsByTagName("ident").item(0) != null ? n.getElementsByTagName("ident").item(0).getTextContent() : null;
	String name = n.getElementsByTagName("name").item(0) != null ? n.getElementsByTagName("name").item(0).getTextContent() : null;
	String description = n.getElementsByTagName("description").item(0) != null ? n.getElementsByTagName("description").item(0).getTextContent()
			: null;
	String value = n.getElementsByTagName("value").item(0) != null ? n.getElementsByTagName("value").item(0).getTextContent() : null;
	String flag = n.getElementsByTagName("flag").item(0) != null ? n.getElementsByTagName("flag").item(0).getTextContent() : null;

	StringBuilder key = new StringBuilder();
	key.append("Varnish/");

	// does it have a custom group?
	String group = getGroup(name);

	if (group != null) {
		key.append(group + "/");
	} else if (type != null)
		key.append(type + "/");
	else {
		key.append("main/");

		int pos = name.indexOf("_");
		if (pos != -1) {
			key.append(name.substring(0, pos) + "/");
		}
	}

	if (ident != null)
		key.append(ident + "/");

	key.append(description);

	String actualKey = key.toString();
	if ("a".equals(flag)) {
		if (!epochCounters.containsKey(actualKey)) {
			epochCounters.put(actualKey, new EpochCounter());
		}
		return new Metric(actualKey, getUnitName(name) + "/sec", epochCounters.get(actualKey).process(NumberFormat.getInstance().parse(value)));
	} else {
		return new Metric(actualKey, getUnitName(name), NumberFormat.getInstance().parse(value));
	}
}