@pgxsinkit/server
Classes
Section titled “Classes”- CircuitsEngineError
- CircuitsLeaseConfigError
- EntitlementsUnavailableError
- FetchRouter
- MalformedEventQueueMessageError
Interfaces
Section titled “Interfaces”- ApplyFunctionRenderOptions
- CircuitsEngineOptions
- CircuitsShapeHandle
- CorsConfig
- CreateEventIngestHandlerOptions
- CreatePgmqEventQueueOptions
- CreateShapeRequest
- CreateSyncServerOptions
- DeadLetteredEventMessage
- DefineEventConsumerOptions
- DeliveredEventMessage
- DeniedSubscription
- DeploymentProfile
- EntitlementSet
- EventConsumer
- EventConsumerBatch
- EventConsumerPollOptions
- EventDeadLetterReport
- EventDrainOptions
- EventDrainSummary
- EventGateInput
- EventIngestDb
- EventPollReport
- EventQueue
- EventQueueExecutor
- EventQueueReadOptions
- EventsEnqueuedInfo
- GrantedSubscription
- MintStreamTokenOptions
- RefreshResult
- ServerDiagnostics
- ShapeRequest
- StreamGateOptions
- StreamGrant
- StreamTokenClaims
- SubscribeOptions
- SubscribeResult
- SubscriptionRequest
- SyncServer
- VerifyStreamTokenOptions
Type Aliases
Section titled “Type Aliases”- CircuitsEngineClient
- CompiledShapeRequest
- CorsScope
- EventConsumerCallback
- EventConsumerSleep
- EventGate
- EventGateDecision
- EventQueueReceipt
- EventsEnqueuedHook
- FetchHandler
- GateDecision
- IdentityResolution
- OperationsLogStartupMode
- RouterErrorHandler
- StartupVerificationMode
- StreamAuthorizationOptions
- StreamTokenVerification
Variables
Section titled “Variables”- authoritativeMutationPaths
- barrierPath
- batchMutationPaths
- DEFAULT_EVENT_CONSUMER_BATCH_SIZE
- DEFAULT_EVENT_DRAIN_BUDGET_MS
- DEFAULT_EVENT_MAX_ATTEMPTS
- DEFAULT_EVENT_POLL_CEILING_MS
- DEFAULT_EVENT_POLL_FACTOR
- DEFAULT_EVENT_POLL_FLOOR_MS
- DEFAULT_EVENT_VISIBILITY_TIMEOUT_SECONDS
- DEFAULT_STREAM_TOKEN_TTL_SECONDS
- EVENT_LANE_FINGERPRINT_PREFIX
- EVENT_QUEUE_UNAVAILABLE_RETRY_AFTER_SECONDS
- operationsLogTable
- PGMQ_DEAD_LETTER_KEY
- refreshPath
- releasePath
- STREAM_READ_EXPOSED_HEADERS
- subscribePath
Functions
Section titled “Functions”- assertEventQueueReceipts
- authorizeStreamRead
- buildPlpgsqlBatchFunctionDdl
- buildRegistrySchema
- compileShapeRequest
- computeEventPollWaitMs
- createBarrierHandler
- createCircuitsEngineClient
- createEventIngestHandler
- createMutationHandler
- createPgmqEventQueue
- createRefreshHandler
- createReleaseHandler
- createStreamGate
- createSubscribeHandler
- createSyncServer
- defineEventConsumer
- ensureOperationsLogSchema
- eventIngestRequiresClaims
- eventLaneDdlFingerprint
- eventLaneStreamNames
- eventStreamQueueName
- expectedApplyFingerprint
- findGrant
- fingerprintShapeRequest
- importStreamTokenKey
- mintStreamToken
- operationsLogRegclassTarget
- readSqlState
- readStreamToken
- refreshStreamToken
- releaseStreamGrants
- renderEventLaneMigration
- renderPgxsinkitUtilitiesMigration
- resolveEntryByShapeKey
- resolveEventIdentity
- subscribeToShapes
- verifyStreamToken