Module realtime

Structs§

AdaptiveTracker: Adaptive tracker that switches between table and row-level tracking.
AdaptiveTrackingConfig: Configuration for adaptive tracking.
AdaptiveTrackingStats: Statistics about adaptive tracking.
ChangeListener: Listens for database changes via PostgreSQL LISTEN/NOTIFY.
InvalidationConfig: Configuration for the invalidation engine.
InvalidationEngine: Engine for determining which query groups need re-execution. Operates on groups (not individual subscriptions) for O(groups) cost.
JobData: Job data sent to client (subset of internal JobRecord).
ListenerConfig: Change listener configuration.
Reactor: ChangeListener -> InvalidationEngine -> Group Re-execution -> SSE Fan-out
ReactorConfig
ReactorStats: Reactor statistics.
RealtimeConfig
SessionManager: Session manager for tracking WebSocket connections.
SessionServer
SessionStats: Session server statistics.
SubscriptionManager: Group-based subscription manager using sharded concurrent data structures.
WorkflowData: Workflow data sent to client.
WorkflowStepData: Workflow step data sent to client.