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); } }
/** * Start a metrics graphite reporter. */ public GraphiteReporter(Configuration conf) { Configuration.MetricsConfig.ReporterConfig metricConf = conf.getReporterConfig(GraphiteReporter.type); frequency = conf.getReportingFrequency(); String[] urlSplit = metricConf.url.split(":"); String hostName = urlSplit[0]; int port = 3002; if (urlSplit.length > 1) { port = Integer.parseInt(urlSplit[1]); } reporter = com.codahale.metrics.graphite.GraphiteReporter .forRegistry(Metrics.registry) .prefixedWith(metricConf.namespace) .convertRatesTo(TimeUnit.SECONDS) .convertDurationsTo(TimeUnit.SECONDS) .build(new Graphite(new InetSocketAddress(hostName, port))); }
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); }
@Override public GraphiteSender get() { switch (configuration.getProtocol()) { case PICKLE: return new PickledGraphite( configuration.getAddress(), SocketFactory.getDefault(), configuration.getCharset(), configuration.getPickleBatchSize()); case TCP: return new Graphite(configuration.getAddress(), SocketFactory.getDefault(), configuration.getCharset()); case UDP: return new GraphiteUDP(configuration.getAddress()); default: throw new IllegalArgumentException("Unknown Graphite protocol \"" + configuration.getProtocol() + "\""); } }
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); } }
