Class E2ETuningHelper

java.lang.Object
ai.pipestream.module.pipelineprobe.e2e.E2ETuningHelper
@ApplicationScoped public class E2ETuningHelper extends Object
Shared helper for pipeline-crawl graph building: applies per-run tuning overrides to graph nodes. All methods are no-ops when the corresponding override is absent.

  • Constructor Summary

    Constructors
    Constructor
    Description
    E2ETuningHelper()
    Creates the tuning helper.

  • Method Summary

    Modifier and Type
    Method
    Description
    ai.pipestream.config.v1.GraphNode.Builder
    applyKafkaPartitions(ai.pipestream.config.v1.GraphNode.Builder nodeBuilder, int kafkaPartitions)
    Applies the kafka partition count to a GraphNode builder if the partition override is positive.

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • E2ETuningHelper

      public E2ETuningHelper()
      Creates the tuning helper. Instances are managed by CDI.

  • Method Details

    • applyKafkaPartitions

      public ai.pipestream.config.v1.GraphNode.Builder applyKafkaPartitions(ai.pipestream.config.v1.GraphNode.Builder nodeBuilder, int kafkaPartitions)
      Applies the kafka partition count to a GraphNode builder if the partition override is positive. Returns the same builder for chaining.
      Parameters:
      nodeBuilder - the graph node builder to tune
      kafkaPartitions - partition override; ignored when not positive
      Returns:
      the same nodeBuilder for chaining