import type { Attributes, Gauge, Meter } from '@opentelemetry/api';
import type { Hash, Promisable, PromisableArray } from '@xylabs/sdk-js';
import type { ArchivistInstance, ArchivistModuleEventData, ArchivistNextOptions, ArchivistParams, ArchivistSnapshotPayload, ArchivistStatsPayload, AttachableArchivistInstance, ReadArchivist } from '@xyo-network/archivist-model';
import { AbstractModuleInstance } from '@xyo-network/module-abstract';
import type { ModuleConfig, ModuleIdentifier, ModuleQueryHandlerResult, ModuleQueryResult } from '@xyo-network/module-model';
import type { AccountInstance, BoundWitness, Payload, QueryBoundWitness, Schema, WithStorageMeta } from '@xyo-network/sdk-protocol-js';
import { QueryBoundWitnessWrapper } from '@xyo-network/sdk-protocol-js';
export interface ActionConfig {
    emitEvents?: boolean;
}
export interface InsertConfig extends ActionConfig {
    writeToParents?: boolean;
}
interface ArchivistParentInstanceMap {
    commit?: Partial<Record<ModuleIdentifier, ArchivistInstance>>;
    read?: Partial<Record<ModuleIdentifier, ArchivistInstance>>;
    write?: Partial<Record<ModuleIdentifier, ArchivistInstance>>;
}
export declare abstract class AbstractArchivist<TParams extends ArchivistParams = ArchivistParams, TEventData extends ArchivistModuleEventData = ArchivistModuleEventData> extends AbstractModuleInstance<TParams, TEventData> implements AttachableArchivistInstance<TParams, TEventData, Payload> {
    static readonly configSchemas: Schema[];
    static readonly defaultConfigSchema: Schema;
    static readonly labels: {
        'network.xyo.storage.class': string;
    };
    static readonly uniqueName: string;
    protected static defaultNextLimitSetting: number;
    private _getCache?;
    private _parentArchivists?;
    private _payloadCountGauge?;
    private _payloadCountMeter?;
    static get defaultNextLimit(): number;
    get queries(): Schema[];
    get requireAllParents(): boolean;
    protected get payloadCountGauge(): Gauge<Attributes> | null | undefined;
    protected get payloadCountMeter(): Meter | null;
    protected get storeParentReads(): boolean;
    /** @deprecated use next or snapshot instead */
    all(): Promise<WithStorageMeta<Payload>[]>;
    /** deprecated use nextQuery or snapshotQuery instead */
    allQuery(account: AccountInstance): Promise<ModuleQueryResult>;
    clear(): Promise<void>;
    clearQuery(account: AccountInstance): Promise<ModuleQueryResult>;
    commit(): Promise<BoundWitness[]>;
    commitQuery(account: AccountInstance): Promise<ModuleQueryResult>;
    delete(hashes: Hash[]): Promise<WithStorageMeta<Payload>[]>;
    deleteQuery(hashes: Hash[], account?: AccountInstance): Promise<ModuleQueryResult>;
    get(hashes: Hash[]): Promise<WithStorageMeta<Payload>[]>;
    getQuery(hashes: Hash[], account?: AccountInstance): Promise<ModuleQueryResult>;
    insert(payloads: Payload[]): Promise<WithStorageMeta<Payload>[]>;
    insertQuery(payloads: Payload[], account?: AccountInstance): Promise<ModuleQueryResult>;
    next(options?: ArchivistNextOptions): Promise<WithStorageMeta<Payload>[]>;
    nextQuery(options?: ArchivistNextOptions, account?: AccountInstance): Promise<ModuleQueryResult>;
    snapshot(): Promise<ArchivistSnapshotPayload<WithStorageMeta<Payload>, Hash>[]>;
    snapshotQuery(account?: AccountInstance): Promise<ModuleQueryResult>;
    protected allHandler(): PromisableArray<WithStorageMeta<Payload>>;
    protected clearHandler(): Promisable<void>;
    protected commitHandler(): Promisable<BoundWitness[]>;
    protected deleteHandler(_hashes: Hash[]): PromisableArray<WithStorageMeta<Payload>>;
    protected deleteWithConfig(hashes: Hash[], config?: ActionConfig): Promise<WithStorageMeta<Payload>[]>;
    protected generateStats(): Promisable<ArchivistStatsPayload>;
    protected getFromParent(hashes: Hash[], archivist: ReadArchivist): Promise<[WithStorageMeta<Payload>[], Hash[]]>;
    protected getFromParents(hashes: Hash[]): Promise<[WithStorageMeta<Payload>[], Hash[]]>;
    protected getHandler(_hashes: Hash[]): Promisable<WithStorageMeta<Payload>[]>;
    protected getWithConfig(hashes: Hash[], _config?: InsertConfig): Promise<WithStorageMeta<Payload>[]>;
    protected insertHandler(_payloads: WithStorageMeta<Payload>[]): Promisable<WithStorageMeta<Payload>[]>;
    protected insertQueryHandler<T extends QueryBoundWitnessWrapper = QueryBoundWitnessWrapper>(query: T, payloads?: Payload[]): Promise<WithStorageMeta<Payload>[]>;
    protected insertWithConfig(payloads: Payload[], config?: InsertConfig): Promise<WithStorageMeta<Payload>[]>;
    protected nextHandler(_options?: ArchivistNextOptions): Promisable<WithStorageMeta<Payload>[]>;
    protected nextWithConfig(options?: ArchivistNextOptions, _config?: InsertConfig): Promise<WithStorageMeta<Payload>[]>;
    protected parentArchivists(): Promise<ArchivistParentInstanceMap>;
    protected payloadCountHandler(): number;
    protected queryHandler<T extends QueryBoundWitness = QueryBoundWitness, TConfig extends ModuleConfig = ModuleConfig>(query: T, payloads: Payload[], queryConfig?: TConfig): Promise<ModuleQueryHandlerResult>;
    protected reportPayloadCount(): void;
    protected snapshotHandler(): PromisableArray<ArchivistSnapshotPayload<WithStorageMeta<Payload>, Hash>>;
    protected startHandler(): Promise<void>;
    protected stateHandler(): Promise<Payload[]>;
    protected writeToParent(parent: ArchivistInstance, payloads: Payload[]): Promise<Payload[]>;
    protected writeToParents(payloads: Payload[]): Promise<Payload[]>;
    private omitClientMetaForDataHashes;
    private resolveArchivists;
}
export {};
//# sourceMappingURL=AbstractArchivist.d.ts.map