Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2026 Changes in this version + func New(a *agent.Agent, cfg Config) workflow.ExecutorBinding + func NewAgent(wf *workflow.Workflow, cfg AgentConfig) (*agent.Agent, error) + type AgentConfig struct + Environment *inproc.ExecutionEnvironment + IncludeErrorDetails bool + IncludeOutputsInResponse bool + type ConcurrentWorkflowBuilder struct + func NewConcurrentWorkflowBuilder(agents ...*agent.Agent) *ConcurrentWorkflowBuilder + func (b *ConcurrentWorkflowBuilder) Build() (*workflow.Workflow, error) + func (b *ConcurrentWorkflowBuilder) WithAggregator(aggregator MessageAggregator) *ConcurrentWorkflowBuilder + func (b *ConcurrentWorkflowBuilder) WithDescription(description string) *ConcurrentWorkflowBuilder + func (b *ConcurrentWorkflowBuilder) WithIntermediateOutputFrom(agents ...*agent.Agent) *ConcurrentWorkflowBuilder + func (b *ConcurrentWorkflowBuilder) WithName(name string) *ConcurrentWorkflowBuilder + func (b *ConcurrentWorkflowBuilder) WithOutputFrom(agents ...*agent.Agent) *ConcurrentWorkflowBuilder + type Config struct + EmitResponseEvents bool + EmitUpdateEvents *bool + ForwardIncomingMessages *bool + InterceptUnterminatedFunctionCalls bool + InterceptUserInputRequests bool + ReassignOtherAgentsAsUsers *bool + type GroupChatManager struct + OnCheckpoint func(ctx *workflow.Context) error + OnCheckpointRestored func(ctx *workflow.Context) error + Reset func() + SelectNextAgent func(ctx context.Context, history []*message.Message) (*agent.Agent, error) + ShouldTerminate func(ctx context.Context, history []*message.Message, iterationCount int) (bool, error) + UpdateHistory func(ctx context.Context, messages []*message.Message) ([]*message.Message, error) + func NewRoundRobinGroupChatManager(agents []*agent.Agent, opts RoundRobinGroupChatOptions) *GroupChatManager + type GroupChatManagerFactory func(agents []*agent.Agent) *GroupChatManager + type GroupChatWorkflowBuilder struct + func NewGroupChatWorkflowBuilder(managerFactory GroupChatManagerFactory, agents ...*agent.Agent) *GroupChatWorkflowBuilder + func (b *GroupChatWorkflowBuilder) Build() (*workflow.Workflow, error) + func (b *GroupChatWorkflowBuilder) WithDescription(description string) *GroupChatWorkflowBuilder + func (b *GroupChatWorkflowBuilder) WithIntermediateOutputFrom(agents ...*agent.Agent) *GroupChatWorkflowBuilder + func (b *GroupChatWorkflowBuilder) WithName(name string) *GroupChatWorkflowBuilder + func (b *GroupChatWorkflowBuilder) WithOutputFrom(agents ...*agent.Agent) *GroupChatWorkflowBuilder + type MessageAggregator func(context.Context, [][]*message.Message) []*message.Message + type ResetSignal struct + type RoundRobinGroupChatOptions struct + MaximumIterationCount int + ShouldTerminate func(ctx context.Context, history []*message.Message, iterationCount int) (bool, error) + type SequentialWorkflowBuilder struct + func NewSequentialWorkflowBuilder(agents ...*agent.Agent) *SequentialWorkflowBuilder + func (b *SequentialWorkflowBuilder) Build() (*workflow.Workflow, error) + func (b *SequentialWorkflowBuilder) WithChainOnlyAgentResponses(enabled bool) *SequentialWorkflowBuilder + func (b *SequentialWorkflowBuilder) WithDescription(description string) *SequentialWorkflowBuilder + func (b *SequentialWorkflowBuilder) WithIntermediateOutputFrom(agents ...*agent.Agent) *SequentialWorkflowBuilder + func (b *SequentialWorkflowBuilder) WithName(name string) *SequentialWorkflowBuilder + func (b *SequentialWorkflowBuilder) WithOutputFrom(agents ...*agent.Agent) *SequentialWorkflowBuilder
Go to main page