本文整理了Java中io.github.hengyunabc.zabbix.sender.ZabbixSender
类的一些代码示例,展示了ZabbixSender
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZabbixSender
类的具体详情如下:
包路径:io.github.hengyunabc.zabbix.sender.ZabbixSender
类名称:ZabbixSender
暂无
代码示例来源:origin: hengyunabc/zabbix-sender
/**
*
* @param dataObject
* @param clock
* TimeUnit is SECONDS.
* @return
* @throws IOException
*/
public SenderResult send(DataObject dataObject, long clock) throws IOException {
return send(Collections.singletonList(dataObject), clock);
}
代码示例来源:origin: addthis/metrics-reporter-config
@Override
public void run() {
final Set<Map.Entry<MetricName, Metric>> metrics = getMetricsRegistry().allMetrics().entrySet();
try {
List<DataObject> dataObjectList = new ArrayList<DataObject>();
for (Map.Entry<MetricName, Metric> entry : metrics) {
final MetricName metricName = entry.getKey();
final Metric metric = entry.getValue();
if (predicate.matches(metricName, metric)) {
metric.processWith(this, entry.getKey(), dataObjectList);
}
}
SenderResult senderResult = sender.send(dataObjectList);
if (!senderResult.success()) {
log.warn("metrics reporting to zabbix {} unsuccessful: {}", sender.getHost(), sender.getPort(), senderResult);
} else if (log.isDebugEnabled()) {
log.debug("metrics reported to zabbix {} {}: {}", sender.getHost(), sender.getPort(), senderResult);
}
} catch (Exception e) {
log.error("failed to report metrics to " + sender.getHost() + ':' + sender.getPort(), e);
}
}
}
代码示例来源:origin: addthis/metrics-reporter-config
@Override
public boolean enable(MetricRegistry registry)
{
if (!isClassAvailable(SENDER_CLASS))
{
log.error("Tried to enable Zabbix Reporter, but class {} was not found", SENDER_CLASS);
return false;
}
this.registry = registry;
if (hostName == null)
hostName = System.getenv("COMPUTERNAME");
if (hostName == null)
hostName = System.getenv("HOSTNAME");
if (hostName == null)
hostName = "localhost";
// note: don't go via InetAddress.getLocalHost() as that may return unexpected results or
// take a long time (DNS roundtrips/timeouts) or even an exception being throws,
for (HostPort hostPort : getFullHostList())
{
ZabbixSender sender = new ZabbixSender(hostPort.getHost(), hostPort.getPort(), connectTimeout, socketTimeout);
MetricFilter filter = MetricFilterTransformer.generateFilter(getPredicate());
ZabbixReporter reporter = new ZabbixReporter(sender, hostName, prefix, registry, name, filter, getRealRateunit(), getRealDurationunit());
reporters.add(reporter);
}
return true;
}
代码示例来源:origin: addthis/metrics-reporter-config
SenderResult senderResult = sender.send(dataObjectList);
if (!senderResult.success()) {
log.warn("metrics reporting to zabbix {} unsuccessful: {}", sender.getHost(), sender.getPort(), senderResult);
} else if (log.isDebugEnabled()) {
log.debug("metrics reported to zabbix {} {}: {}", sender.getHost(), sender.getPort(), senderResult);
log.error("failed to report metrics to " + sender.getHost() + ':' + sender.getPort(), e);
代码示例来源:origin: addthis/metrics-reporter-config
@Override
public boolean enable()
{
if (!isClassAvailable(SENDER_CLASS))
{
log.error("Tried to enable Zabbix Reporter, but class {} was not found", SENDER_CLASS);
return false;
}
if (hostName == null)
hostName = System.getenv("COMPUTERNAME");
if (hostName == null)
hostName = System.getenv("HOSTNAME");
if (hostName == null)
hostName = "localhost";
// note: don't go via InetAddress.getLocalHost() as that may return unexpected results or
// take a long time (DNS roundtrips/timeouts) or even an exception being throws,
for (HostPort hostPort : getFullHostList())
{
ZabbixSender sender = new ZabbixSender(hostPort.getHost(), hostPort.getPort(), connectTimeout, socketTimeout);
ZabbixReporter reporter = new ZabbixReporter(sender, hostName, prefix, name, getRealRateunit(), getRealDurationunit(),
MetricPredicateTransformer.generatePredicate(getPredicate()), Clock.defaultClock());
reporter.start(getPeriod(), getRealTimeunit());
}
return true;
}
代码示例来源:origin: io.github.hengyunabc/zabbix-sender
/**
*
* @param dataObject
* @param clock
* TimeUnit is SECONDS.
* @return
* @throws IOException
*/
public SenderResult send(DataObject dataObject, long clock) throws IOException {
return send(Collections.singletonList(dataObject), clock);
}
代码示例来源:origin: io.github.hengyunabc/zabbix-sender
public SenderResult send(List<DataObject> dataObjectList) throws IOException {
return send(dataObjectList, System.currentTimeMillis() / 1000);
}
代码示例来源:origin: hengyunabc/zabbix-sender
public SenderResult send(DataObject dataObject) throws IOException {
return send(dataObject, System.currentTimeMillis() / 1000);
}
代码示例来源:origin: hengyunabc/zabbix-sender
public SenderResult send(List<DataObject> dataObjectList) throws IOException {
return send(dataObjectList, System.currentTimeMillis() / 1000);
}
代码示例来源:origin: io.github.hengyunabc/zabbix-sender
public SenderResult send(DataObject dataObject) throws IOException {
return send(dataObject, System.currentTimeMillis() / 1000);
}
内容来源于网络,如有侵权,请联系作者删除!