import type { CapabilityInvocation, CanonicalState, Capability, ExecutionContext } from "../types/index.js";
import { EventStore } from "../infra/event-store.js";
import type { IStateStore } from "../infra/state-store.js";
import type { ICheckpointStore } from "../infra/checkpoint-store.js";
import { ConsumerGroup } from "./partition-router.js";
export type RuntimeConfig = {
    partitionCount?: number;
    usePartitions?: boolean;
};
export declare class RuntimeEngine {
    private eventStore;
    private stateStore;
    private partitionStore?;
    private partitionRouter?;
    private producer?;
    private consumerGroups;
    private checkpointStore?;
    private config;
    constructor(eventStore: EventStore, stateStore: IStateStore, checkpointStore?: ICheckpointStore, config?: RuntimeConfig);
    private initializePartitioned;
    private capabilityRegistry?;
    /** Register a capability for runtime resolution (bootstrap only). */
    registerCapability(cap: Capability): void;
    /** Execute a capability invocation. Assumes intent is pre-validated. */
    execute(invocation: CapabilityInvocation, context: ExecutionContext): Promise<import("../types/index.js").ExecutionResult>;
    /** Get current canonical state (rebuilt from events) */
    getState(): Promise<CanonicalState>;
    /** Get event count */
    getEventCount(): Promise<number>;
    /** Load all events (for replay/audit) */
    loadEvents(): Promise<import("../types/event.js").SynthEvent[]>;
    getConsumerGroup(groupId: string): ConsumerGroup;
}
export declare class RuntimeError extends Error {
    constructor(message: string);
}