import { GlobalConfig } from '@n8n/config';
import { DataSource } from '@n8n/typeorm';
import type { EntityManager } from '@n8n/typeorm';
import { BaseRepository } from './base-repository';
import { WorkflowPublicationOutbox, WorkflowPublicationOutboxStatus as Status, WorkflowPublicationReason } from '../entities/workflow-publication-outbox';
import type { OperationContext } from '../services/transaction';
import { TransactionRunner } from '../services/transaction';
export declare class WorkflowPublicationOutboxRepository extends BaseRepository<WorkflowPublicationOutbox> {
    private readonly globalConfig;
    constructor(dataSource: DataSource, globalConfig: GlobalConfig, transactionRunner: TransactionRunner);
    findInFlightByWorkflowId(workflowId: string, ctx?: OperationContext): Promise<WorkflowPublicationOutbox | null>;
    enqueue(workflowId: string, publishedVersionId: string, reason: WorkflowPublicationReason, trx?: EntityManager): Promise<void>;
    private enqueueWithPostgresUpsert;
    private enqueueWithSqliteUpsert;
    enqueueByWorkflowIds(workflowIds: string[], reason: WorkflowPublicationReason): Promise<void>;
    private enqueueByWorkflowIdsWithPostgresUpsert;
    private enqueueByWorkflowIdsWithSqliteUpsert;
    findVersionSkewedWorkflowIds(): Promise<string[]>;
    findTriggerStatusDriftedWorkflowIds(): Promise<string[]>;
    findUnreportedPublishedWorkflowIds(): Promise<string[]>;
    claimNextPendingRecord(): Promise<WorkflowPublicationOutbox | null>;
    private claimWithPostgresLocking;
    private claimWithSqliteTransaction;
    returnToPending(id: number): Promise<void>;
    markCompleted(id: number, ctx?: OperationContext, warningMessage?: string): Promise<void>;
    markFailed(id: number, errorMessage: string, ctx?: OperationContext): Promise<void>;
    markPartialSuccess(id: number, errorMessage: string, ctx?: OperationContext): Promise<void>;
    deleteTerminalOlderThan(completedRetentionSeconds: number, failedRetentionSeconds: number, batchSize: number): Promise<number>;
    private deleteTerminalWithPostgres;
    private deleteTerminalWithSqlite;
    getRecordStatsByStatus(): Promise<Map<Status, {
        count: number;
        oldestCreatedAt: Date;
    }>>;
    private parseTimestamp;
    private assertSingleRowAffected;
    private getTableName;
}