/**
 * @param {string} id - Run id.
 * @returns {void}
 */
export function registerActiveDeploymentRun(id: string): void;
/**
 * @param {string} id - Run id.
 * @returns {void}
 */
export function unregisterActiveDeploymentRun(id: string): void;
/**
 * @param {number} staleRunTimeoutMs - Lease duration.
 * @returns {number} Heartbeat interval strictly below the lease.
 */
export function heartbeatIntervalMs(staleRunTimeoutMs: number): number;
/**
 * @param {{activeRunIds: Set<string>, nowMs: number, run: {heartbeatAtMs: number|null, id: string, launchProtectedUntilMs?: number|null, requestedAtMs: number, status?: string}, staleRunTimeoutMs: number}} args - Lease data.
 * @returns {boolean} Whether ownership expired.
 */
export function isRunLeaseExpired({ activeRunIds: localIds, nowMs, run, staleRunTimeoutMs }: {
    activeRunIds: Set<string>;
    nowMs: number;
    run: {
        heartbeatAtMs: number | null;
        id: string;
        launchProtectedUntilMs?: number | null;
        requestedAtMs: number;
        status?: string;
    };
    staleRunTimeoutMs: number;
}): boolean;
/**
 * @param {{id: string, mountIdentifier: string, ownerToken: string}} args - Fence identifiers.
 * @returns {Record<string, unknown>} Update conditions.
 */
export function terminalTransitionConditions({ id, mountIdentifier, ownerToken }: {
    id: string;
    mountIdentifier: string;
    ownerToken: string;
}): Record<string, unknown>;
/**
 * Includes the observed heartbeat so a concurrent renewal defeats stale reconciliation.
 *
 * @param {{mountIdentifier: string, run: Pick<DeploymentRunRow, 'heartbeatAtMs'|'id'|'ownerToken'|'status'>}} args - Fence data.
 * @returns {Record<string, unknown>} Update conditions.
 */
export function reconciliationConditions({ mountIdentifier, run }: {
    mountIdentifier: string;
    run: Pick<DeploymentRunRow, "heartbeatAtMs" | "id" | "ownerToken" | "status">;
}): Record<string, unknown>;
/** Rampway-owned durable deployment state stored through Velocious's database abstraction. */
export default class DeploymentRunStore {
    /**
     * @param {object} args - Store options.
     * @param {any} args.configuration - Velocious configuration.
     * @param {string} [args.databaseIdentifier] - Database identifier.
     * @param {string} args.mountIdentifier - Authenticated mount scope.
     * @param {number} args.staleRunTimeoutMs - Lease duration.
     */
    constructor({ configuration, databaseIdentifier, mountIdentifier, staleRunTimeoutMs }: {
        configuration: any;
        databaseIdentifier?: string | undefined;
        mountIdentifier: string;
        staleRunTimeoutMs: number;
    });
    configuration: any;
    databaseIdentifier: string;
    mountIdentifier: string;
    staleRunTimeoutMs: number;
    /** @type {Promise<void>|null} */
    readyPromise: Promise<void> | null;
    /** @returns {Promise<void>} */
    ensureReady(): Promise<void>;
    /**
     * Adds the handoff lease to databases created by the previous API schema.
     *
     * @param {any} db - Open Velocious database connection.
     * @returns {Promise<void>}
     */
    _ensureLaunchProtectionColumn(db: any): Promise<void>;
    /** @param {any} db @returns {Promise<void>} */
    _ensureExpectedActiveRevisionColumn(db: any): Promise<void>;
    /**
     * @param {string} id - Run id.
     * @returns {Promise<DeploymentRunRow|null>} Run.
     */
    findRunById(id: string): Promise<DeploymentRunRow | null>;
    /**
     * @param {string} key - Idempotency key.
     * @returns {Promise<DeploymentRunRow|null>} Run.
     */
    findRunByKey(key: string): Promise<DeploymentRunRow | null>;
    /**
     * Serializes admission by target then by mount-global idempotency key.
     *
     * @param {{idempotencyKey: string, project: string, revision: string, expectedActiveRevision?: string|null, stage: string}} args - Run request.
     * @returns {Promise<{outcome: string, run: DeploymentRunRow|null}>} Admission result.
     */
    createRunIfPossible({ idempotencyKey, project, revision, expectedActiveRevision, stage }: {
        idempotencyKey: string;
        project: string;
        revision: string;
        expectedActiveRevision?: string | null;
        stage: string;
    }): Promise<{
        outcome: string;
        run: DeploymentRunRow | null;
    }>;
    /**
     * @param {{id: string, startedAtMs: number}} args - Cross-process worker claim.
     * @returns {Promise<DeploymentRunRow>} Claimed run.
     */
    claimPendingRun({ id, startedAtMs }: {
        id: string;
        startedAtMs: number;
    }): Promise<DeploymentRunRow>;
    /** @param {{id: string, startedAtMs: number}} args - Transition. @returns {Promise<void>} */
    markRunning({ id, startedAtMs }: {
        id: string;
        startedAtMs: number;
    }): Promise<void>;
    /** @param {{id: string, ownerToken: string, finishedAtMs: number, error: any}} args - Launch failure. @returns {Promise<void>} */
    markPendingFailed({ id, ownerToken, finishedAtMs, error }: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        error: any;
    }): Promise<void>;
    /** @param {{id: string, finishedAtMs: number, error: any}} args - Pre-claim worker failure. @returns {Promise<void>} */
    failPendingRun({ id, finishedAtMs, error }: {
        id: string;
        finishedAtMs: number;
        error: any;
    }): Promise<void>;
    /** @param {{id: string, heartbeatAtMs: number}} args - Heartbeat. @returns {Promise<void>} */
    heartbeat({ id, heartbeatAtMs }: {
        id: string;
        heartbeatAtMs: number;
    }): Promise<void>;
    /** @param {{id: string, ownerToken: string, finishedAtMs: number, result: any}} args - Transition. @returns {Promise<void>} */
    markSucceeded({ id, ownerToken, finishedAtMs, result }: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        result: any;
    }): Promise<void>;
    /** @param {{id: string, ownerToken: string, finishedAtMs: number, error: any}} args - Transition. @returns {Promise<void>} */
    markFailed({ id, ownerToken, finishedAtMs, error }: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        error: any;
    }): Promise<void>;
    /** @param {{id: string, ownerToken: string, finishedAtMs: number, error: any}} args - Transition. @returns {Promise<void>} */
    markReconciliationRequired({ id, ownerToken, finishedAtMs, error }: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        error: any;
    }): Promise<void>;
    /** @param {{event: string, payload: any, runId: string|null}} args - Audit event. @returns {Promise<void>} */
    addAuditEvent({ event, payload, runId }: {
        event: string;
        payload: any;
        runId: string | null;
    }): Promise<void>;
    /**
     * @param {{runId: string}} args - Query.
     * @returns {Promise<Array<Record<string, any>>>} Events.
     */
    listAuditEvents({ runId }: {
        runId: string;
    }): Promise<Array<Record<string, any>>>;
    /**
     * @param {any} db - Open Velocious database connection.
     * @param {DeploymentRunRow} run - Observed stale run.
     * @returns {Promise<boolean>} Whether this reconciler won.
     */
    _reconcileExpiredRun(db: any, run: DeploymentRunRow): Promise<boolean>;
    /**
     * Reconciles an expired pending/running owner before returning durable state.
     *
     * @param {any} db - Open Velocious database connection.
     * @param {DeploymentRunRow|null} run - Observed run.
     * @returns {Promise<DeploymentRunRow|null>} Current durable run.
     */
    _reconcileExpiredRunIfNeeded(db: any, run: DeploymentRunRow | null): Promise<DeploymentRunRow | null>;
    /** @param {{data: Record<string, any>, id: string, ownerToken: string}} args - Transition. @returns {Promise<void>} */
    _transition({ data, id, ownerToken }: {
        data: Record<string, any>;
        id: string;
        ownerToken: string;
    }): Promise<void>;
    /**
     * @param {string} kind - Lock kind.
     * @param {string} value - Scoped value.
     * @returns {string} Lock name.
     */
    _lockName(kind: string, value: string): string;
    /**
     * @param {any} db - Connection.
     * @param {string} id - Run id.
     * @returns {Promise<DeploymentRunRow|null>} Run.
     */
    _findRunById(db: any, id: string): Promise<DeploymentRunRow | null>;
    /**
     * @param {any} db - Connection.
     * @param {string} key - Idempotency key.
     * @returns {Promise<DeploymentRunRow|null>} Run.
     */
    _findRunByKey(db: any, key: string): Promise<DeploymentRunRow | null>;
    /**
     * @param {any} db - Connection.
     * @param {{project: string, stage: string}} args - Target.
     * @returns {Promise<DeploymentRunRow|null>} Run.
     */
    _findBlockingRun(db: any, { project, stage }: {
        project: string;
        stage: string;
    }): Promise<DeploymentRunRow | null>;
    /**
     * @param {Record<string, any>} row - Database row.
     * @returns {DeploymentRunRow} Run.
     */
    _row(row: Record<string, any>): DeploymentRunRow;
    /**
     * @param {string} context - Context.
     * @param {unknown} error - Failure.
     * @returns {void}
     */
    _emitFrameworkError(context: string, error: unknown): void;
    /**
     * @template T
     * @param {(db: any) => Promise<T>} callback - Work.
     * @returns {Promise<T>} Result.
     */
    _withDb<T>(callback: (db: any) => Promise<T>): Promise<T>;
}
export type DeploymentRunRow = {
    id: string;
    mountIdentifier: string;
    project: string;
    stage: string;
    revision: string;
    expectedActiveRevision: string | null;
    idempotencyKey: string;
    status: string;
    result: any;
    error: any;
    requestedAtMs: number;
    startedAtMs: number | null;
    finishedAtMs: number | null;
    ownerToken: string | null;
    heartbeatAtMs: number | null;
    launchProtectedUntilMs: number | null;
};
export type DeploymentRunStoreContract = {
    findRunById: (id: string) => Promise<DeploymentRunRow | null>;
    findRunByKey: (key: string) => Promise<DeploymentRunRow | null>;
    createRunIfPossible: (args: {
        idempotencyKey: string;
        project: string;
        revision: string;
        expectedActiveRevision?: string | null;
        stage: string;
    }) => Promise<{
        outcome: string;
        run: DeploymentRunRow | null;
    }>;
    markRunning: (args: {
        id: string;
        startedAtMs: number;
    }) => Promise<void>;
    claimPendingRun: (args: {
        id: string;
        startedAtMs: number;
    }) => Promise<DeploymentRunRow>;
    heartbeat: (args: {
        id: string;
        heartbeatAtMs: number;
    }) => Promise<void>;
    markPendingFailed: (args: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        error: any;
    }) => Promise<void>;
    failPendingRun: (args: {
        id: string;
        finishedAtMs: number;
        error: any;
    }) => Promise<void>;
    markSucceeded: (args: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        result: any;
    }) => Promise<void>;
    markFailed: (args: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        error: any;
    }) => Promise<void>;
    markReconciliationRequired: (args: {
        id: string;
        ownerToken: string;
        finishedAtMs: number;
        error: any;
    }) => Promise<void>;
    addAuditEvent: (args: {
        event: string;
        payload: any;
        runId: string | null;
    }) => Promise<void>;
};
export const AUDIT_TABLE: "rampway_deployment_api_audit_events";
/**
 * @typedef {object} DeploymentRunRow
 * @property {string} id
 * @property {string} mountIdentifier
 * @property {string} project
 * @property {string} stage
 * @property {string} revision
 * @property {string|null} expectedActiveRevision
 * @property {string} idempotencyKey
 * @property {string} status
 * @property {any} result
 * @property {any} error
 * @property {number} requestedAtMs
 * @property {number|null} startedAtMs
 * @property {number|null} finishedAtMs
 * @property {string|null} ownerToken
 * @property {number|null} heartbeatAtMs
 * @property {number|null} launchProtectedUntilMs
 */
/**
 * @typedef {object} DeploymentRunStoreContract
 * @property {(id: string) => Promise<DeploymentRunRow|null>} findRunById
 * @property {(key: string) => Promise<DeploymentRunRow|null>} findRunByKey
 * @property {(args: {idempotencyKey: string, project: string, revision: string, expectedActiveRevision?: string|null, stage: string}) => Promise<{outcome: string, run: DeploymentRunRow|null}>} createRunIfPossible
 * @property {(args: {id: string, startedAtMs: number}) => Promise<void>} markRunning
 * @property {(args: {id: string, startedAtMs: number}) => Promise<DeploymentRunRow>} claimPendingRun
 * @property {(args: {id: string, heartbeatAtMs: number}) => Promise<void>} heartbeat
 * @property {(args: {id: string, ownerToken: string, finishedAtMs: number, error: any}) => Promise<void>} markPendingFailed
 * @property {(args: {id: string, finishedAtMs: number, error: any}) => Promise<void>} failPendingRun
 * @property {(args: {id: string, ownerToken: string, finishedAtMs: number, result: any}) => Promise<void>} markSucceeded
 * @property {(args: {id: string, ownerToken: string, finishedAtMs: number, error: any}) => Promise<void>} markFailed
 * @property {(args: {id: string, ownerToken: string, finishedAtMs: number, error: any}) => Promise<void>} markReconciliationRequired
 * @property {(args: {event: string, payload: any, runId: string|null}) => Promise<void>} addAuditEvent
 */
export const RUNS_TABLE: "rampway_deployment_runs";
//# sourceMappingURL=run-store.d.ts.map