import type { IEventData, PGMBEventBatcherOpts } from './types.ts';
export declare class PGMBEventBatcher<T extends IEventData> {
    #private;
    constructor({ shouldLog, publish, flushIntervalMs, maxBatchSize, logger }: PGMBEventBatcherOpts<T>);
    end(): Promise<void>;
    /**
     * Enqueue a message to be published, will be flushed to the database
     * when flush() is called (either manually or via interval)
     */
    enqueue(msg: T): void;
    flush(): Promise<void>;
}