Reverted influxdb 0.9.0 changes as the Ansible is not yet ready

The original changes are at https://review.openstack.org/#/c/193590/

Change-Id: I032423e7ca65b8bb280b53e4b254e6660b5dd69b
This commit is contained in:
Tim Kuhlman 2015-06-22 09:15:20 -06:00
parent 15acc0fa10
commit 1c2c8bcb7a
2 changed files with 11 additions and 16 deletions
java/src/main/java/monasca/persister/repository/influxdb

@ -21,42 +21,37 @@ import java.util.Map;
public class InfluxPoint {
private final String measurement;
private final String name;
private final Map<String, String> tags;
private final String time;
private final String timestamp;
private final Map<String, Object> fields;
private final String Precision = "ms";
public InfluxPoint(
final String measurement,
final String name,
final Map<String, String> tags,
final String time,
final String timestamp,
final Map<String, Object> fields) {
this.measurement = measurement;
this.name = name;
this.tags = tags;
this.time = time;
this.timestamp = timestamp;
this.fields = fields;
}
public String getMeasurement() {
return measurement;
public String getName() {
return name;
}
public Map<String, String> getTags() {
return this.tags;
}
public String getTime() {
return this.time;
public String getTimestamp() {
return this.timestamp;
}
public Map<String, Object> getFields() {
return this.fields;
}
public String getPrecision() {
return Precision;
}
}

@ -185,7 +185,7 @@ public class InfluxV9RepoWriter {
int rc = response.getStatusLine().getStatusCode();
if (rc != HttpStatus.SC_OK && rc != HttpStatus.SC_NO_CONTENT) {
if (rc != HttpStatus.SC_OK) {
logger.error("[{}]: failed to send data to influxdb {} at {}: {}", id,
this.influxName, this.influxUrl, String.valueOf(rc));