import { Queue } from "bullmq";
import { QueueName, TQueueJobTypes } from "../queues";
export declare class IngestionQueue {
    private static instances;
    static getShardNames(): string[];
    static getShardIndexFromShardName(shardName: string | undefined): number | null;
    /**
     * Get the ingestion queue instance for the given sharding key or shard name.
     * @param shardingKey - ShardingKey is being hashed and randomly allocated to a shard. Should be `projectId-eventBodyId`.
     * @param shardName - Name of the shard. Should be `ingestion-queue-${shardIndex}` or plainly `ingestion-queue` for the first shard.
     */
    static getInstance({ shardingKey, shardName, }: {
        shardingKey?: string;
        shardName?: string;
    }): Queue<TQueueJobTypes[QueueName.IngestionQueue]> | null;
}
export declare class SecondaryIngestionQueue {
    private static instance;
    static getInstance(): Queue<TQueueJobTypes[QueueName.IngestionSecondaryQueue]> | null;
}
//# sourceMappingURL=ingestionQueue.d.ts.map