interface ErrorInjection { failAfter(n: number, error?: Error): void; failOn(pattern: RegExp, error?: Error): void; withLatency(minMs: number, maxMs?: number): void; clearInjections(): void; } interface MockOperation { type: "read" | "write" | "delete" | "list"; key?: string; timestamp: number; } interface MockOperations { operations: MockOperation[]; reads(): MockOperation[]; writes(): MockOperation[]; deletes(): MockOperation[]; reset(): void; } interface MockMessage { body: unknown; contentType?: string; } /** * In-memory Queue mock for unit testing. */ declare function createMockQueue(): Queue & { _messages: MockMessage[]; } & MockOperations & ErrorInjection; export { createMockQueue };