Package com.tnsai.coordination.groups.pipeline

Class DefaultPipelineOrg

java.lang.Object

com.tnsai.coordination.groups.DefaultAgentGroup

com.tnsai.coordination.groups.pipeline.DefaultPipelineOrg

All Implemented Interfaces:

com.tnsai.agents.groups.AgentGroup, PipelineOrganization

public class DefaultPipelineOrg
extends DefaultAgentGroup
implements PipelineOrganization

Default implementation of PipelineOrganization.

Provides sequential stage-based processing where input flows through each stage in order, with metrics tracking and bottleneck detection.

Constructor Summary

Constructors

Constructor	Description
DefaultPipelineOrg(String id, String name, String description, com.tnsai.agents.groups.GroupPolicy policy)	Creates a new DefaultPipelineOrg.

Method Summary

Modifier and Type	Method	Description
void	addStage(String name, String agentId)	Adds a new stage at the end of the pipeline.
PipelineResult	execute(String input)	Executes the pipeline with the given input.
Optional<String>	getBottleneck()	Returns the current bottleneck stage (slowest).
PipelineMetrics	getPipelineMetrics()	Returns the pipeline metrics.
List<Stage>	getStages()	Returns all stages in pipeline order.
String	toString()

Methods inherited from class com.tnsai.coordination.groups.DefaultAgentGroup

addLifecycleListener, addMember, addMembershipListener, assignTask, broadcast, dissolve, electLeader, electLeader, findMembers, getDescription, getEventBus, getId, getLeader, getLifecycle, getMember, getMembers, getMembershipManager, getMetrics, getName, getPolicy, hasMember, notifyTaskComplete, notifyTaskFailed, removeLifecycleListener, removeMember, removeMembershipListener, scatter, scatter, scatterAsync, setPolicy, start, stop, stopNow

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.tnsai.agents.groups.AgentGroup

addLifecycleListener, addMember, addMembershipListener, assignTask, broadcast, broadcast, dissolve, electLeader, electLeader, findMembers, getDescription, getEventBus, getId, getLeader, getLifecycle, getMember, getMemberCount, getMembers, getMembershipManager, getMetrics, getName, getPolicy, hasMember, isActive, isDissolved, removeLifecycleListener, removeMember, removeMembershipListener, scatter, scatter, scatterAsync, setPolicy, start, stop, stopNow

Constructor Details

DefaultPipelineOrg

public DefaultPipelineOrg(String id,
 String name,
 String description,
 com.tnsai.agents.groups.GroupPolicy policy)

Creates a new DefaultPipelineOrg.

Parameters:

id - pipeline ID

name - pipeline name

description - pipeline description

policy - group policy

Method Details

getStages

public List<Stage> getStages()

Description copied from interface: PipelineOrganization

Returns all stages in pipeline order.

Specified by:

getStages in interface PipelineOrganization

Returns:

ordered list of stages

addStage

public void addStage(String name,
 String agentId)

Description copied from interface: PipelineOrganization

Adds a new stage at the end of the pipeline.

Specified by:

addStage in interface PipelineOrganization

Parameters:

name - stage name

agentId - agent ID for this stage

execute

public PipelineResult execute(String input)

Description copied from interface: PipelineOrganization

Executes the pipeline with the given input. Data flows sequentially through each stage.

Specified by:

execute in interface PipelineOrganization

Parameters:

input - initial input

Returns:

pipeline execution result

getPipelineMetrics

public PipelineMetrics getPipelineMetrics()

Description copied from interface: PipelineOrganization

Returns the pipeline metrics.

Specified by:

getPipelineMetrics in interface PipelineOrganization

Returns:

pipeline metrics

getBottleneck

public Optional<String> getBottleneck()

Description copied from interface: PipelineOrganization

Returns the current bottleneck stage (slowest).

Specified by:

getBottleneck in interface PipelineOrganization

Returns:

bottleneck stage name, or empty if no data

toString

public String toString()

Overrides:

toString in class DefaultAgentGroup