import type { AcceptMessageResult, IdentityQuery, IdentityRecord, MemoryQuery, MemoryRecord, RecoveryResult } from "../storage/types.js";
import type { AcceptBrokerMessageInput, BrokerBootstrap, BrokerDependencies, BrokerHealth, CancelTurnFromBindingInput, CancelTurnOutcome, CompactContextFromBindingInput, ResetContextFromBindingInput, SupervisionStatusQuery, CorrelationWaitResult, CorrelationReadResult, ReadCorrelationInput, SteerSubjectInput, SteerSubjectResult, WatchSubjectInput, WatchSubjectResult, RememberIdentityFromBindingInput, RememberMemoryFromBindingInput, RetractRecordFromBindingInput, SupersedeIdentityFromBindingInput, SupersedeMemoryFromBindingInput, TurnQueueSnapshot, WaitForCorrelationInput } from "./types.js";
/**
 * Durable Broker application core. HTTP, MCP, process startup, and SQLite
 * ownership are composed outside this class.
 */
export declare class GroupXBroker {
    #private;
    constructor(dependencies: BrokerDependencies);
    acceptMessage(input: AcceptBrokerMessageInput): Promise<AcceptMessageResult>;
    contextUsage(roomId?: string): import("../memory/types.js").RoomContextUsage;
    compactContextFromBinding(input: CompactContextFromBindingInput): Promise<import("../memory/types.js").RoomContextCompactionResult>;
    resetContextFromBinding(input: ResetContextFromBindingInput): Promise<import("../memory/types.js").RoomContextResetResult>;
    supervisionStatus(input: SupervisionStatusQuery): {
        pairId: string;
        correlationId: string;
        mode: "live_steer";
        workers: import("../core/supervision.js").SupervisionSnapshot[];
        observers: Array<{
            actorId: string;
            turnId: string;
            status: string;
        }>;
    };
    cancelTurn(turnId: string): Promise<CancelTurnOutcome>;
    cancelFromBinding(input: CancelTurnFromBindingInput): Promise<CancelTurnOutcome>;
    readCorrelation(input?: ReadCorrelationInput): CorrelationReadResult;
    waitForCorrelation(input: WaitForCorrelationInput): Promise<CorrelationWaitResult>;
    inspectTurnQueue(turnId: string): TurnQueueSnapshot;
    recoverAfterRestart(): Promise<RecoveryResult>;
    notifySessionReady(actorId: string): void;
    restartAgent(actorId: string): Promise<void>;
    health(): BrokerHealth;
    bootstrap(input?: {
        roomId?: string;
        recentLimit?: number;
    }): BrokerBootstrap;
    queryMemory(input?: MemoryQuery): MemoryRecord[];
    queryIdentity(input?: IdentityQuery): IdentityRecord[];
    rememberMemory(input: RememberMemoryFromBindingInput): Promise<MemoryRecord>;
    supersedeMemory(memoryId: string, input: SupersedeMemoryFromBindingInput): Promise<MemoryRecord>;
    retractMemory(memoryId: string, input: RetractRecordFromBindingInput): Promise<MemoryRecord>;
    rememberIdentity(input: RememberIdentityFromBindingInput): Promise<IdentityRecord>;
    supersedeIdentity(identityId: string, input: SupersedeIdentityFromBindingInput): Promise<IdentityRecord>;
    retractIdentity(identityId: string, input: RetractRecordFromBindingInput): Promise<IdentityRecord>;
    waitForIdle(): Promise<void>;
    close(): Promise<void>;
    assertObserverRouting(watchTurnId: string, targets: readonly string[]): void;
    watchSubject(input: WatchSubjectInput): Promise<WatchSubjectResult>;
    steerSubject(input: SteerSubjectInput): Promise<SteerSubjectResult>;
}
//# sourceMappingURL=broker.d.ts.map