Package ai.pipestream.module.pipelineprobe.mockengine

package ai.pipestream.module.pipelineprobe.mockengine

Related Packages

Package	Description
ai.pipestream.module.pipelineprobe

Classes

Class	Description
MockWorkCorpus	The bounded supply of work the MockWorkEngineService hands out.
MockWorkEngineResource	Control + observability for the MockWorkEngineService.
MockWorkEngineService	A mock ModuleWorkService engine for exercising a module's demand-pull work loop in isolation — no real engine, Kafka, Redis or S3.
MockWorkStats	Accumulates what the module-under-test did with the served work: how many units it acked, by ProcessingStatus (SUCCESS / RETRYABLE / PERMANENT) and by result disposition (UPDATED_PAYLOAD / NO_OP / REJECT), plus a wall-clock throughput between the first served unit and the last ack.