import { Except } from 'type-fest';
import { EntityManager, FindOptionsOrder } from 'typeorm';
import { Config } from '../config';
import { JobEntity } from './job.entity';
import { JobStatus } from './types';
export type JobEntityUpdateData<TParams extends object = object, TResultData extends object = object> = Except<JobEntity<TParams, TResultData>, 'id' | 'created' | 'updated'>;
export type JobEntityCreateData<TParams extends object = object, TResultData extends object = object> = Except<JobEntityUpdateData<TParams, TResultData>, 'status' | 'resultData' | 'thread' | 'labels'> & {
    thread?: string;
    labels?: string[];
};
export declare class JobService {
    private readonly config;
    private readonly logger;
    private readonly repository;
    constructor(config: Config);
    /**
     * Creates a new job. If `thread` is not passed in `data`, a unique `thread` will be generated
     * @param data
     * @returns
     */
    create(data: JobEntityCreateData, manager?: EntityManager): Promise<JobEntity>;
    findById(id: string, manager?: EntityManager): Promise<JobEntity>;
    /**
     * Deletes (only scheduled) jobs that match passed filters.
     * @param filters
     * @returns Number of affected jobs
     */
    deleteScheduledJobs(filters: {
        method: string;
        thread?: string;
        labels?: string[];
    }, manager?: EntityManager): Promise<number>;
    /**
     * Changes schedule time (only if the job status is `scheduled`)
     * @param jobId
     * @returns Number of affected jobs
     */
    reschedule(jobId: string, runAfter: Date, manager?: EntityManager): Promise<number>;
    /**
     * Finds jobs that match passed filters.
     * @param filters
     * @param paging
     * @returns Jobs that match given filters
     */
    find(filters: {
        method: string;
        thread?: string;
        labels?: string[];
        status?: JobStatus[];
    }, paging?: {
        order?: FindOptionsOrder<JobEntity>;
        skip?: number;
        take?: number;
    }): Promise<JobEntity[]>;
    update(id: string, data: Partial<JobEntityUpdateData>): Promise<JobEntity<object, object>>;
    /**
     * Returns the next runnable job (by current time newer than `runAfter`), and marks it as `running`.
     * @param methods Applicable job methods. If `undefined`, all jobs apply.
     */
    getNextJob(methods?: string[]): Promise<JobEntity | null>;
    /**
     * Returns a maximum number of `limit` runnable (current time newer than `runAfter`) jobs in a batch, and marks them as `running`.
     * @param methods Applicable job methods. If `undefined`, all jobs apply.
     * @param limit Maximum number of jobs to return.
     */
    getJobBatch(methods?: string[], limit?: number): Promise<JobEntity[]>;
    /**
     * Finds jobs that have been in status `running` for longer than
     * `jobRunningTimeoutMs` and marks them as failed.
     */
    failJobsStuckInRunning(manager?: EntityManager): Promise<JobEntity[]>;
    /**
     * Returns information on the state of the job queue.
     * @returns Object containing information on the state of the job queue
     */
    getQueuedJobsInfo(): Promise<{
        queuedJobCount: number;
    }>;
}