import type { Server } from "node:http";
import { type AgentContinuationOriginContext } from "@mono-agent/agent-contracts";
import type { ContinuationStore, DurableContinuationRecord } from "./continuation-store.js";
import { type ClaimBinding, type ContinuationServiceLogger, type ContinuationServiceOptions, type ResolvedOriginContext } from "./continuation-service-types.js";
import { type ContinuationLimits, type NamedContinuationRoute } from "./continuations.js";
export declare abstract class ContinuationOriginService {
    protected readonly store: ContinuationStore;
    protected readonly secret: Buffer;
    protected readonly options: ContinuationServiceOptions;
    protected readonly releaseStoreLock: () => Promise<void>;
    protected readonly instanceId: `${string}-${string}-${string}-${string}-${string}`;
    protected readonly operatorToken: string;
    protected readonly claimBindings: Map<string, ClaimBinding>;
    protected readonly activeClaimBindings: Set<ClaimBinding>;
    protected readonly namedRoutes: Readonly<Record<string, NamedContinuationRoute>>;
    protected readonly detachedServiceTokenHashes: ReadonlyMap<string, string>;
    protected readonly maxResultBytes: number;
    protected readonly maxDeadlineMs: number;
    protected readonly leaseMs: number;
    protected readonly workerIntervalMs: number;
    protected readonly autoProcess: boolean;
    protected readonly limits: ContinuationLimits;
    protected readonly now: () => Date;
    protected readonly logger: ContinuationServiceLogger | undefined;
    protected readonly lifecycleAbort: AbortController;
    protected readonly inFlight: Map<string, Promise<boolean>>;
    protected readonly activeHttpRequests: Set<Promise<void>>;
    protected activeHandleOperations: number;
    protected handleDrainPromise: Promise<void> | undefined;
    protected resolveHandleDrain: (() => void) | undefined;
    protected readonly resolvingUnknown: Set<string>;
    protected dispatchTail: Promise<void>;
    protected server: Server | undefined;
    protected baseUrl: string;
    protected worker: ReturnType<typeof setInterval> | undefined;
    protected stopped: boolean;
    protected stopPromise: Promise<void> | undefined;
    constructor(store: ContinuationStore, secret: Buffer, options: ContinuationServiceOptions, releaseStoreLock: () => Promise<void>);
    abstract processDue(limit?: number): Promise<number>;
    protected throwIfStopping(): void;
    protected runBoundedOperation<T>(phase: "synthesis" | "delivery", timeoutMs: number, operation: () => Promise<T> | T): Promise<T>;
    protected runHandleOperation<T>(operation: () => Promise<T>): Promise<T>;
    protected drainHandleOperations(): Promise<void>;
    protected closeClaimBinding(token: string, binding: ClaimBinding): Promise<void>;
    protected beginClaim(binding: ClaimBinding): () => void;
    protected requiresOriginContext(binding: ClaimBinding): Promise<boolean>;
    private beginOriginSettlementOperation;
    protected settleClaimBinding(binding: ClaimBinding): void;
    protected finalizeOriginContext(binding: ClaimBinding, snapshot: AgentContinuationOriginContext): Promise<void>;
    protected activateOriginContext(binding: ClaimBinding): Promise<void>;
    protected abandonOriginContext(binding: ClaimBinding): Promise<void>;
    protected resolveOriginContext(record: DurableContinuationRecord): Promise<ResolvedOriginContext>;
    private markOriginContextUnavailable;
}
//# sourceMappingURL=continuation-service-origin.d.ts.map