import { EngineService } from '../../engine';
import { ILogger } from '../../logger';
import { ActivityData, ActivityLeg, ActivityMetadata, ActivityType } from '../../../types/activity';
import { JobState } from '../../../types/job';
import { StreamCode, StreamData, StreamStatus } from '../../../types/stream';
interface ProcessContext {
    config: ActivityType;
    context: JobState;
    metadata: ActivityMetadata;
    engine: EngineService;
    logger: ILogger;
    status: StreamStatus;
    code: StreamCode;
    data: ActivityData;
    leg: ActivityLeg;
    adjacencyList: StreamData[];
    adjacentIndex: number;
    setLeg(leg: ActivityLeg): void;
    verifyReentry(): Promise<number>;
    bindActivityError(data: Record<string, unknown>): void;
    bindActivityData(type: 'output' | 'hook'): void;
    bindJobError(data: Record<string, unknown>): void;
    filterAdjacent(): Promise<StreamData[]>;
    mapJobData(): void;
    executeStepProtocol(delta: number, shouldFinalize: boolean): Promise<boolean>;
}
export declare function processEvent(instance: ProcessContext, status?: StreamStatus, code?: StreamCode, type?: 'hook' | 'output'): Promise<void>;
export {};