Versions in this module Expand all Collapse all v2 v2.12.0 Aug 6, 2026 v2.11.4 Aug 3, 2026 v2.11.3 Aug 2, 2026 Changes in this version type State + ObservationAging bool + func (s *State) CompactAllObservations(maxBytes int) int + func (s *State) CompactObservations(keepRecent, maxBytes int) int + func (s *State) EnableObservationAging() + func (s *State) LatestPromptTokens() int v2.11.2 Jul 31, 2026 Changes in this version + const AskUserTool + const EventAction + const EventAskUser + const EventRejected + const EventStalled + const EventTaskStatus + const SetTaskStatusTool + func MergeParams(stepParams string, args map[string]any, pinned map[string]struct{}) string + func ParamString(args map[string]any) string + func PinnedParams(step core.Step) map[string]struct + func ValidTaskStatus(value string) bool + type Catalog struct + func NewCatalog(ctx context.Context, dag *core.DAG) (*Catalog, error) + func (c *Catalog) Definitions() []exec.ToolDefinition + func (c *Catalog) StepFor(tool string) (string, bool) + func (c *Catalog) ToolNames() []string + func (c *Catalog) Tools() []llmpkg.Tool + type Decision struct + Args map[string]any + Content string + Kind DecisionKind + Problem string + Question string + Reason string + Step string + Task string + TaskStatus TaskStatus + ToolCallID string + ToolName string + type DecisionKind int + const DecideAskUser + const DecideInvalid + const DecideRunStep + const DecideSetTaskStatus + const DecideStop + type Event struct + Attempt int + ChildDAGName string + ChildDAGRunID string + FinishedAt string + Kind string + Name string + Reason string + StartedAt string + Status string + Turn int + func EventsFromState(raw json.RawMessage) []Event + type MaskFunc func([]exec.LLMMessage) []exec.LLMMessage + type PendingAction struct + Question string + Step string + ToolCallID string + ToolName string + type Planner struct + func NewPlanner(provider llmpkg.Provider, cfg *core.LLMConfig, catalog *Catalog, system string, ...) *Planner + func (p *Planner) Next(ctx context.Context, st *State) (*Decision, error) + type State struct + Answers map[string]string + Events []Event + Nudges int + Pending *PendingAction + StepRuns map[string]int + Tasks []TaskState + Turns int + func LoadState(raw json.RawMessage, messages []exec.LLMMessage, dag *core.DAG) (*State, error) + func NewState(dag *core.DAG) *State + func (s *State) Append(msgs ...exec.LLMMessage) + func (s *State) FailedTasks() []TaskState + func (s *State) FinalizeEvent(step, status, finishedAt, reason string) + func (s *State) Marshal() (json.RawMessage, error) + func (s *State) Messages() []exec.LLMMessage + func (s *State) OpenTaskNames() []string + func (s *State) PriorAnswer(question string) (string, bool) + func (s *State) QuestionCount() int + func (s *State) RecordAnswer(question, answer string) + func (s *State) RecordEvent(e Event) + func (s *State) RecordStepRun(step string) int + func (s *State) SetTaskStatus(name string, status TaskStatus, reason string) error + func (s *State) Settled() bool + func (s *State) StepRunCount(step string) int + type TaskState struct + Description string + Done bool + Name string + Reason string + Status TaskStatus + func TasksFromState(raw json.RawMessage) []TaskState + type TaskStatus string + const TaskCompleted + const TaskFailed + const TaskOpen + const TaskSkipped
Go to main page