workflow

Nov 18, 2025

Changes in this version

+ type Agent interface

+ Execute func(ctx context.Context, message string) iter.Seq2[*session.Event, error]

+ Name func() string

+ type LoopAgent struct

+ func NewLoopAgent(cfg LoopConfig) (*LoopAgent, error)

+ func (a *LoopAgent) Execute(ctx context.Context, message string) iter.Seq2[*session.Event, error]

+ func (a *LoopAgent) MaxIterations() uint

+ func (a *LoopAgent) Name() string

+ func (a *LoopAgent) SubAgents() []Agent

+ type LoopConfig struct

+ MaxIterations uint

+ Name string

+ StopCondition StopCondition

+ SubAgents []Agent

+ type ParallelAgent struct

+ func NewParallelAgent(cfg ParallelConfig) (*ParallelAgent, error)

+ func (a *ParallelAgent) AddSubAgent(agent Agent)

+ func (a *ParallelAgent) Execute(ctx context.Context, message string) iter.Seq2[*session.Event, error]

+ func (a *ParallelAgent) Name() string

+ func (a *ParallelAgent) SubAgents() []Agent

+ type ParallelConfig struct

+ MaxConcurrent int

+ Name string

+ SubAgents []Agent

+ type SequentialAgent struct

+ func NewSequentialAgent(cfg SequentialConfig) (*SequentialAgent, error)

+ func (a *SequentialAgent) Execute(ctx context.Context, message string) iter.Seq2[*session.Event, error]

+ type SequentialConfig struct

+ Name string

+ StopOnError bool

+ SubAgents []Agent

+ type StopCondition func(event *session.Event) bool