Package com.societegenerale.failover.dashboard.metrics.source.sharedstore

Class ClusterSeriesSampler

java.lang.Object

com.societegenerale.failover.dashboard.metrics.source.sharedstore.ClusterSeriesSampler

All Implemented Interfaces:

AutoCloseable

public class ClusterSeriesSampler
extends Object
implements AutoCloseable

Periodically samples the merged cluster aggregate (a MetricsSource) into a ClusterSeriesStore, producing the cluster-wide trend for cluster.mode=shared-store.

Reset-aware monotonic cumulative (consistency rule, design §5.3). SeriesPoints are cumulative and the UI deltas consecutive points. When a peer restarts, its counters reset to zero, so the raw cluster sum drops — naive cumulative would yield a negative delta. This sampler instead accumulates a monotonic adjusted total: per field it adds max(increase, freshValueAfterReset) so the series never decreases and post-reset activity is still counted.

Runs on a single daemon thread; stopped on shutdown.

Author:

Anand Manissery

Constructor Summary

Constructors

Constructor	Description
ClusterSeriesSampler(MetricsSource source, ClusterSeriesStore store, int intervalSeconds)	Creates a new sampler and starts its scheduled sampling.

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ClusterSeriesSampler

public ClusterSeriesSampler(MetricsSource source,
 ClusterSeriesStore store,
 int intervalSeconds)

Creates a new sampler and starts its scheduled sampling.

Parameters:

source - the metrics source to sample

store - the ring to append samples into

intervalSeconds - seconds between samples

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable