Package io.jans.fido2.service.metric

Class Fido2MetricsAggregationScheduler

java.lang.Object

io.jans.fido2.service.metric.Fido2MetricsAggregationScheduler

@ApplicationScoped
public class Fido2MetricsAggregationScheduler
extends Object

Scheduler service for FIDO2 metrics aggregation

Author:

FIDO2 Team

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Fido2MetricsAggregationScheduler.DailyAggregationJob	Job for daily aggregation Uses distributed locking to ensure only one node performs aggregation
static class	Fido2MetricsAggregationScheduler.DataCleanupJob	Job for data cleanup
static class	Fido2MetricsAggregationScheduler.HourlyAggregationJob	Job for hourly aggregation This job is designed to work in cluster environments where nodes can be added/removed All statistics are persisted to the database, not kept in memory Uses distributed locking to ensure only one node performs aggregation
static class	Fido2MetricsAggregationScheduler.MonthlyAggregationJob	Job for monthly aggregation Uses distributed locking to ensure only one node performs aggregation
static class	Fido2MetricsAggregationScheduler.WeeklyAggregationJob	Job for weekly aggregation Uses distributed locking to ensure only one node performs aggregation

Constructor Summary

Constructors

Constructor	Description
Fido2MetricsAggregationScheduler()

Method Summary

Modifier and Type	Method	Description
void	flushPendingMetrics()	Ensure all pending metrics are persisted to database This method should be called before node shutdown or during maintenance
int	getDataRetentionDays()	Get data retention days
void	initTimer()	Initialize and register Quartz jobs for metrics aggregation Called during application startup by AppInitializer
boolean	isAggregationEnabled()	Check if aggregation is enabled
void	releaseClusterNode()	Cleanup resources on shutdown Shuts down update executor if in cluster mode
boolean	shouldPerformAggregation()	Check if this node should perform the aggregation In single-node deployments: always returns true In multi-node clusters: uses distributed locking to coordinate Synchronized to prevent race conditions between concurrent job threads
ScheduledFuture<?>	startPeriodicLockUpdates()	Start periodic updates to keep the lock alive during aggregation work Should be called at the start of aggregation work Only used in cluster environments

Methods inherited from class java.lang.Object

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

Constructor Details

Fido2MetricsAggregationScheduler

public Fido2MetricsAggregationScheduler()

Method Details

isAggregationEnabled

public boolean isAggregationEnabled()

Check if aggregation is enabled

getDataRetentionDays

public int getDataRetentionDays()

Get data retention days

flushPendingMetrics

public void flushPendingMetrics()

Ensure all pending metrics are persisted to database This method should be called before node shutdown or during maintenance

shouldPerformAggregation

public boolean shouldPerformAggregation()

Check if this node should perform the aggregation In single-node deployments: always returns true In multi-node clusters: uses distributed locking to coordinate Synchronized to prevent race conditions between concurrent job threads

startPeriodicLockUpdates

public ScheduledFuture<?> startPeriodicLockUpdates()

Start periodic updates to keep the lock alive during aggregation work Should be called at the start of aggregation work Only used in cluster environments

Returns:

ScheduledFuture that can be used to cancel the updates, or null if not in cluster

initTimer

public void initTimer()

Initialize and register Quartz jobs for metrics aggregation Called during application startup by AppInitializer

releaseClusterNode

@PreDestroy
public void releaseClusterNode()

Cleanup resources on shutdown Shuts down update executor if in cluster mode