Class StepScaffolds

java.lang.Object
ai.pipestream.module.pipelineprobe.moduletest.scaffold.StepScaffolds
@ApplicationScoped public class StepScaffolds extends Object
Factory for per-step StepScaffolds — forStep("embedder") etc. Keeps the "what does this step need to run in isolation" logic in one place; the perf/test runners just ask for a scaffold and use prepare/wrap/cleanup.

  • Constructor Details

    • StepScaffolds

      public StepScaffolds()
      Creates the scaffold factory. Instances are managed by CDI.

  • Method Details

    • forStep

      public StepScaffold forStep(String module)
      Scaffold with default options (sink → CHUNK_COMBINED, the e2e default).
      Parameters:
      module - the module/step to build a scaffold for
      Returns:
      a fresh scaffold for the module, using default options

    • forStep

      public StepScaffold forStep(String module, String strategyRaw)
      A fresh scaffold for the given module. Stateful (prepare() stores provisioned ids), so callers get a new instance per session.
      Parameters:
      module - the module/step to build a scaffold for
      strategyRaw - opensearch-sink only: indexing strategy name — nested / separate_indices / chunk_combined (case-insensitive, full enum names also accepted); null/blank = CHUNK_COMBINED, matching the e2e default. Ignored by other steps.
      Returns:
      a fresh scaffold for the module