import { KeyedResolvOnce, Logger, LRUSet, Result, URI } from "@adviser/cement";
import { type AnyLink, type CarHeader, type CommitOpts, type TransactionMeta, type CarGroup, type Loadable, BlockstoreRuntime, BlockstoreOpts, AttachedStores, ActiveStore, CIDActiveStore, CarLog, FroozenCarLog, FPBlock, CarBlockItem, BlockFetcher, CommitQueueIf } from "@fireproof/core-types-blockstore";
import { TaskManager } from "@fireproof/core-runtime";
import { type Attachable, type Attached, type CarTransaction, type DbMeta, type Falsy, type SuperThis, KeyBagIf } from "@fireproof/core-types-base";
export declare function carLogIncludesGroup(list: FroozenCarLog, cids: CarGroup): boolean;
export declare class Loader implements Loadable {
    readonly blockstoreParent?: BlockFetcher;
    readonly ebOpts: BlockstoreRuntime;
    readonly logger: Logger;
    readonly commitQueue: CommitQueueIf<CarGroup>;
    isCompacting: boolean;
    readonly cidCache: KeyedResolvOnce<FPBlock>;
    private readonly maxConcurrentCarReader;
    private readonly maxConcurrentWrite;
    readonly seenCompacted: LRUSet<string>;
    readonly sthis: SuperThis;
    readonly taskManager: TaskManager;
    readonly carLog: CarLog;
    readonly attachedStores: AttachedStores;
    tryToLoadStaleCars(store: ActiveStore): Promise<void>;
    attach(attachable: Attachable): Promise<Attached>;
    private ensureAttachedStore;
    private seenMeta;
    keyBag(): Promise<KeyBagIf>;
    private readonly onceReady;
    metaStreamReader: ReadableStreamDefaultReader<DbMeta[]>;
    ready(): Promise<void>;
    currentMeta: CarGroup;
    waitFirstMeta(reader: ReadableStreamDefaultReader<DbMeta[]>, local: ActiveStore, opts?: {
        meta?: DbMeta;
        origin?: URI;
    }): Promise<CarGroup>;
    handleMetaStream(reader: ReadableStreamDefaultReader<DbMeta[]>, local: ActiveStore, opts?: {
        meta?: DbMeta;
        origin?: URI;
        first: (v: CarGroup) => void;
        error: (e: Error) => void;
    }): void;
    close(): Promise<void>;
    destroy(): Promise<void>;
    readonly id: string;
    constructor(sthis: SuperThis, ebOpts: BlockstoreOpts, blockstore?: BlockFetcher);
    handleDbMetasFromStore(metas: DbMeta[], activeStore: ActiveStore): Promise<CarGroup>;
    mergeDbMetaIntoClock(meta: DbMeta, activeStore: ActiveStore): Promise<CarGroup[]>;
    loadCarHeaderFromMeta<T>(dbm: DbMeta, astore: ActiveStore): Promise<CarHeader<T>>;
    commitFiles(t: CarTransaction, done: TransactionMeta): Promise<CarGroup>;
    loadFileCar(cid: AnyLink, store: ActiveStore): Promise<FPBlock<CarBlockItem>>;
    commit<T = TransactionMeta>(t: CarTransaction, done: T, opts?: CommitOpts): Promise<CarGroup>;
    updateCarLog<T>(cids: CarGroup, cHeader: CarHeader<T>, compact: boolean): Promise<void>;
    cacheTransaction(t: CarTransaction): Promise<void>;
    removeCidsForCompact(cid: AnyLink, store: ActiveStore): Promise<void>;
    entries(): AsyncIterableIterator<FPBlock>;
    getBlock(cid: AnyLink): Promise<FPBlock | Falsy>;
    getCompactCarCids(carCid: AnyLink, store: ActiveStore): Promise<void>;
    loadCar(cid: AnyLink, store: ActiveStore): Promise<FPBlock<CarBlockItem>>;
    private makeDecoderAndCarReader;
    protected storesLoadCar(carCid: AnyLink, store: CIDActiveStore): Promise<FPBlock<CarBlockItem>>;
    protected getMoreReaders(cids: AnyLink[], store: ActiveStore): Promise<Result<FPBlock<CarBlockItem>>[]>;
}