import type { LocusActionPayloads } from "../../types/locus.types.js";
import type { HostedLiveMapLibrariesSnapshot } from "../../types/livemap.types.js";
import type { LocusHostedAggregateWireEnvelope } from "./locus.hosted-multi-library.js";
import type { LocusDownstreamSink, LocusFiniteOperationRequest } from "./locus.transport.internal.js";
export type LocusHostedAggregateRecoveryCursor = Readonly<{
    incarnationId: string;
    registryDigest: string;
    lastAppliedRev: number;
}>;
type PlanOutcome = "current" | "replay" | "snapshot" | "reject";
type SnapshotReason = "no_usable_revision" | "incarnation_mismatch" | "registry_mismatch" | "history_unavailable";
export type LocusHostedAggregateSynchronizationOutput = Readonly<{
    type: "recovery-plan";
    id: string;
    logicalMapId: string;
    incarnationId: string;
    registryDigest: string;
    headRev: number;
    outcome: Exclude<PlanOutcome, "reject">;
    reason?: SnapshotReason;
}> | Readonly<{
    type: "recovery-plan";
    id: string;
    logicalMapId: string;
    incarnationId: string;
    registryDigest: string;
    headRev: number;
    outcome: "reject";
    error: Readonly<{
        code?: string;
        message: string;
    }>;
}> | Readonly<{
    type: "recovery-snapshot";
    id: string;
    snapshot: HostedLiveMapLibrariesSnapshot;
}> | Readonly<{
    type: "recovery-commit";
    id: string;
    phase: "body" | "tail";
    commit: LocusHostedAggregateWireEnvelope;
}> | Readonly<{
    type: "recovery-caught-up";
    id: string;
    logicalMapId: string;
    incarnationId: string;
    registryDigest: string;
    throughRev: number;
}> | Readonly<{
    type: "synchronization-failure";
    error: Readonly<{
        code?: string;
        message: string;
        cause?: unknown;
    }>;
}>;
export type LocusHostedAggregateCanonicalPublication = Readonly<{
    type: "commit";
    id: string;
    commit: LocusHostedAggregateWireEnvelope;
}>;
export type LocusHostedAggregateDownstreamSink = LocusDownstreamSink<LocusHostedAggregateSynchronizationOutput, LocusHostedAggregateCanonicalPublication>;
export type LocusHostedAggregateFiniteOperationRequest<TActions extends LocusActionPayloads = LocusActionPayloads> = LocusFiniteOperationRequest<TActions>;
export {};
//# sourceMappingURL=locus.hosted-multi-library.transport.internal.d.ts.map