@pgxsinkit/client
Classes
Section titled “Classes”- ClientDisposedError
- CommittedStoreUnreachableError
- DataExportDrainError
- ElectedEngineUnconstructibleError
- EngineRelocatedError
- EventPayloadInvalidError
- EventPayloadTooLargeError
- EventStreamsNotRegisteredError
- ExecutionLimitMismatchError
- InvalidStorePathError
- LazyRelationNotActivatedError
- LifecycleBusyError
- LiveRowsMaterializer
- NonPersistentStoreError
- ProvisionExpiredError
- ProvisionStalledError
- RestoreTargetExistsError
- StoreDestroyRefusedError
- StoreOwnershipWaitError
- StreamInbox
- UnknownEventStreamError
- WriteNotReadyError
Interfaces
Section titled “Interfaces”- AttachAckPayload
- AttachPayload
- AttachSyncClientOptions
- AuthTokenSnapshot
- BootReport
- BridgeCodec
- BridgeEnvelope
- BridgePort
- BufferedBatch
- ChangeLike
- CircuitsGroupSyncOptions
- CircuitsGroupSyncResult
- CircuitsShapeSpec
- CircuitsSyncHandle
- CircuitsSyncOptions
- CircuitsTableSyncResult
- CloneDumpPhases
- CloneDumpResult
- CommittedStoreUnreachableWire
- ConvergenceBarrier
- ConvergenceClient
- ConvergenceDriver
- ConvergenceDriverOptions
- ConvergenceTrigger
- CopyFromBlobStatementOptions
- CreatePgwasmClientOptions
- CreateSyncClientOptions
- DataExportDeps
- DataExportOptions
- DataExportReport
- DataExportResult
- DefineSyncWorkerOptions
- DiagnosticDumpReport
- DiagnosticExportDeps
- DiagnosticExportOptions
- DiagnosticExportResult
- DrainJournalOptions
- DrizzleQueryBuilder
- ElectedEngineWorker
- EventAppendResult
- EventBackoffOptions
- EventFlushDriver
- EventFlushDriverOptions
- EventFlushGate
- EventLaneBackoffTransition
- EventLaneDb
- EventLaneOptions
- EventLaneReport
- EventLaneRuntime
- EventLaneVerdict
- EventStreamFlushOptions
- ExecutionLimitConfig
- ExportArtefactWire
- ExportReportCommon
- FreshBootResolution
- GrantedStream
- GroupShapeSpec
- GuardedRawQuerySpec
- LazyGuardIndex
- LifecycleSlot
- LiveDiffPayload
- LiveDiffState
- LiveInitialPayload
- LiveQueryDiagnostics
- LiveRowsSubscription
- LocalStoreVersionEvent
- MutationDetail
- MutationDiagnostics
- MutationListOptions
- MutationListSubscription
- MutationsApi
- MutationsApiDeps
- MutationSummary
- MutationSummarySubscription
- OpfsEffects
- OpfsEffectsDeps
- OutboxStatus
- PreparedQueryResult
- PrepareQueryInput
- ProvisionAckPayload
- ProvisionPayload
- ProvisionStalledWire
- RawQueryOptions
- RawStatement
- RefusedStream
- ReplInspectionSurface
- ResolveStoreBootOptions
- RpcPayload
- RpcResultPayload
- SetOnlinePayload
- ShapeGroupBatch
- ShapeGroupOptions
- ShapeStreamSubscription
- ShapeSubscriptionRequest
- StoreBackupReport
- StoreBootResolution
- StoreDestructionRetryOptions
- StoreExportDeps
- StoreExportOptions
- StoreExportResult
- StoreWorkerQuiesceOptions
- StoreWorkerQuiesceOutcome
- StreamBatch
- StreamSourceOptions
- SubscribeLiveRowsInput
- SubscribePayload
- SubscriptionClientOptions
- SubscriptionSession
- SyncClient
- SyncClientTableHandle
- SyncTransaction
- SyncTransactionResult
- SyncTransactionTableHandle
- SyncWorkerHost
- TokenRequestPayload
- TokenResponsePayload
- WakePayload
- WorkerTokenCache
Type Aliases
Section titled “Type Aliases”- AllMutationsView
- AttachedSyncClient
- BridgeEvent
- BridgeMessageType
- BridgeTransferable
- DrainJournalOption
- EngineRelocatedOutcome
- ExportReport
- GuardedQueryFn
- JournalTable
- LocalMetaTable
- MutationBatchItem
- MutationKind
- MutationSummaryDetail
- OutboxTable
- OverlayTable
- PgwasmClient
- ReadModelView
- ResolvedStorageBackend
- RpcOp
- ShapeGroup
- StoreEngineFactory
- StoreEngineModuleLoader
- StreamErrorHandler
- SyncStateView
Variables
Section titled “Variables”- BRIDGE_CHANNEL
- BRIDGE_PROTOCOL_VERSION
- COMMITTED_STORE_UNREACHABLE_CODE
- DEFAULT_DRAIN_TIMEOUT_MS
- DEFAULT_EVENT_BACKOFF_BASE_MS
- DEFAULT_EVENT_BACKOFF_CEILING_MS
- DEFAULT_EVENT_BATCH_SIZE
- DEFAULT_EVENT_FLUSH_INTERVAL_MS
- ENGINE_RELOCATED_CODE
- identityCodec
- OUTBOX_SEQUENCE
- OUTBOX_TABLE
- PROVISION_STALLED_CODE
- STORE_OWNERSHIP_WAIT_MS
- STREAM_START
Functions
Section titled “Functions”- assertLazyRefsActivated
- attachSyncClient
- buildCopyFromBlobStatement
- buildLazyGuardIndex
- buildRegistryReadHandles
- classifyEventBatchFailure
- committedStoreUnreachableFromWire
- computeEventBackoffMs
- computeLiveDiff
- createBarrierReader
- createBrowserConvergenceTrigger
- createConvergenceDriver
- createEventFlushDriver
- createEventLaneRuntime
- createIntervalConvergenceTrigger
- createLifecycleSlot
- createMutationsApi
- createOpfsEffects
- createPgwasmClient
- createShapeGroup
- createStoreEngineResolver
- createSyncClient
- createTokenRecovery
- createWorkerTokenCache
- defineSyncWorker
- deriveBatchEventUrl
- deriveStoreId
- destroyStoreArtifacts
- encodeEnvelope
- envelopeToChange
- findReferencedLazyKeysInSql
- findReferencedSyncedKeysInSql
- generateCopyData
- generateLocalSchemaSql
- getAllMutationsView
- getJournalTable
- getLocalMetaTable
- getOutboxTable
- getOverlayTable
- getReadModelView
- getSyncedLocalTable
- getSyncStateView
- isBridgeEnvelope
- loadStoreEngineFactory
- openSubscriptionSession
- parseRetryAfterMs
- performDatadirDump
- performDataExport
- performDiagnosticExport
- performStoreExport
- postBridgeMessage
- primaryKeyFromStreamKey
- provisionStalledFromWire
- provisionSyncWorker
- quiesceStoreWorker
- readShapeStream
- replAdapter
- resolveBatchEventUrl
- resolveStoreBoot
- resolveStoreDataDir
- rowKey
- runFreshCommitmentBarrier
- runThrowawayCloneDump
- seedLiveDiffState
- serializeCopyValue
- setSyncDebugSink
- startCircuitsSync
- storeIndexedDbDatabaseName
- storeTargetExists
- syncCircuitsShapes
- syncDebug
- timeAsync
- wrapEngineWorker
- wrapLiveQueryForMaterialization