export interface ParsedFields {
    channel: string;
    payload: string;
    timestamp: string;
    attempt: string;
    exactlyOnce: string;
    dedupTTL: string;
    pattern: string;
    error: string;
    streamKey: string;
    [key: string]: string;
}
export declare function acquireFields(): ParsedFields;
export declare function releaseFields(fields: ParsedFields): void;
export declare function parseFields(raw: string[]): Record<string, string>;
export declare function parseFieldsFast(raw: string[]): ParsedFields;
export declare function getStreamKey(channel: string): string;
export declare function getLoopKey(stream: string, group: string): string;
export declare function splitLoopKey(loopKey: string): [string, string];
export declare function getGroupName(pattern: string, customName?: string): string;
export declare function defaultConsumerName(): string;
export declare function generateDedupKey({ channel, payload, group, pattern, side, explicitKey, }: {
    channel: string;
    payload: any;
    group?: string;
    pattern?: string;
    side?: 'pub' | 'con';
    explicitKey?: string;
}): string;
type PatternMatcher = (channel: string) => boolean;
export declare function getCachedMatcher(pattern: string, minimatchFn: (input: string, pattern: string) => boolean): PatternMatcher;
export declare function clearPatternCache(): void;
export declare function getPatternCacheStats(): {
    size: number;
    maxSize: number;
};
export declare function chunkArray<T>(array: T[], size: number): T[][];
export declare function processWithConcurrency<T, R>(items: T[], processor: (item: T) => Promise<R>, concurrency?: number): Promise<R[]>;
export {};
//# sourceMappingURL=utils.d.ts.map