Package com.tnsai.quality.security.harness

Interface PipelineStage

All Known Implementing Classes:
EnrichStage, ExportStage, ProcessStage, RevalidateStage, ScanStage
public interface PipelineStage
Pipeline stage SPI (TNS-291). One implementation per scan, process, revalidate, enrich, export.

Stages share state through PipelineStateStore — a stage reads the records produced by the previous stage and writes its own output back. Stages MUST be idempotent: re-running on already-completed state produces no net change (or a deterministic delta).

Since:
0.10.0 (TNS-291)

  • Method Details

    • id

      String id()
      Stable id, e.g. "scan", "process".

    • execute

      StageResult execute(PipelineContext ctx)
      Execute the stage. Reads from / writes to ctx.stateStore().

      Stages SHOULD respect Thread.interrupted() — long-running stages (process, revalidate) check periodically so the pipeline can be cancelled cleanly.