Module realtime

@honua/sdk-js/realtime — realtime transport adapters. Raw Server-Sent Events (sse.ts) and WebSocket (websocket.ts) wire adapters pair with the bounded, resumable wrapper in resumable-transport.ts (issue #557), which adds the #556 delivery gate, reconnect/backoff, heartbeat timeout, and redacted telemetry on top of either one. odata-delta.ts (issue #558) adds a pull-based OData v4 delta-link adapter with its own bounded poll loop and honest, non-live freshness reporting — it satisfies the same RealtimeFeatureTransport surface but is not a socket transport, so it does not compose with resumable-transport.ts's reconnect wrapper.

Index

Classes

HonuaRealtimeReconciliationError HonuaRealtimeResumeError

Interfaces

CreateHonuaServerRealtimeSubscriptionOptions CreateResumableRealtimeSubscriptionOptions DeriveRealtimeContractAuthorityOptions HonuaServerFeatureChange HonuaServerFeatureChangeEnvelope IndexedDbRealtimeCheckpointStoreOptions OdataDeltaEntity OdataDeltaInitialQuery OdataDeltaPollTelemetry OdataDeltaTransportOptions RealtimeCheckpointCompatibility RealtimeCheckpointRecordStorage RealtimeCheckpointRecordV1 RealtimeCheckpointStore RealtimeCheckpointStoreDiagnosticV1 RealtimeCheckpointStoreHandle RealtimeCheckpointStoreOptions RealtimeContractAuthority RealtimeDeleteEvent RealtimeDeletePatch RealtimeDeltaEvent RealtimeDetailSelectorOptions RealtimeDetailState RealtimeDurableCheckpointV1 RealtimeErrorEvent RealtimeFeatureEventBase RealtimeFeatureObserver RealtimeFeaturePatch RealtimeFeatureRecord RealtimeFeatureRecordSelectorOptions RealtimeFeatureReference RealtimeFeatureState RealtimeFeatureStore RealtimeFeatureTombstone RealtimeFeatureTransport RealtimeHeartbeatEvent RealtimeKeyedStateReconciliation RealtimeReconciledCache RealtimeReconciledCacheSnapshot RealtimeReconciler RealtimeReconcilerOptions RealtimeReconciliationChange RealtimeReconciliationDiff RealtimeReconciliationInvalidation RealtimeReconciliationResult RealtimeReconciliationVersion RealtimeReconnectPolicy RealtimeReducerOptions RealtimeResumableTransportOptions RealtimeResumableTransportTelemetry RealtimeResumeCheckpoint RealtimeResumeContextV1 RealtimeServerSentEventSource RealtimeServerSentEventsTransportOptions RealtimeSnapshotEvent RealtimeStalenessOptions RealtimeStatusEvent RealtimeStoredResumePosition RealtimeSubscriptionHandle RealtimeSubscriptionIdentity RealtimeSubscriptionRequest RealtimeTransportCapabilities RealtimeUpsertEvent RealtimeViewportReconciliation RealtimeWebSocket RealtimeWebSocketCloseEvent RealtimeWebSocketTransportOptions RedactedRealtimeCheckpointV1 RedactedRealtimeResumePosition ResumableRealtimeDelivery ResumableRealtimeState ResumableRealtimeSubscription

Type Aliases

RealtimeCheckpointCompatibilityCode RealtimeCheckpointStoreReason RealtimeConnectionStatus RealtimeContractAuthorityState RealtimeExternalResnapshotReason RealtimeFeatureEvent RealtimeReconciliationChangeKind RealtimeReconciliationErrorCode RealtimeReconciliationInvalidationReason RealtimeReconciliationMode RealtimeReconciliationRebuildReason RealtimeReconciliationResetReasonCode RealtimeReconciliationTrigger RealtimeResumeMode RealtimeSequencedEvent RealtimeServerSentEventSourceFactory RealtimeStateListener RealtimeSubscriptionMode RealtimeTransportKind RealtimeWebSocketFactory RedactedResumePosition ResumableRealtimeDeliveryStatus ResumableRealtimePhase ResumableRealtimeReasonCode

Variables

DEFAULT_REALTIME_CHECKPOINT_MAX_AGE_MS DEFAULT_REALTIME_CHECKPOINT_MAX_RECORDS HONUA_REALTIME_CHECKPOINT_STORE_FORMAT HONUA_SERVER_STREAMING_FEATURES_PATH MAX_REALTIME_CHECKPOINT_MAX_AGE_MS MAX_REALTIME_CHECKPOINT_RECORDS REALTIME_DURABLE_CHECKPOINT_VERSION

Functions

assertRealtimePlanIdentity computeReconnectDelayMs createHonuaServerRealtimeSubscription createIndexedDbCheckpointStorage createIndexedDbRealtimeCheckpointStore createMemoryCheckpointStorage createMemoryRealtimeCheckpointStore createOdataDeltaTransport createRealtimeCheckpointStore createRealtimeFeatureStore createRealtimeReconciledCache createRealtimeReconciler createRealtimeServerSentEventsTransport createRealtimeWebSocketTransport createResumableRealtimeSubscription createResumableRealtimeTransport createResumableServerSentEventsTransport createResumableWebSocketTransport decodeHonuaServerRealtimeEvent decodeRealtimeServerSentEvent deriveRealtimeContractAuthority diffRealtimeFeatureState emptyRealtimeFeatureState encodeDefaultRealtimeRequest encodeHonuaServerRealtimeRequest evaluateRealtimeCheckpoint filterRealtimeSelection honuaServerRealtimePreset realtimeAuthorizationScopeDigest realtimeCheckpointScopeKey realtimeFeatureKey realtimePlanFingerprint realtimeReconciliationVersion realtimeResumeCheckpoint realtimeSubscriptionKey reconcileRealtimeKeyedState reconcileRealtimeSelection reconcileRealtimeStaleness reconcileRealtimeViewport redactRealtimeCheckpoint reduceRealtimeFeatureState selectRealtimeDetail selectRealtimeFeatureRecordMap selectRealtimeFeatureRecords selectRealtimeFeatures selectRealtimeFeatureTombstones serializeRealtimeCheckpoint serializeRedactedRealtimeCheckpoint

Settings

Member Visibility