Store tenant_id and region as private

Store tenant_id as _tenant_id.
Store region as _region.

Change-Id: If0498cdbf445d5556308e7d2ba9b4770ffc4d6f0
This commit is contained in:
Deklan Dieterly 2015-03-26 15:52:42 -06:00
parent d2b08924e8
commit 5f422951db
2 changed files with 7 additions and 6 deletions

View File

@ -17,9 +17,10 @@
package monasca.persister.repository;
import com.google.inject.Inject;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.inject.Inject;
import org.influxdb.dto.Serie;
import org.slf4j.Logger;
@ -94,7 +95,7 @@ public class InfluxV8MetricRepo extends InfluxMetricRepo
logger.debug("Added column value to colValsObjArry[{}] = {}", 2, valueMetaJson);
}
catch (JsonProcessingException e) {
logger.error("Unable to serialize " + measurement.valueMeta, e);
logger.error("Unable to serialize value meta data {}", measurement.valueMeta, e);
}
}
builder.values(colValsObjArry);

View File

@ -18,11 +18,11 @@
package monasca.persister.repository;
import com.google.inject.Inject;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.inject.Inject;
import org.joda.time.DateTime;
import org.joda.time.DateTimeZone;
import org.joda.time.format.DateTimeFormatter;
@ -84,8 +84,8 @@ public class InfluxV9MetricRepo extends InfluxMetricRepo {
for (Dim dim : dimSet) {
tagMap.put(dim.name, dim.value);
}
tagMap.put("tenant_id", def.tenantId);
tagMap.put("region", def.region);
tagMap.put("_tenant_id", def.tenantId);
tagMap.put("_region", def.region);
for (final Measurement measurement : this.measurementMap.get(defDimId)) {