import { Job, Runner, RunnerOptions, TaskSpec, WorkerUtils } from "graphile-worker"; import { ListenerExplorerService } from "./listener-explorer.service"; import { TaskExplorerService } from "./task-explorer.service"; export declare class WorkerService { private readonly options; private readonly listenerExplorerService; private readonly taskExplorerService; private readonly logger; private isMigrationDone; constructor(options: RunnerOptions, listenerExplorerService: ListenerExplorerService, taskExplorerService: TaskExplorerService); /** * Runs until either stopped by a signal event like `SIGINT` or by calling the `stop()` method on the resolved object. * * The resolved `Runner` object has a number of helpers on it, see [Runner object](https://github.com/graphile/worker#runner-object) for more information. */ run(): Promise; /** * Runs until there are no runnable jobs left, and then resolve. */ runOnce(): Promise; getWorkerUtils(): Promise; addJob(identifier: string, payload?: unknown, spec?: TaskSpec): Promise; addJobs(jobs: Array<{ identifier: string; payload?: unknown; spec?: TaskSpec; }>): Promise; private runMigrations; private hookEvents; }