Merge pull request #11967 from jkschneider

* pr/11967:
  Polish "Add publishUnchangedMeters StatsD support"
  Add publishUnchangedMeters StatsD support
pull/11893/merge
Phillip Webb 7 years ago
commit 9a31b08816

@ -59,7 +59,8 @@ public class StatsdProperties {
/** /**
* How often gauges will be polled. When a gauge is polled, its value is recalculated * How often gauges will be polled. When a gauge is polled, its value is recalculated
* and if the value has changed, it is sent to the StatsD server. * and if the value has changed (or publishUnchangedMeters is true), it is sent to the
* StatsD server.
*/ */
private Duration pollingFrequency = Duration.ofSeconds(10); private Duration pollingFrequency = Duration.ofSeconds(10);
@ -68,6 +69,11 @@ public class StatsdProperties {
*/ */
private Integer queueSize = Integer.MAX_VALUE; private Integer queueSize = Integer.MAX_VALUE;
/**
* Send unchanged meters to the StatsD server.
*/
private Boolean publishUnchangedMeters;
public Boolean getEnabled() { public Boolean getEnabled() {
return this.enabled; return this.enabled;
} }
@ -124,4 +130,12 @@ public class StatsdProperties {
this.queueSize = queueSize; this.queueSize = queueSize;
} }
public Boolean getPublishUnchangedMeters() {
return this.publishUnchangedMeters;
}
public void setPublishUnchangedMeters(Boolean publishUnchangedMeters) {
this.publishUnchangedMeters = publishUnchangedMeters;
}
} }

@ -78,4 +78,10 @@ public class StatsdPropertiesConfigAdapter
return get(StatsdProperties::getQueueSize, StatsdConfig.super::queueSize); return get(StatsdProperties::getQueueSize, StatsdConfig.super::queueSize);
} }
@Override
public boolean publishUnchangedMeters() {
return get(StatsdProperties::getPublishUnchangedMeters,
StatsdConfig.super::publishUnchangedMeters);
}
} }

Loading…
Cancel
Save