import type { EventListener, Hex } from '@ariestools/sdk'; import { zodAsFactory, zodIsFactory, zodToFactory } from '@ariestools/sdk'; import { type Payload, type Schema, type WithStorageMeta } from '@xyo-network/sdk-protocol'; import * as z from 'zod/mini'; import type { ArchivistInstance, ArchivistModuleEventData } from '../archivist-model/index.js'; import type { DivinerInstance, DivinerModuleEventData } from '../diviner-model/index.js'; import { PayloadDiviner } from '../diviner-payload-abstract/index.js'; import type { Order, PayloadDivinerConfig, PayloadDivinerParams, PayloadDivinerQueryPayload } from '../diviner-payload-model/index.js'; import { PayloadDivinerConfigZod } from '../diviner-payload-model/index.js'; export declare const GenericPayloadDivinerConfigSchema: 'network.xyo.diviner.payload.generic.config' & { readonly __schema: true; }; export type GenericPayloadDivinerConfigSchema = typeof GenericPayloadDivinerConfigSchema; export declare const GenericPayloadDivinerConfigZod: z.ZodMiniObject & { indexes: z.ZodMiniOptional>>; schema: z.ZodMiniLiteral; }, z.core.$strip>; export type GenericPayloadDivinerConfigBase = z.infer; export declare const isGenericPayloadDivinerConfig: ReturnType>; export declare const asGenericPayloadDivinerConfig: ReturnType>; export declare const toGenericPayloadDivinerConfig: ReturnType>; export type GenericPayloadDivinerConfig = PayloadDivinerConfig<{ indexes?: string[]; }, GenericPayloadDivinerConfigSchema>; export declare class GenericPayloadDiviner = PayloadDivinerParams, TIn extends PayloadDivinerQueryPayload = PayloadDivinerQueryPayload, TOut extends WithStorageMeta = WithStorageMeta, TEventData extends DivinerModuleEventData, TIn, TOut> = DivinerModuleEventData, TIn, TOut>> extends PayloadDiviner { static readonly configSchemas: Schema[]; static readonly defaultConfigSchema: Schema; protected indexMaps: Record[]>; protected payloadsWithMeta: WithStorageMeta[]; private _archivistInstance?; private _cursor?; private _updatePayloadPairsMutex; protected get indexBatchSize(): number; protected get indexes(): string[]; protected get maxIndexSize(): number; protected all(order?: Order, cursor?: Hex): WithStorageMeta[]; protected archivistInstance(): Promise; protected archivistInstance(required: true): Promise; protected clearIndex(): Promise; protected divineHandler(payloads?: TIn[]): Promise; protected onArchivistCleared: EventListener; protected onArchivistDeleted: EventListener; protected onArchivistInserted: EventListener; protected stopHandler(_timeout?: number): Promise; protected updateIndex(): Promise; private indexPayloads; } //# sourceMappingURL=Diviner.d.ts.map