import { EngineService } from '../../engine';
import { ILogger } from '../../logger';
import { StoreService } from '../../store';
import { ActivityMetadata, ActivityType } from '../../../types/activity';
import { ProviderClient, ProviderTransaction, TransactionResultList } from '../../../types/provider';
import { JobState } from '../../../types/job';
import { StreamData } from '../../../types/stream';
interface ProtocolContext {
    config: ActivityType;
    context: JobState;
    metadata: ActivityMetadata;
    store: StoreService<ProviderClient, ProviderTransaction>;
    engine: EngineService;
    logger: ILogger;
    adjacencyList: StreamData[];
    adjacentIndex: number;
    guidLedger: number;
    mapStatusThreshold(): number;
    setState(txn?: ProviderTransaction): Promise<string>;
    shouldEmit(): boolean;
    shouldPersistJob(): boolean;
    resolveThresholdHit(results: TransactionResultList): boolean;
}
/**
 * 3-step Leg2 protocol using GUID ledger for crash-safe resume.
 * Each step bundles durable writes with its concluding digit
 * update in a single transaction.
 */
export declare function executeStepProtocol(instance: ProtocolContext, delta: number, shouldFinalize: boolean): Promise<boolean>;
/**
 * 3-step Leg1 protocol for Category B activities
 * (Leg1-only with children: Hook passthrough, Signal, Interrupt-another).
 *
 * Step A: setState + Leg1 completion + step1 marker
 * Step B: publish children + semaphore + edge capture
 * Step C: if edge → completion tasks + finalize
 */
export declare function executeLeg1StepProtocol(instance: ProtocolContext, delta: number): Promise<boolean>;
export {};