import type { CompiledSchema, CompiledTable } from './schema.js'; import { type SqliteDatabase } from './sqlite-driver.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 declare class SqliteServerStorage implements ServerStorage { #private; readonly db: SqliteDatabase; constructor(db?: SqliteDatabase | string); /** Resolve a table's compiled schema; row operations require `ensureSchema`. */ table(name: string): CompiledTable; ensureSchema(schema: CompiledSchema): Promise; touchPartition(partition: string, authenticatedAtMs: number, initialLogEpoch: string): Promise; rotatePartitionLogEpoch(partition: string, logEpoch: string, authenticatedAtMs: number): Promise; listPartitionRegistry(): Promise; begin(partition: string): Promise; /** Internal: write a row + refresh its scope-index entries. */ writeRow(partition: string, table: string, row: StoredRow): void; getMaxCommitSeq(partition: string): Promise; queryAuthoritative(partition: string, query: AuthoritativeQueryRequest): Promise; getHorizonSeq(partition: string): Promise; setHorizonSeq(partition: string, seq: number): Promise; pruneCommitsThrough(partition: string, seq: number): Promise; getCommitSeqBefore(partition: string, createdBeforeMs: number): Promise; getRow(partition: string, table: string, rowId: string): Promise; getPushResult(partition: string, clientId: string, clientCommitId: string): Promise; claimReactions(partition: string, query: ReactionClaimQuery): Promise; completeReaction(partition: string, idempotencyKey: string, leaseOwner: string, completedAtMs: number): Promise; extendReactionLease(partition: string, idempotencyKey: string, leaseOwner: string, leaseExpiresAtMs: number): Promise; failReaction(partition: string, idempotencyKey: string, update: ReactionFailureUpdate): Promise; retryReaction(partition: string, idempotencyKey: string, nowMs: number): Promise; getReaction(partition: string, idempotencyKey: string): Promise; listReactions(partition: string, query: ReactionListQuery): Promise; pruneReactions(partition: string, query: ReactionPruneQuery): Promise; readCommitWindow(partition: string, query: CommitWindowQuery): Promise; scanRows(partition: string, query: RowScanQuery): Promise; scanRowsByIndex(partition: string, query: IndexRowScanQuery): Promise; getClientRecord(partition: string, clientId: string): Promise; putClientRecord(partition: string, record: ClientRecord): Promise; listClientCursors(partition: string): Promise; listRowsReferencingBlob(partition: string, blobId: string): Promise<{ readonly table: string; readonly rowId: string; readonly scopes: Record; }[]>; listReferencedBlobIds(partition: string): Promise; listClientRecords(partition: string): Promise; listCommitMetadata(partition: string, query: CommitMetadataQuery): Promise; scopeActivity(partition: string, query: ScopeActivityQuery): Promise; getRowScopes(partition: string, table: string, rowId: string): Promise<{ serverVersion: number; scopes: Record; } | undefined>; listPartitions(): Promise; }