com.nmontytskyi.monitoring.server.service.MetricsPersistenceService

@Service public class MetricsPersistenceService extends Object

Core service responsible for persisting incoming metric snapshots and triggering real-time anomaly detection for every saved record.

For each inbound MetricSnapshotRequest the service:

Maps the request to a MetricRecordEntity and persists it.
Fetches the 100 most recent records for the same service to build a historical baseline.
Delegates to AnomalyDetector for Z-score computation; updates anomaly and zScore fields when sufficient history is available (≥ 10 records).
Triggers alert evaluation via AlertEvaluationService.

Author:

Nazar Montytskyi

See Also:

Constructor Details
- MetricsPersistenceService
  
  public MetricsPersistenceService()
Method Details
- saveEndpointSnapshot
  
  @Transactional public MetricRecordResponse saveEndpointSnapshot(MetricSnapshotRequest request)
- saveEndpointSnapshot
  
  @Transactional public MetricRecordResponse saveEndpointSnapshot(MetricSnapshotRequest request, MetricRecordEntity.MetricSource source)
- saveBatch
  
  @Transactional public List<MetricRecordResponse> saveBatch(List<MetricSnapshotRequest> requests)
  
  Saves a batch of metric snapshots in a single transaction. Alert evaluation runs for each record individually.
- getLatest
  
  @Transactional(readOnly=true) public Optional<MetricRecordResponse> getLatest(Long serviceId)
- getAggregate
  
  @Transactional(readOnly=true) public AggregateMetricsResponse getAggregate(Long serviceId, LocalDateTime from, LocalDateTime to)

Class MetricsPersistenceService

Constructor Summary