import { RetryPolicy } from '@sha1n/about-time';
import { Pipeline } from './Pipeline';
import { HandlerContext, StatefulPipelineEntity } from './types';
declare class PipelineDriver<T extends StatefulPipelineEntity<S>, S, C extends HandlerContext> {
    readonly push: (entity: T, ctx: C) => Promise<T>;
    constructor(pipeline: Pipeline<T, S, C>, retryPolicy?: RetryPolicy);
}
export { PipelineDriver };