import BeeQueue from 'bee-queue';
import { FastifyLoggerInstance } from 'fastify';
import { Db } from 'mongodb';
import { CreatedEventContext, CreatedEventHandler, DeletedEventContext, DeletedEventHandler, UpdatedEventContext, UpdatedEventHandler } from '../types';
export declare const CRUD_EVENTS: readonly ["created", "updated", "deleted"];
export declare type CRUDEvent = 'created' | 'updated' | 'deleted';
declare type GenericModule = {
    default: (ctx: any) => any;
    broadcast?: boolean;
};
export declare type CRUDEventMap = {
    created?: {
        default: CreatedEventHandler<any>;
        broadcast?: boolean;
    };
    deleted?: {
        default: DeletedEventHandler<any>;
        broadcast?: boolean;
    };
    updated?: {
        default: UpdatedEventHandler<any>;
        broadcast?: boolean;
    };
};
export declare type EventCtxMap = {
    created: CreatedEventContext<any>;
    deleted: DeletedEventContext<any>;
    updated: UpdatedEventContext<any>;
};
export declare type EmitData<T extends CRUDEvent> = Omit<EventCtxMap[T], 'db' | 'eventName'>;
export declare class CRUDEventsManager {
    private eventDefs;
    private db;
    private _log;
    emitMap: Map<string, Map<CRUDEvent, {
        queue: BeeQueue;
        module: GenericModule;
    }>>;
    constructor(eventDefs: Record<string, CRUDEventMap>, db: Db, _log: FastifyLoggerInstance);
    emit<T extends CRUDEvent>(collection: string, event: T, data: EmitData<T>): Promise<BeeQueue.Job<EmitData<T>>> | undefined;
    setupLocalHandlers(): void;
    close(): Promise<void[]>;
}
export {};