IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

make heartbeat optional

Browse Source
This commit is contained in:
Jonathan Shook
2024-01-18 00:23:26 -06:00
parent e6ebdc3ab5
commit e7881c1b9f
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
nb-api/src/main/java/io/nosqlbench/nb/api/components/status/NBHeartbeatComponent.java
View File

@@ -20,10 +20,13 @@ import io.nosqlbench.nb.api.components.core.NBComponent;
import io.nosqlbench.nb.api.labels.NBLabels; import io.nosqlbench.nb.api.labels.NBLabels;
import java.util.Map; import java.util.Map;
import java.util.Optional;
/** /**
* A <EM>live</EM> component is one which provides evidence that it is either * A <EM>heartbeat</EM> component is one which provides evidence that it is either
* in a healthy state or that it is not, via a heartbeat mechanism. * in a healthy state or that it is not, via a heartbeat mechanism. This requires
* that a component property 'heartbeat' is provides which is the millisecond interval
* between beats.
*/ */
public class NBHeartbeatComponent extends NBStatusComponent { public class NBHeartbeatComponent extends NBStatusComponent {
@@ -33,8 +36,12 @@ public class NBHeartbeatComponent extends NBStatusComponent {
public NBHeartbeatComponent(NBComponent parentComponent, NBLabels componentSpecificLabelsOnly, Map<String, String> props, String liveLabel) { public NBHeartbeatComponent(NBComponent parentComponent, NBLabels componentSpecificLabelsOnly, Map<String, String> props, String liveLabel) {
super(parentComponent, componentSpecificLabelsOnly, props); super(parentComponent, componentSpecificLabelsOnly, props);
// attaches, no further reference needed getComponentProp("heartbeat")
new ComponentPulse(this, NBLabels.forKV(), liveLabel, Long.parseLong(getComponentProp("heartbeat").orElse("60000"))); .map(Long::parseLong)
.ifPresent(
// attaches, no further reference needed
hbmillis -> new ComponentPulse(this, NBLabels.forKV(), liveLabel, hbmillis)
);
} }
} }