/**
 * 
 */
package com.yoho.jobs.server.alarm;

import java.util.concurrent.TimeUnit;

import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;

/**
 * @author yanzhang.fu
 *
 */
public class InfluxDbSource {

	private String influxdbUrl;

	private String influxdbName;

	private String password;

	private final InfluxDB influxDB;

	public InfluxDbSource(String influxdbUrl, String influxdbName, String password) {

		this.influxdbUrl = influxdbUrl;

		this.influxdbName = influxdbName;

		this.password = password;

		influxDB = InfluxDBFactory.connect(influxdbUrl, influxdbName, password);
		influxDB.enableBatch(1500, 50, TimeUnit.MILLISECONDS);
	}

	public InfluxDB getInfluxDb() {

		return influxDB;

	}

	public String getInfluxdbUrl() {
		return influxdbUrl;
	}

	public void setInfluxdbUrl(String influxdbUrl) {
		this.influxdbUrl = influxdbUrl;
	}

	public String getInfluxdbName() {
		return influxdbName;
	}

	public void setInfluxdbName(String influxdbName) {
		this.influxdbName = influxdbName;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

}