import type { LiveMapAnyOp, LiveMapCommit } from "../../types/livemap.types.js";
import { type PreparedLiveMapTransition } from "../livemap/livemap.authority.js";
export type LocusAuthorityMutationSource = "locus" | "action" | "document-action" | "link" | "checkpoint";
export type LocusAuthorityGateInput<TMap extends object> = Readonly<{
    map: TMap;
    transition: PreparedLiveMapTransition;
    commit: LiveMapCommit<LiveMapAnyOp>;
    baseRevision: number;
    nextRevision: number;
}>;
export type LocusAuthorityGate<TMap extends object> = (input: LocusAuthorityGateInput<TMap>) => void | Promise<void>;
export type LocusAuthorityErrorCode = "LOCUS_AUTHORITY_ALREADY_MANAGED" | "LOCUS_AUTHORITY_CLOSED" | "LOCUS_AUTHORITY_GATE_REJECTED" | "LOCUS_AUTHORITY_TERMINAL" | "LOCUS_AUTHORITY_ACCEPTED_INGESTION_FAILED";
export declare class LocusAuthorityError extends Error {
    readonly code: LocusAuthorityErrorCode;
    constructor(code: LocusAuthorityErrorCode, message: string, options?: ErrorOptions);
}
export type LocusAuthorityEvent = Readonly<{
    phase: "enqueued" | "prepared" | "gate-started" | "gate-completed" | "gate-failed" | "accepted" | "notification-failed" | "failed" | "released";
    source: LocusAuthorityMutationSource;
    queueDepth: number;
    baseRevision?: number;
    nextRevision?: number;
    changed?: boolean;
    errorCode?: string;
}>;
export type LocusExclusiveAuthority<TMap extends object, TContext = undefined> = Readonly<{
    mutate: (mutation: (draft: TMap) => LiveMapCommit<LiveMapAnyOp>, source?: LocusAuthorityMutationSource, context?: TContext) => Promise<LiveMapCommit<LiveMapAnyOp>>;
    runExclusive: <TResult>(operation: () => TResult | Promise<TResult>) => Promise<TResult>;
    dispose: () => void;
    closed: Promise<void>;
    readonly failed: boolean;
}>;
/** One Locus-scoped FIFO authority queue with one future durability gate. */
export declare function make_locus_exclusive_authority<TMap extends object, TContext = undefined>(map: TMap, options: Readonly<{
    gate?: LocusAuthorityGate<TMap>;
    accepted: (commit: LiveMapCommit<LiveMapAnyOp>, notificationFailureCount: number, source: LocusAuthorityMutationSource, context: TContext | undefined) => void;
    event?: (event: LocusAuthorityEvent) => void;
    afterGate?: (transition: PreparedLiveMapTransition) => void;
    released?: () => void;
    terminal?: (error: LocusAuthorityError) => void;
}>): LocusExclusiveAuthority<TMap, TContext>;
//# sourceMappingURL=locus.authority.d.ts.map