import { EngineDriver, WorkflowMessageDriver, KVEntry, KVWrite } from './index.js'; export { BranchConfig, BranchOutput, BranchStatus, BranchStatusType, CancelledError, CriticalError, DEFAULT_LOOP_HISTORY_PRUNE_INTERVAL, DEFAULT_MAX_RETRIES, DEFAULT_RETRY_BACKOFF_BASE, DEFAULT_RETRY_BACKOFF_MAX, DEFAULT_STEP_TIMEOUT, Entry, EntryInProgressError, EntryKind, EntryKindType, EntryMetadata, EntryStatus, EvictedError, History, HistoryDivergedError, JoinEntry, JoinError, Location, Loop, LoopConfig, LoopEntry, LoopIterationMarker, LoopResult, Message, MessageEntry, MessageWaitError, NameIndex, PathSegment, RaceEntry, RaceError, RemovedEntry, RollbackCheckpointEntry, RollbackCheckpointError, RollbackContextInterface, RollbackError, RunWorkflowOptions, SleepEntry, SleepError, SleepState, StepConfig, StepEntry, StepExhaustedError, StepFailedError, Storage, TryBlockCatchKind, TryBlockConfig, TryBlockFailure, TryBlockResult, TryStepCatchKind, TryStepConfig, TryStepFailure, TryStepResult, WorkflowContextImpl, WorkflowContextInterface, WorkflowEntryMetadataSnapshot, WorkflowError, WorkflowErrorEvent, WorkflowErrorHandler, WorkflowFunction, WorkflowHandle, WorkflowHistoryEntry, WorkflowHistorySnapshot, WorkflowQueue, WorkflowQueueMessage, WorkflowQueueNextBatchOptions, WorkflowQueueNextOptions, WorkflowResult, WorkflowRollbackErrorEvent, WorkflowRunErrorEvent, WorkflowRunMode, WorkflowState, WorkflowStepErrorEvent, appendLoopIteration, appendName, createEntry, createHistorySnapshot, createStorage, deleteEntriesWithPrefix, emptyLocation, extractErrorInfo, flush, generateId, getEntry, getOrCreateMetadata, isLocationPrefix, isLoopIterationMarker, loadMetadata, loadStorage, locationToKey, locationsEqual, parentLocation, registerName, replayWorkflowFromStep, resolveName, runWorkflow, setEntry } from './index.js'; import 'pino'; /** * In-memory implementation of EngineDriver for testing. * Uses binary keys (Uint8Array) with hex encoding for internal Map storage. */ declare class InMemoryDriver implements EngineDriver { #private; private kv; private alarms; /** Simulated latency per operation (ms) */ latency: number; /** How often the worker polls for work */ workerPollInterval: number; messageDriver: WorkflowMessageDriver; get(key: Uint8Array): Promise; set(key: Uint8Array, value: Uint8Array): Promise; delete(key: Uint8Array): Promise; deletePrefix(prefix: Uint8Array): Promise; deleteRange(start: Uint8Array, end: Uint8Array): Promise; list(prefix: Uint8Array): Promise; batch(writes: KVWrite[]): Promise; setAlarm(workflowId: string, wakeAt: number): Promise; clearAlarm(workflowId: string): Promise; waitForMessages(messageNames: string[], abortSignal: AbortSignal): Promise; /** * Get the alarm time for a workflow (for testing). */ getAlarm(workflowId: string): number | undefined; /** * Check if any alarms are due and return their workflow IDs. */ getDueAlarms(): string[]; /** * Clear all data (for testing). */ clear(): void; /** * Get a snapshot of all data (for testing/debugging). */ snapshot(): { kv: Record; alarms: Record; }; /** * Get all hex-encoded keys (for testing). */ keys(): string[]; } export { EngineDriver, InMemoryDriver, KVEntry, KVWrite, WorkflowMessageDriver };