Overview @nestjs-expand @nestjs-pg-pubsub API

Overview @nestjs-expand @nestjs-pg-pubsub API

Expandable Expander ExpanderMethods RegisterPgTableChangeListener Selectable UseExpansionMethod

NestKitExpandModule PgLockService PgPubSubModule PgPubSubService

ListenerDiscovery LockOptions PgTableChangeContext PgTableChangeListener PoolConfig QueueConfig QueuedMessage ResolvedListener TableListener TransactionAdapter TriggerMetadata

DiscoveredPgTableChangeListener ExpandableParams ExpandConfig ExpandContext ExpanderMethodsParams ExpandErrorPolicy ExpansionError ExpansionErrorFormatter ExpansionErrorHandlingConfig PgPubSubConfig PgTableChangeErrorHandler PgTableChangePayload PgTableChanges PgTableChangeType PgTableDeletePayload PgTableInsertPayload PgTableUpdatePayload RegisterPgTableChangeListenerMetadata ReusableExpandMethod SelectableParams StandardExpandMethod UseExpansionMethodConfig UseExpansionMethodMetadata

DEFAULT_EXPAND_CONFIG EXPAND_CONFIG EXPANDABLE_KEY EXPANDER_KEY EXPANDER_METHODS_KEY PG_PUBSUB_CONFIG PG_PUBSUB_DRAIN_INTERVAL PG_PUBSUB_FALLBACK_POLLING_INTERVAL PG_PUBSUB_LOCK_DURATION PG_PUBSUB_POOL_MAX PG_PUBSUB_QUEUE_BATCH_SIZE PG_PUBSUB_QUEUE_CLEANUP_INTERVAL PG_PUBSUB_QUEUE_CONCURRENCY PG_PUBSUB_QUEUE_MAX_RETRIES PG_PUBSUB_QUEUE_MESSAGE_TTL PG_PUBSUB_QUEUE_PROCESSING_TIMEOUT PG_PUBSUB_QUEUE_SCHEMA PG_PUBSUB_QUEUE_TABLE PG_PUBSUB_TRIGGER_NAME PG_PUBSUB_TRIGGER_SCHEMA RegisterPgTableChangeListenerMeta SELECTABLE_KEY USE_EXPANSION_METHOD_KEY

NestKit/API/Variables/PG_PUBSUB_QUEUE_BATCH_SIZE

Open in ChatGPT Open in Claude

PG_PUBSUB_QUEUE_BATCH_SIZE

const

Default batch size for fetching pending messages.

typescript

const PG_PUBSUB_QUEUE_BATCH_SIZE: 100

← PreviousPG_PUBSUB_POOL_MAX Next →PG_PUBSUB_QUEUE_CLEANUP_INTERVAL

Powered byngedoc