import { RunnerOptions as SchedulerRunnerOptions } from "graphile-scheduler";
import { AddJobFunction, JobHelpers, Logger, RunnerOptions as WorkerRunnerOptions, Task as GraphileWorkerTask, TaskList as GraphileWorkerTaskList } from "graphile-worker";
import { Pool, PoolClient } from "pg";
import Cryptr = require("cryptr");
import { ModuleI } from "../objects/module/core";
declare type PoolOrPoolClient = Pool | PoolClient;
declare type ComposeWorkerOptions = {
    encryptionSecret: string;
    pgPool: Pool;
    logger?: Logger;
} & Omit<WorkerRunnerOptions & SchedulerRunnerOptions, "connectionString" | "schema" | "schedules" | "logger">;
export interface PgComposeWorker {
    stop: () => Promise<void>;
    setSecret: (secretRef: string, unencryptedSecret: string) => Promise<void>;
    getSecret: (secretRef: string) => Promise<string>;
    addJob: AddJobFunction;
}
export declare type Task = (payload: any, helpers: JobHelpers) => Promise<any>;
export interface TaskList {
    [name: string]: Task;
}
export declare const makeWrapTaskList: (pool: PoolOrPoolClient, cryptr: Cryptr) => (taskList: TaskList) => GraphileWorkerTaskList;
export declare const run: (m: ModuleI, opts: ComposeWorkerOptions) => Promise<PgComposeWorker>;
export declare const runTaskListOnce: (m: ModuleI, opts: ComposeWorkerOptions, client: PoolClient) => Promise<void>;
export declare const runMigrations: (opts: Pick<ComposeWorkerOptions, "taskList" | "taskDirectory" | "crontab" | "crontabFile" | "parsedCronItems" | "concurrency" | "noHandleSignals" | "pollInterval" | "logger" | "maxPoolSize" | "pgPool" | "noPreparedStatements" | "forbiddenFlags" | "events" | "useNodeTime" | "checkInterval" | "leadTime" | "maxAge" | "workerSchema" | "schedulerSchema">) => Promise<void>;
export interface GraphileSecrets {
    ref: string;
    encrypted_secret: string;
}
export interface GraphileUnencryptedSecrets {
    ref: string;
    unencrypted_secret: string;
}
export declare const encryptSecret: (client: PoolClient, cryptr: Cryptr, secretRef: string) => Promise<void>;
export declare const getSecret: (client: PoolOrPoolClient, cryptr: Cryptr, secretRef: string) => Promise<string>;
export declare const setSecret: (client: PoolOrPoolClient, secretRef: string, unencryptedSecret: string) => Promise<void>;
export declare const deepCloneWithSecretReplacement: (client: PoolOrPoolClient, cryptr: Cryptr, v: any) => Promise<any>;
export declare const extractAfterFnAndContext: (payload: any) => {
    payload: any;
    afterFn: string | undefined;
    context: any;
};
export declare const wrapTask: (client: PoolOrPoolClient, cryptr: Cryptr, task: Task) => GraphileWorkerTask;
export {};