Record Class PipelineGraphFactory.Built

java.lang.Object
java.lang.Record
ai.pipestream.module.pipelineprobe.e2e.PipelineGraphFactory.Built
Record Components:
graph - the built pipeline graph
entryNodeId - node-id the engine routes intake documents into (the virtual intake node)
terminalNodeId - node-id of the terminal testing-sidecar
mainFlowNodeIds - effective main-flow step node-ids in graph order, e.g. ["parser","chunker","embedder"]
tapNodeIds - tap node-ids in the same order as mainFlowNodeIds
receiveNodeIds - receive-side stages the wait loop must close: all taps plus the terminal sidecar
richTapNodeIds - subset of tapNodeIds that the TestProcessor will run rich-mode for
Enclosing class:
PipelineGraphFactory
public static record PipelineGraphFactory.Built(ai.pipestream.config.v1.PipelineGraph graph, String entryNodeId, String terminalNodeId, List<String> mainFlowNodeIds, List<String> tapNodeIds, List<String> receiveNodeIds, Set<String> richTapNodeIds) extends Record
Result of PipelineGraphFactory.build(String, String, PipelineSource, Set, Set, Set, List, int, Struct, Struct, Struct, Struct, Struct, String) — graph + names callers need to dispatch into it.

  • Constructor Details

    • Built

      public Built(ai.pipestream.config.v1.PipelineGraph graph, String entryNodeId, String terminalNodeId, List<String> mainFlowNodeIds, List<String> tapNodeIds, List<String> receiveNodeIds, Set<String> richTapNodeIds)
      Creates an instance of a Built record class.
      Parameters:
      graph - the value for the graph record component
      entryNodeId - the value for the entryNodeId record component
      terminalNodeId - the value for the terminalNodeId record component
      mainFlowNodeIds - the value for the mainFlowNodeIds record component
      tapNodeIds - the value for the tapNodeIds record component
      receiveNodeIds - the value for the receiveNodeIds record component
      richTapNodeIds - the value for the richTapNodeIds record component

  • Method Details

    • toString

      public final String toString()
      Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.
      Specified by:
      toString in class Record
      Returns:
      a string representation of this object

    • hashCode

      public final int hashCode()
      Returns a hash code value for this object. The value is derived from the hash code of each of the record components.
      Specified by:
      hashCode in class Record
      Returns:
      a hash code value for this object

    • equals

      public final boolean equals(Object o)
      Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. All components in this record class are compared with Objects::equals(Object,Object).
      Specified by:
      equals in class Record
      Parameters:
      o - the object with which to compare
      Returns:
      true if this object is the same as the o argument; false otherwise.

    • graph

      public ai.pipestream.config.v1.PipelineGraph graph()
      Returns the value of the graph record component.
      Returns:
      the value of the graph record component

    • entryNodeId

      public String entryNodeId()
      Returns the value of the entryNodeId record component.
      Returns:
      the value of the entryNodeId record component

    • terminalNodeId

      public String terminalNodeId()
      Returns the value of the terminalNodeId record component.
      Returns:
      the value of the terminalNodeId record component

    • mainFlowNodeIds

      public List<String> mainFlowNodeIds()
      Returns the value of the mainFlowNodeIds record component.
      Returns:
      the value of the mainFlowNodeIds record component

    • tapNodeIds

      public List<String> tapNodeIds()
      Returns the value of the tapNodeIds record component.
      Returns:
      the value of the tapNodeIds record component

    • receiveNodeIds

      public List<String> receiveNodeIds()
      Returns the value of the receiveNodeIds record component.
      Returns:
      the value of the receiveNodeIds record component

    • richTapNodeIds

      public Set<String> richTapNodeIds()
      Returns the value of the richTapNodeIds record component.
      Returns:
      the value of the richTapNodeIds record component