/** * Aggregation pipeline engine. * * Supports stages: * $match, $group, $sort, $limit, $skip, $project, * $unwind, $count, $addFields, $lookup, $replaceRoot, $sample */ import type { AggregationStage } from '@digitaldefiance/suite-core-lib'; import type { BsonDocument } from '../interfaces/storage/documentTypes'; type LookupResolver = (collectionName: string) => Promise; /** * Run an aggregation pipeline over an array of documents. * * @param docs - Input documents * @param pipeline - Array of aggregation stages * @param lookupResolver - Optional resolver for $lookup stages (fetches docs from another collection) */ export declare function runAggregation(docs: BsonDocument[], pipeline: AggregationStage[], lookupResolver?: LookupResolver): Promise; export {}; //# sourceMappingURL=aggregation.d.ts.map