|
|
@ -57,6 +57,21 @@ public class InfluxProperties extends StepRegistryProperties {
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
private String retentionPolicy;
|
|
|
|
private String retentionPolicy;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* Time period for which influx should retain data in the current database (e.g. 2h, 52w)
|
|
|
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
private String retentionDuration;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* How many copies of the data are stored in the cluster. Must be 1 for a single node instance.
|
|
|
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
private Integer retentionReplicationFactor;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* The time range covered by a shard group (e.g. 2h, 52w).
|
|
|
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
private String retentionShardDuration;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* URI of the Influx server.
|
|
|
|
* URI of the Influx server.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
@ -137,4 +152,27 @@ public class InfluxProperties extends StepRegistryProperties {
|
|
|
|
this.autoCreateDb = autoCreateDb;
|
|
|
|
this.autoCreateDb = autoCreateDb;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public String getRetentionDuration() {
|
|
|
|
|
|
|
|
return retentionDuration;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setRetentionDuration(String retentionDuration) {
|
|
|
|
|
|
|
|
this.retentionDuration = retentionDuration;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public Integer getRetentionReplicationFactor() {
|
|
|
|
|
|
|
|
return retentionReplicationFactor;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setRetentionReplicationFactor(Integer retentionReplicationFactor) {
|
|
|
|
|
|
|
|
this.retentionReplicationFactor = retentionReplicationFactor;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public String getRetentionShardDuration() {
|
|
|
|
|
|
|
|
return retentionShardDuration;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void setRetentionShardDuration(String retentionShardDuration) {
|
|
|
|
|
|
|
|
this.retentionShardDuration = retentionShardDuration;
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|