Package com.knezevic.edaf.v3.core.events

package com.knezevic.edaf.v3.core.events

Event bus, run events and sink contracts used for observability and persistence.

Supports synchronous and asynchronous sinks so optimization loops remain decoupled from telemetry transport/storage concerns.

Class	Description
AdaptiveActionEvent	Event emitted whenever adaptive control modifies exploration/restart behavior.
AsyncEventSink	Asynchronous wrapper around one sink with bounded queue and single worker.
CheckpointSavedEvent	Event emitted when a checkpoint is persisted.
EventBus	Thread-safe event fan-out used as the observability backbone.
EventSink	Consumer for run events used by persistence, console, and web adapters.
IterationCompletedEvent	Event emitted on each iteration with metrics and model diagnostics.
RunCompletedEvent	Event emitted when a run terminates.
RunEvent	Marker interface for all run lifecycle events.
RunFailedEvent	Event emitted when a run fails with an unrecoverable error.
RunResumedEvent	Event emitted when a run is resumed from checkpoint.
RunStartedEvent	Event emitted when a run starts.
RunStoppedEvent	Event emitted when a run is stopped cooperatively by user/API request.