import { type JsonValue } from "../state/json.js";
export declare const MAX_WORKFLOW_RUNNER_PROTOCOL_MESSAGE_BYTES: number;
export declare const WORKFLOW_RUNNER_CONTENT_CHUNK_BYTES: number;
export declare const WORKFLOW_RUNNER_MESSAGE_SCHEMA: "pi-workflows.worker-message.v1";
export declare const WORKFLOW_RUNNER_RESPONSE_SCHEMA: "pi-workflows.worker-response.v1";
export declare const WORKFLOW_RUNNER_CONTENT_REFERENCE_SCHEMA: "pi-workflows.worker-content-reference.v1";
export declare const WORKFLOW_RUNNER_CONTENT_CHUNK_SCHEMA: "pi-workflows.worker-content-chunk.v1";
export type WorkflowRunnerCommand = {
    kind: "start";
    input: JsonValue;
} | {
    kind: "resume";
    resumeInteractionAttemptId?: string;
} | {
    kind: "restart";
    input: JsonValue;
};
export declare const WORKFLOW_RUNNER_MESSAGE_KINDS: readonly ["runner.ready", "node.started", "node.update", "node.finished", "node.failed", "run.parked", "run.finished", "interaction.requested", "interaction.accepted", "interaction.rejected", "notification.requested", "effect.reserve", "effect.settle", "runner.progress", "runner.exiting"];
export type WorkflowRunnerMessageKind = (typeof WORKFLOW_RUNNER_MESSAGE_KINDS)[number];
export declare const WORKFLOW_RUNNER_STORE_OPERATIONS: readonly ["store.initializeRun", "store.prepareRunResume", "store.readRunState", "store.commitTransition", "store.publishUpdate", "store.findSettingsScope", "store.ensureSettingsScope", "store.getSettingsScopeAtChange", "store.readCheckpoint", "store.reserveEffect", "store.settleEffect", "content.read", "process.register", "process.unregister", "interaction.request", "interaction.accept", "interaction.reject", "notification.request"];
export type WorkflowRunnerStoreOperation = (typeof WORKFLOW_RUNNER_STORE_OPERATIONS)[number];
export type WorkflowRunnerMessage = {
    schema: typeof WORKFLOW_RUNNER_MESSAGE_SCHEMA;
    launchSchema: "pi-workflows.worker-launch.v1";
    messageId: string;
    kind: WorkflowRunnerMessageKind;
    operation: WorkflowRunnerStoreOperation | "runner.ready" | "runner.exiting";
    runId: string;
    generation: number;
    runnerEpoch: string;
    expectedRevision: number;
    attemptId?: string;
    payload: JsonValue;
};
export type WorkflowRunnerResponse = {
    schema: typeof WORKFLOW_RUNNER_RESPONSE_SCHEMA;
    messageId: string;
    outcome: "accepted" | "adopted" | "rejected" | "claimLost";
    revision?: number;
    result?: JsonValue;
    error?: string;
};
export type WorkflowRunnerContentReference = {
    schema: typeof WORKFLOW_RUNNER_CONTENT_REFERENCE_SCHEMA;
    sha256: string;
    mediaType: "application/json";
    bytes: number;
};
export type WorkflowRunnerContentChunk = {
    schema: typeof WORKFLOW_RUNNER_CONTENT_CHUNK_SCHEMA;
    sha256: string;
    mediaType: "application/json";
    bytes: number;
    offset: number;
    nextOffset: number;
    complete: boolean;
    data: string;
};
export declare function isRunnerContentReference(value: unknown): value is WorkflowRunnerContentReference;
export declare function isRunnerContentChunk(value: unknown): value is WorkflowRunnerContentChunk;
export declare function runnerKindForOperation(operation: WorkflowRunnerStoreOperation, payload: Record<string, unknown>): WorkflowRunnerMessageKind;
export declare function encodeRunnerLine(message: WorkflowRunnerMessage | WorkflowRunnerResponse): Buffer;
export declare function parseRunnerMessage(line: Buffer | string): WorkflowRunnerMessage;
export declare function parseRunnerResponse(line: Buffer | string): WorkflowRunnerResponse;