This module provides a decentralized, pull-based subscription system where each subscriber is a self-contained agent.

Design

The architecture consists of two main components:

1. The Notifier: A single, lightweight process that listens for a generic "new event" notification from PostgreSQL and broadcasts a simple "tick" to all active subscribers.
2. The Subscriber Worker: Each subscription runs in its own thread. The worker pulls data from the database in a unified loop, naturally handling both catch-up and real-time processing. It is responsible for its own state management and data fetching.

This design eliminates the complexity and bottlenecks of a centralized manager, provides inherent backpressure, and leverages the database for efficient filtering.