public static void config(String graphiteHost, int port, TimeUnit tu, int period, VertxOptions vopt, String hostName) { final String registryName = "okapi"; MetricRegistry registry = SharedMetricRegistries.getOrCreate(registryName); DropwizardMetricsOptions metricsOpt = new DropwizardMetricsOptions(); metricsOpt.setEnabled(true).setRegistryName(registryName); vopt.setMetricsOptions(metricsOpt); Graphite graphite = new Graphite(new InetSocketAddress(graphiteHost, port)); final String prefix = "folio.okapi." + hostName ; GraphiteReporter reporter = GraphiteReporter.forRegistry(registry) .prefixedWith(prefix) .build(graphite); reporter.start(period, tu); logger.info("Metrics remote:" + graphiteHost + ":" + port + " this:" + prefix); }
@PostConstruct private void init() { if (jHipsterProperties.getMetrics().getGraphite().isEnabled()) { log.info("Initializing Metrics Graphite reporting"); String graphiteHost = jHipsterProperties.getMetrics().getGraphite().getHost(); Integer graphitePort = jHipsterProperties.getMetrics().getGraphite().getPort(); String graphitePrefix = jHipsterProperties.getMetrics().getGraphite().getPrefix(); Graphite graphite = new Graphite(new InetSocketAddress(graphiteHost, graphitePort)); GraphiteReporter graphiteReporter = GraphiteReporter.forRegistry(metricRegistry) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .prefixedWith(graphitePrefix) .build(graphite); graphiteReporter.start(1, TimeUnit.MINUTES); } }
@Override public void report(MetricRegistry metricRegistry) { JbootMetricsGraphiteReporterConfig config = Jboot.config(JbootMetricsGraphiteReporterConfig.class); if (StringUtils.isBlank(config.getHost())) { throw new NullPointerException("graphite reporter host must not be null, please config jboot.metrics.reporter.graphite.host in you properties."); } if (config.getPort() == null) { throw new NullPointerException("graphite reporter port must not be null, please config jboot.metrics.reporter.graphite.port in you properties."); } if (config.getPrefixedWith() == null) { throw new NullPointerException("graphite reporter prefixedWith must not be null, please config jboot.metrics.reporter.graphite.prefixedWith in you properties."); } Graphite graphite = new Graphite(new InetSocketAddress(config.getHost(), config.getPort())); GraphiteReporter reporter = GraphiteReporter.forRegistry(metricRegistry) .prefixedWith(config.getPrefixedWith()) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .filter(MetricFilter.ALL) .build(graphite); reporter.start(1, TimeUnit.MINUTES); }
@PostConstruct private void init() { if (properties.getMetrics().getGraphite().isEnabled()) { log.info("Initializing Metrics Graphite reporting"); String graphiteHost = properties.getMetrics().getGraphite().getHost(); Integer graphitePort = properties.getMetrics().getGraphite().getPort(); String graphitePrefix = properties.getMetrics().getGraphite().getPrefix(); Graphite graphite = new Graphite(new InetSocketAddress(graphiteHost, graphitePort)); GraphiteReporter graphiteReporter = GraphiteReporter.forRegistry(metricRegistry) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .prefixedWith(graphitePrefix) .build(graphite); graphiteReporter.start(1, TimeUnit.MINUTES); } }
@PostConstruct private void init() { Boolean graphiteEnabled = propertyResolver.getProperty(PROP_GRAPHITE_ENABLED, Boolean.class, false); if (graphiteEnabled) { log.info("Initializing Metrics Graphite reporting"); String graphiteHost = propertyResolver.getRequiredProperty(PROP_HOST); Integer graphitePort = propertyResolver.getRequiredProperty(PROP_PORT, Integer.class); String graphitePrefix = propertyResolver.getProperty(PROP_GRAPHITE_PREFIX, String.class, ""); Graphite graphite = new Graphite(new InetSocketAddress(graphiteHost, graphitePort)); GraphiteReporter graphiteReporter = GraphiteReporter.forRegistry(metricRegistry) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .prefixedWith(graphitePrefix) .build(graphite); graphiteReporter.start(1, TimeUnit.MINUTES); } }
protected void startMetricReporters(int metricsReportingInterval, int graphitePort, String graphiteHostname, MetricRegistry metricRegistry) { if (shouldCreateLoggingMetricsReporter()) { registerReporter(Slf4jReporter.forRegistry(metricRegistry) .convertDurationsTo(MILLISECONDS) .convertRatesTo(SECONDS) .withLoggingLevel(TRACE) .outputTo(getLogger(ReverseProxyFilter.class)) .build() ).start(metricsReportingInterval, SECONDS); } if (shouldCreateGraphiteMetricsReporter()) { Graphite graphite = new Graphite(graphiteHostname, graphitePort); registerReporter(GraphiteReporter.forRegistry(metricRegistry) .convertDurationsTo(MILLISECONDS) .convertRatesTo(SECONDS) .build(graphite) ).start(metricsReportingInterval, SECONDS); } }
@Override public void configureReporters(MetricRegistry metricRegistry) { registerReporter(Slf4jReporter.forRegistry(metricRegistry) .outputTo(LoggerFactory.getLogger("metrics")) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .build()).start(1, TimeUnit.MINUTES); // set DNS ttl to 60 per Hosted Graphite documentation java.security.Security.setProperty("networkaddress.cache.ttl", "60"); Graphite graphite = new Graphite(new InetSocketAddress(graphiteHost, graphitePort)); registerReporter(GraphiteReporter.forRegistry(metricRegistry) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .prefixedWith(graphiteApiKey) .build(graphite)).start(1, TimeUnit.MINUTES); }
public GraphiteRegistry(MetricRegistry metricRegistry, JHipsterProperties jHipsterProperties) { this.jHipsterProperties = jHipsterProperties; if (this.jHipsterProperties.getMetrics().getGraphite().isEnabled()) { log.info(INITIALIZING_MESSAGE); String graphiteHost = jHipsterProperties.getMetrics().getGraphite().getHost(); Integer graphitePort = jHipsterProperties.getMetrics().getGraphite().getPort(); String graphitePrefix = jHipsterProperties.getMetrics().getGraphite().getPrefix(); Graphite graphite = getGraphite(graphiteHost, graphitePort); GraphiteReporter graphiteReporter = getBuilder(metricRegistry) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .prefixedWith(graphitePrefix) .build(graphite); graphiteReporter.start(REPORTER_PERIOD, TimeUnit.MINUTES); } }
private static void init() { // Init JMX reporter reporter = JmxReporter.forRegistry(registry).build(); reporter.start(); // Init graphite reporter Graphite graphite = getGraphite(); GraphiteReporter graphiteReporter; if (graphite == null) { graphiteReporter = null; } else { graphiteReporter = GraphiteReporter.forRegistry(registry).prefixedWith(PREFIX).convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS).filter(MetricFilter.ALL).build(graphite); graphiteReporter.start(AuditConfig.GRAPHITE_REPORT_PERIOD_SEC, TimeUnit.SECONDS); } }
private void setupGraphiteReporter(Configuration configuration) { boolean graphiteEnabled = configuration.getBoolean("graphite.enabled", false); if (graphiteEnabled) { String host = configuration.getString("graphite.host", "localhost"); int port = configuration.getInt("graphite.port", 80); String prefix = configuration.getString("graphite.prefix", ""); long period = configuration.getLong("graphite.period", 1l); TimeUnit periodUnit = TimeUnit.valueOf(configuration.getString("graphite.periodUnit", "MINUTES")); final Graphite graphite = new Graphite(new InetSocketAddress(host, port)); GraphiteReporter.Builder reportBuilder = GraphiteReporter.forRegistry(metricRegistry) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.MILLISECONDS) .filter(MetricFilter.ALL); if (prefix != null && !prefix.isEmpty()) { reportBuilder.prefixedWith(prefix); } graphiteReporter = reportBuilder.build(graphite); graphiteReporter.start(period, periodUnit); } }