/** * Scheduled Actions - Processor * Processes pending actions with parallel execution and lock-group based locking * * Features: * - Controlled parallelism with configurable concurrency limit * - Lock-group based locking to prevent race conditions on same resource * - SELECT FOR UPDATE SKIP LOCKED for safe concurrent processing * - Timeout protection per action */ import type { ScheduledAction, ProcessResult } from './types'; /** * Process pending actions with parallel execution * Uses SELECT FOR UPDATE SKIP LOCKED for safe concurrent processing * * Lock Group Behavior: * - Actions with same lockGroup are processed sequentially * - Actions with NULL lockGroup can run in parallel with any other action * - Uses PostgreSQL row-level locking to prevent race conditions * * @param batchSize - Maximum number of actions to process (uses config default if not provided) * @returns Result with counts and errors * * @example * const result = await processPendingActions() * console.log(`Processed ${result.processed}, succeeded ${result.succeeded}, failed ${result.failed}`) */ export declare function processPendingActions(batchSize?: number): Promise; /** * Execute a single action * Handles the full lifecycle of action execution */ export declare function executeAction(action: ScheduledAction): Promise; //# sourceMappingURL=processor.d.ts.map