How to push Collector metrics to Pushgateway about client_ruby HOT 4 CLOSED

class PromCollector extends Collector implements Collector.Describable {

	@Override
	public List<MetricFamilySamples> describe() {
		List<MetricFamilySamples> sampleFamilies = new ArrayList<MetricFamilySamples>();
		sampleFamilies.add(new MetricFamilySamples("random_sample_1", Type.GAUGE, "Metis random sample no. 1",
				new ArrayList<MetricFamilySamples.Sample>()));
		sampleFamilies.add(new MetricFamilySamples("random_sample_2", Type.GAUGE, "Metis random sample no. 2",
				new ArrayList<MetricFamilySamples.Sample>()));
		return sampleFamilies;
	}

	@Override
	public List<MetricFamilySamples> collect() {
		List<MetricFamilySamples> mfsList = new ArrayList<MetricFamilySamples>();
		List<MetricFamilySamples.Sample> samples = new ArrayList<MetricFamilySamples.Sample>();
		long start = System.nanoTime();
		try {
			Thread.sleep(3000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

		samples.add(new MetricFamilySamples.Sample("random_sample_1", new ArrayList<String>(),
				new ArrayList<String>(), (System.nanoTime() - start) / 1.0E9));

		mfsList.add(new MetricFamilySamples("random_sample_1", Type.UNTYPED,
				"Metis random sample no. 1", samples));

		ArrayList<String> labelNames = new ArrayList<String>();
		labelNames.add("LN1");
		labelNames.add("LN2");

		ArrayList<String> labelValues = new ArrayList<String>();
		labelValues.add("LV 1");
		labelValues.add("LV 2");

		samples = new ArrayList<Collector.MetricFamilySamples.Sample>();
		
		samples.add(new MetricFamilySamples.Sample("random_sample_2", labelNames, labelValues, 1));
		mfsList.add(new MetricFamilySamples("random_sample_2", Type.UNTYPED,
				"Metis random sample no. 2", samples));

		System.out.println("Successfully added metrics from MetisPromCollector !!!");

		return mfsList;
	}

}

void executeBatchJob() throws Exception {
		CollectorRegistry registry = new CollectorRegistry();

		MetisPromCollector mpc = new MetisPromCollector();
		mpc.register(registry);

		System.out.println("Job successfully completed");
		} finally {
			PushGateway pg = new PushGateway("localhost:9091");
			pg.pushAdd(registry, "job-name");
		}
	}

# config.ru

require ::File.expand_path('../config/environment',  __FILE__)
require 'rack'
require 'prometheus/client/rack/collector'
require 'prometheus/client/rack/exporter'

use Rack::Deflater
use Prometheus::Client::Rack::Collector
use Prometheus::Client::Rack::Exporter

require 'prometheus/client'
require 'prometheus/client/push'

prometheus = Prometheus::Client.registry

Prometheus::Client::Push.new(
  'my-job', 'instance-name', 'http://<pushgateway_ip>:9091').add(prometheus)

run Storybook::Application