import { ObjectId, MongoClient } from 'mongodb';
import type { DatabaseAdapter, QueueJobRecord } from '../interfaces/database.ts';
import type { JobMeta, JobStatus } from '../interfaces/job.ts';
import { DbQueue } from '../drivers/db.ts';
export interface MongoCollection {
    insertOne(doc: any): Promise<{
        insertedId: ObjectId;
    }>;
    findOneAndUpdate(filter: any, update: any, options?: any): Promise<any>;
    updateOne(filter: any, update: any): Promise<any>;
    updateMany(filter: any, update: any): Promise<any>;
    findOne(filter: any, options?: any): Promise<any>;
    deleteOne(filter: any): Promise<any>;
    createIndex(keys: any, options?: any): Promise<any>;
}
export interface MongoConfig {
    url?: string;
    database?: string;
    collection?: string;
}
export declare class MongoDatabaseAdapter implements DatabaseAdapter {
    private col;
    private indexesInitialized;
    constructor(col: MongoCollection);
    private initializeIndexes;
    ensureIndexes(): Promise<void>;
    insertJob(payload: Buffer, meta: JobMeta): Promise<string>;
    reserveJob(timeout: number): Promise<QueueJobRecord | null>;
    completeJob(id: string): Promise<void>;
    releaseJob(id: string): Promise<void>;
    failJob(id: string, error: string): Promise<void>;
    getJobStatus(id: string): Promise<JobStatus | null>;
    deleteJob(id: string): Promise<void>;
    markJobDone(id: string): Promise<void>;
    close(): Promise<void>;
}
export declare class MongoQueue<T = Record<string, any>> extends DbQueue<T> {
    mongoAdapter: MongoDatabaseAdapter;
    constructor(config: {
        collection: MongoCollection;
        name: string;
    });
}
export declare function createMongoQueue<T = Record<string, any>>(name: string, client: MongoClient, database: string, collection?: string): MongoQueue<T>;
export declare function createMongoQueueFromUrl<T = Record<string, any>>(name: string, url: string, database: string, collection?: string): Promise<MongoQueue<T>>;
export { DbQueue };