import { ILogger } from "@golemio/core/dist/helpers/logger";
import { AbstractTask } from "@golemio/core/dist/integration-engine/workers";
import { IPresetLogRepository } from "../data-access/interfaces/IPresetLogRepository";
import { IPresetLogDataSourceFactory } from "../datasources/interfaces/IPresetLogDataSourceFactory";
import { ILogFilter } from "../helpers/interfaces/ILogFilter";
import { ILogCollectionParams } from "../interfaces/ILogCollectionParams";
import { LogCollectionValidationSchema } from "../schema/LogCollectionSchema";
import { IPresetLogTransformation } from "../transformations/interfaces/IPresetLogTransformation";
export declare class CollectAndSaveLogsTask extends AbstractTask<ILogCollectionParams> {
    private readonly dataSourceFactory;
    private readonly logTransformation;
    private readonly logRepository;
    private readonly logFilter;
    private readonly logger;
    readonly queueName = "collectAndSaveLogs";
    readonly queueTtl: number;
    readonly schema: typeof LogCollectionValidationSchema;
    constructor(dataSourceFactory: IPresetLogDataSourceFactory, logTransformation: IPresetLogTransformation, logRepository: IPresetLogRepository, logFilter: ILogFilter, logger: ILogger);
    protected execute(data: ILogCollectionParams): Promise<void>;
}