workflow

Oct 25, 2026

Changes in this version

type Compiled

+ Closers []io.Closer

+ type StepModelHooks struct

+ After []llmagent.AfterModelCallback

+ Before []llmagent.BeforeModelCallback

+ Closer io.Closer

Sep 26, 2026

Changes in this version

type WorkflowAgentConfig

+ ModelCallbacksBuilder func(step Step, llm model.LLM) ([]llmagent.BeforeModelCallback, []llmagent.AfterModelCallback)

Aug 29, 2026

Changes in this version

+ const StatusDone

+ const StatusFailed

+ const StatusWorking

+ const WorkflowsGlobalDirName

+ const WorkflowsRepoDirName

+ var DefaultTracker = NewTracker()

+ var ErrWorkflowAmbiguous = errors.New("workflow exists in multiple scopes; pass scope to pick one")

+ func BuildStepInstruction(step Step, source Source, pc *StepPromptCtx) string

+ func ChatTurnCountLabel(n int) string

+ func DefToConfigDef(d Def) config.WorkflowDef

+ func EndTurnInstructionBlock(loop *LoopPromptCtx) string

+ func ExportBytes(d Def) ([]byte, error)

+ func ExportFile(d Def) (string, error)

+ func FileName(name string) string

+ func GlobalDir() string

+ func LoopNoteLine(loopName, action, detail string) string

+ func MutateWorkflows(cwd string, fn func(items []Def) ([]Def, error)) error

+ func ProviderMeta(provider, model string) string

+ func RepoDir(cwd string) string

+ func SaveAll(cwd string, items []Def) error

+ func StepSummaryLine(name, provider, model, summary string) string

+ func WorkflowNoteLine(msg, detail string) string

+ type ChatTurn struct

+ Role string

+ Text string

+ type Compiled struct

+ AgentInfo map[string]StepAgentInfo

+ Models []model.LLM

+ Workflow *adkworkflow.Workflow

+ func CompileWorkflow(ctx context.Context, cfg WorkflowAgentConfig) (*Compiled, error)

+ func (c *Compiled) Close() error

+ func (c *Compiled) StepIndex(author string) (int, bool)

+ type Def struct

+ Description string

+ Name string

+ Plugin string

+ Scope Scope

+ Steps []Step

+ func ConfigDefToDef(d config.WorkflowDef) Def

+ func ListAll(cwd string) []Def

+ func LoadFileWorkflows(dir string, scope Scope) []Def

+ func LoadPluginWorkflows(cwd string) []Def

+ func LoadUserWorkflows(cwd string) ([]Def, error)

+ func ResolveByName(cwd, name string, scope Scope) (Def, error)

+ func (d Def) EffectiveMaxIterations(s Step) int

+ func (d Def) ReadOnly() bool

+ func (d Def) Validate() error

+ type FinishData struct

+ Artifacts []string

+ Description string

+ type LoopPromptCtx struct

+ ExitCondition string

+ IsTail bool

+ MaxIterations int

+ Name string

+ type NoopRunnerListener struct

+ func (NoopRunnerListener) OnNote(int, string)

+ func (NoopRunnerListener) OnWorkflowDone(int, string, []string)

+ func (NoopRunnerListener) OnWorkflowFailed(int, string)

+ func (NoopRunnerListener) OnWorkflowStarted(int, Def, Source)

+ func (NoopRunnerListener) OnWorkflowStepDone(int, int, string)

+ func (NoopRunnerListener) OnWorkflowStepStarted(int, int, string, string, string)

+ type Progress struct

+ func NewProgress(compiled *Compiled, def Def, src Source, cwd string, tabID int, ...) *Progress

+ func (p *Progress) Finish(err error) *RunState

+ func (p *Progress) Observe(ev *session.Event)

+ func (p *Progress) SetFinishData(fd *FinishData)

+ func (p *Progress) State() *RunState

+ type RunState struct

+ Done bool

+ Failed bool

+ FailedReason string

+ FinishData *FinishData

+ Source Source

+ StartedAt time.Time

+ StepIdx int

+ Workflow Def

+ type RunnerListener interface

+ OnNote func(tabID int, text string)

+ OnWorkflowDone func(tabID int, description string, artifacts []string)

+ OnWorkflowFailed func(tabID int, reason string)

+ OnWorkflowStarted func(tabID int, def Def, src Source)

+ OnWorkflowStepDone func(tabID int, stepIdx int, summary string)

+ OnWorkflowStepStarted func(tabID int, stepIdx int, stepName, provider, model string)

+ type Scope string

+ const ScopeGlobal

+ const ScopePlugin

+ const ScopeRepo

+ const ScopeUser

+ func NormalizeScope(s Scope) (Scope, error)

+ type Source struct

+ ChatKey string

+ ChatLabel string

+ ChatTranscript []ChatTurn

+ IssueDisplay string

+ IssueKey string

+ Kind SourceKind

+ TextAppend string

+ TextKey string

+ TextLabel string

+ func NewChatSource(originTabID int, turns []ChatTurn) Source

+ func NewTextSource(originTabID int, appendText string) Source

+ func (s Source) Display() string

+ func (s Source) Key() string

+ func (s Source) RefBlock() string

+ type SourceKind int

+ const SourceKindChat

+ const SourceKindIssue

+ const SourceKindText

+ type StatusListener func(key string, status string)

+ type Step struct

+ ExitCondition string

+ Kind string

+ MaxIterations int

+ Model string

+ Name string

+ Prompt string

+ Provider string

+ Steps []Step

+ func (s Step) IsLoop() bool

+ type StepAgentInfo struct

+ InLoop bool

+ InnerIdx int

+ LoopName string

+ Model string

+ Provider string

+ StepIndex int

+ StepName string

+ type StepPromptCtx struct

+ IsStartStep bool

+ IsWorkflowFinalStep bool

+ Loop *LoopPromptCtx

+ type StepRole struct

+ InLoop bool

+ IsFinal bool

+ IsTail bool

+ type Tracker struct

+ func GlobalTracker() *Tracker

+ func NewTracker() *Tracker

+ func (t *Tracker) ActiveTabFor(key string) (int, bool)

+ func (t *Tracker) ActiveWorkflowNames() map[string]struct{}

+ func (t *Tracker) Clear(key string)

+ func (t *Tracker) Lookup(cwd, key string) (TrackerEntry, bool)

+ func (t *Tracker) MarkFinal(cwd, key, workflow, status string, stepIdx int)

+ func (t *Tracker) MarkStep(key string, stepIdx int)

+ func (t *Tracker) MarkWorking(cwd, key, workflow string, tabID int)

+ func (t *Tracker) ResetForTest()

+ func (t *Tracker) SetListener(l StatusListener)

+ type TrackerEntry struct

+ StartedAt time.Time

+ Status string

+ StepIndex int

+ TabID int

+ UpdatedAt time.Time

+ Workflow string

+ type WorkflowAgentConfig struct

+ BeforeModelCallbacks []llmagent.BeforeModelCallback

+ Cwd string

+ Def Def

+ InstructionBuilder func(step Step, src Source, pc *StepPromptCtx) string

+ MaxRetries int

+ ModelBuilder func(ctx context.Context, step Step) (model.LLM, error)

+ Source Source

+ TabID int

+ ToolsBuilder func(ctx context.Context, step Step, role StepRole) ([]tool.Tool, error)

+ ToolsetsBuilder func(ctx context.Context, step Step, role StepRole) ([]tool.Toolset, error)