import type { CompiledSchema, CompiledTable } from './schema.js';
import type { AuthoritativeQueryRequest, AuthoritativeQueryResult, ClientCursorInfo, ClientRecord, CommitMetadata, CommitMetadataQuery, CommitWindowQuery, IndexRowScanQuery, PartitionRegistryEntry, PrunedReactionCounts, ReactionClaimQuery, ReactionFailureUpdate, ReactionListQuery, ReactionPruneQuery, RowScanQuery, ScopeActivityQuery, ScopeCommitActivity, ServerStorage, StorageTransaction, StoredCommit, StoredPushResult, StoredReaction, StoredRow } from './storage.js';
export interface D1PreparedStatement {
    bind(...values: unknown[]): D1PreparedStatement;
    first<T = Record<string, unknown>>(): Promise<T | null>;
    all<T = Record<string, unknown>>(): Promise<{
        results: T[];
    }>;
    run(): Promise<unknown>;
}
export interface D1Database {
    prepare(query: string): D1PreparedStatement;
    batch(statements: D1PreparedStatement[]): Promise<unknown[]>;
    exec(query: string): Promise<unknown>;
}
export interface D1ServerStorageOptions {
    /**
     * Assert that all writes for a partition reach this storage serially.
     * Required for every push because D1 exposes no interactive transaction
     * lock. Set this only inside an explicit per-partition request queue,
     * Durable Object, or equivalent coordinator; the default fails closed.
     */
    readonly pushApplySerialized?: boolean;
    /**
     * @deprecated Use `pushApplySerialized`. This alias remains valid only
     * because the old assertion already promised that every partition write,
     * not merely validator callbacks, was externally serialized.
     */
    readonly commitValidationSerialized?: boolean;
}
export declare class D1ServerStorage implements ServerStorage {
    #private;
    constructor(db: D1Database, options?: D1ServerStorageOptions);
    /** Apply the schema DDL (idempotent). Call once before use. */
    migrate(): Promise<void>;
    /** Resolve a table's compiled schema; row operations require `ensureSchema`. */
    table(name: string): CompiledTable;
    ensureSchema(schema: CompiledSchema): Promise<void>;
    touchPartition(partition: string, authenticatedAtMs: number, initialLogEpoch: string): Promise<PartitionRegistryEntry>;
    rotatePartitionLogEpoch(partition: string, logEpoch: string, authenticatedAtMs: number): Promise<PartitionRegistryEntry>;
    listPartitionRegistry(): Promise<PartitionRegistryEntry[]>;
    begin(partition: string): Promise<StorageTransaction>;
    getMaxCommitSeq(partition: string): Promise<number>;
    queryAuthoritative(partition: string, query: AuthoritativeQueryRequest): Promise<AuthoritativeQueryResult>;
    getHorizonSeq(partition: string): Promise<number>;
    setHorizonSeq(partition: string, seq: number): Promise<void>;
    pruneCommitsThrough(partition: string, seq: number): Promise<number>;
    getCommitSeqBefore(partition: string, createdBeforeMs: number): Promise<number>;
    getRow(partition: string, table: string, rowId: string): Promise<StoredRow | undefined>;
    getPushResult(partition: string, clientId: string, clientCommitId: string): Promise<StoredPushResult | undefined>;
    claimReactions(partition: string, query: ReactionClaimQuery): Promise<StoredReaction[]>;
    completeReaction(partition: string, idempotencyKey: string, leaseOwner: string, completedAtMs: number): Promise<boolean>;
    extendReactionLease(partition: string, idempotencyKey: string, leaseOwner: string, leaseExpiresAtMs: number): Promise<boolean>;
    failReaction(partition: string, idempotencyKey: string, update: ReactionFailureUpdate): Promise<boolean>;
    retryReaction(partition: string, idempotencyKey: string, nowMs: number): Promise<boolean>;
    getReaction(partition: string, idempotencyKey: string): Promise<StoredReaction | undefined>;
    listReactions(partition: string, query: ReactionListQuery): Promise<StoredReaction[]>;
    pruneReactions(partition: string, query: ReactionPruneQuery): Promise<PrunedReactionCounts>;
    readCommitWindow(partition: string, query: CommitWindowQuery): Promise<StoredCommit[]>;
    scanRows(partition: string, query: RowScanQuery): Promise<StoredRow[]>;
    scanRowsByIndex(partition: string, query: IndexRowScanQuery): Promise<StoredRow[]>;
    getClientRecord(partition: string, clientId: string): Promise<ClientRecord | undefined>;
    putClientRecord(partition: string, record: ClientRecord): Promise<void>;
    listClientCursors(partition: string): Promise<ClientCursorInfo[]>;
    listRowsReferencingBlob(partition: string, blobId: string): Promise<{
        readonly table: string;
        readonly rowId: string;
        readonly scopes: Record<string, string>;
    }[]>;
    listReferencedBlobIds(partition: string): Promise<string[]>;
    listClientRecords(partition: string): Promise<ClientRecord[]>;
    listCommitMetadata(partition: string, query: CommitMetadataQuery): Promise<CommitMetadata[]>;
    scopeActivity(partition: string, query: ScopeActivityQuery): Promise<ScopeCommitActivity[]>;
    getRowScopes(partition: string, table: string, rowId: string): Promise<{
        serverVersion: number;
        scopes: Record<string, string>;
    } | undefined>;
    listPartitions(): Promise<string[]>;
}