agentworkflow

type AgentConfig struct {
	agent.Config

	// Environment is the execution environment used to run the workflow on
	// each agent turn. When nil, [inproc.Concurrent] is used if every workflow
	// executor supports concurrent shared execution; otherwise [inproc.OffThread]
	// is used.
	Environment *inproc.ExecutionEnvironment

	// IncludeOutputsInResponse, if true, surfaces [workflow.OutputEvent]
	// payloads in the agent response stream when the payload is a
	// [*message.Message], [[]*message.Message], or [*agent.Response]. By
	// default, only [*agent.ResponseUpdate] payloads emitted by hosted agents
	// inside the workflow are surfaced as response content.
	IncludeOutputsInResponse bool

	// IncludeErrorDetails, if true, surfaces the full error message from
	// [workflow.ErrorEvent]s in the agent response stream. When false, a
	// generic message is emitted instead.
	IncludeErrorDetails bool
}

type ConcurrentWorkflowBuilder struct {
	// contains filtered or unexported fields
}

type Config struct {
	// EmitUpdateEvents controls whether streaming [agent.ResponseUpdate]
	// outputs are emitted as the agent runs. When nil, a [workflow.TurnToken]
	// controls update emission for that turn.
	EmitUpdateEvents *bool

	// EmitResponseEvents controls whether an aggregated [agent.Response]
	// output is emitted at the end of each turn.
	EmitResponseEvents bool

	// ForwardIncomingMessages controls whether incoming messages are forwarded
	// downstream before the agent runs. The default is true.
	ForwardIncomingMessages *bool

	// ReassignOtherAgentsAsUsers controls whether incoming
	// [message.RoleAssistant] messages whose [message.Message.AuthorName]
	// does not match this agent are rewritten to [message.RoleUser]. The default
	// is true.
	ReassignOtherAgentsAsUsers *bool

	// InterceptUserInputRequests controls how [message.ToolApprovalRequestContent]
	// produced by the agent is dispatched.
	//
	// When false (the default), each request is raised as a workflow
	// [workflow.ExternalRequest] via [workflow.Context.PostRequest], and
	// the matching [workflow.ExternalResponse] is delivered back to this
	// executor by the runner.
	//
	// When true, each request is sent as a regular workflow message (via
	// [workflow.Context.SendMessage]) so other executors in the graph can
	// handle the approval; the matching
	// [message.ToolApprovalResponseContent] must be routed back to
	// this executor as a workflow message.
	//
	// In both modes the agent is re-invoked with the response merged into
	// the conversation, and the [workflow.TurnToken] propagated downstream
	// after the turn is held until all outstanding requests are resolved.
	InterceptUserInputRequests bool

	// InterceptUnterminatedFunctionCalls controls how
	// [message.FunctionCallContent] produced by the agent without a
	// matching [message.FunctionResultContent] in the same turn is
	// dispatched.
	//
	// When false (the default), each unresolved call is raised as a
	// workflow [workflow.ExternalRequest] via
	// [workflow.Context.PostRequest], and the matching
	// [workflow.ExternalResponse] is delivered back to this executor by
	// the runner.
	//
	// When true, each unresolved call is sent as a regular workflow
	// message (via [workflow.Context.SendMessage]); the matching
	// [message.FunctionResultContent] must be routed back to this
	// executor as a workflow message.
	//
	// In both modes the agent is re-invoked with the result merged into
	// the conversation, and the [workflow.TurnToken] propagated downstream
	// after the turn is held until all outstanding calls are resolved.
	InterceptUnterminatedFunctionCalls bool
}

type GroupChatManager struct {
	// SelectNextAgent selects the next participant to speak. Returning nil ends
	// the chat and yields the accumulated conversation.
	SelectNextAgent func(ctx context.Context, history []*message.Message) (*agent.Agent, error)

	// UpdateHistory filters the messages broadcast to participants for the current
	// turn. Returning nil preserves the original messages.
	UpdateHistory func(ctx context.Context, messages []*message.Message) ([]*message.Message, error)

	// ShouldTerminate decides whether the chat should end. When nil, the host
	// stops after 40 participant turns.
	ShouldTerminate func(ctx context.Context, history []*message.Message, iterationCount int) (bool, error)

	// Reset clears manager-owned local state when the hosting executor is reset.
	Reset func()

	// OnCheckpoint persists manager-owned state. The supplied context prefixes
	// state keys with "GroupChatManager_" so custom manager state cannot collide
	// with host state.
	OnCheckpoint func(ctx *workflow.Context) error

	// OnCheckpointRestored restores manager-owned state from the same prefixed
	// state context used by OnCheckpoint.
	OnCheckpointRestored func(ctx *workflow.Context) error
}

type GroupChatManagerFactory func(agents []*agent.Agent) *GroupChatManager

type GroupChatWorkflowBuilder struct {
	// contains filtered or unexported fields
}

type MessageAggregator func(context.Context, [][]*message.Message) []*message.Message

type ResetSignal struct{}

type RoundRobinGroupChatOptions struct {
	// MaximumIterationCount is the maximum number of participant turns before
	// the default termination behavior ends the chat. The zero value is 40.
	MaximumIterationCount int

	// ShouldTerminate can stop the chat before the default iteration-limit check
	// runs.
	ShouldTerminate func(ctx context.Context, history []*message.Message, iterationCount int) (bool, error)
}

type SequentialWorkflowBuilder struct {
	// contains filtered or unexported fields
}