Module realtime 

Real-time subscription system.

Forge provides automatic real-time updates via PostgreSQL LISTEN/NOTIFY. When tables change, affected subscriptions are invalidated and re-executed.

Architecture

Client                Gateway                  PostgreSQL
  │                      │                         │
  │─── Subscribe ───────>│                         │
  │                      │── Execute query ───────>│
  │<── Initial data ─────│<── Results ────────────│
  │                      │                         │
  │                      │<── NOTIFY on change ───│
  │                      │── Re-execute query ───>│
  │<── Delta update ─────│<── New results ────────│

Key Types

• ReadSet - Tables a subscription depends on
• SessionInfo - WebSocket connection state
• SubscriptionInfo - Active subscription with query parameters
• Delta - Change payload sent to clients

Structs

Change

A database change event.

Delta

Delta format for subscription updates.

ReadSet

Read set tracking tables and rows read during query execution.

SessionId

Unique session identifier.

SessionInfo

Information about a WebSocket session.

SubscriptionId

Unique subscription identifier.

SubscriptionInfo

Information about a server-side subscription.

SubscriptionState

Subscription state from the client’s perspective.

Enums

ChangeOperation

Change operation type.

SessionStatus

Session status.

TrackingMode

Tracking mode for read sets.