import { Result } from "../common/result";
export interface ConcurrencyControl {
    checkVersionConflict(aggregateId: string, expectedVersion: number, currentVersion: number): Promise<Result<boolean>>;
    resolveVersionConflict(aggregateId: string, expectedVersion: number, currentVersion: number): Promise<Result<number>>;
    getCurrentVersion(aggregateId: string): Promise<Result<number>>;
    incrementVersion(aggregateId: string): Promise<Result<number>>;
}
export declare class VersionConflictError extends Error {
    readonly aggregateId: string;
    readonly expectedVersion: number;
    readonly currentVersion: number;
    constructor(aggregateId: string, expectedVersion: number, currentVersion: number);
}
export interface OptimisticLock {
    acquire(aggregateId: string, timeout?: number): Promise<Result<void>>;
    release(aggregateId: string): Promise<Result<void>>;
    isLocked(aggregateId: string): Promise<Result<boolean>>;
    getLockInfo(aggregateId: string): Promise<Result<LockInfo>>;
}
export interface LockInfo {
    readonly aggregateId: string;
    readonly acquiredAt: Date;
    readonly timeout: number;
    readonly acquiredBy?: string;
}
export declare abstract class BaseConcurrencyControl implements ConcurrencyControl {
    checkVersionConflict(aggregateId: string, expectedVersion: number, currentVersion: number): Promise<Result<boolean>>;
    resolveVersionConflict(aggregateId: string, expectedVersion: number, currentVersion: number): Promise<Result<number>>;
    abstract getCurrentVersion(aggregateId: string): Promise<Result<number>>;
    abstract incrementVersion(aggregateId: string): Promise<Result<number>>;
}