agent

package module

Go to main page

Versions in this module

v0

v0.3.4

Jul 19, 2026

v0.3.3

Jul 18, 2026

v0.3.2

Jul 18, 2026

v0.3.1

Jul 18, 2026

Changes in this version

type ModelConfig

+ func (c ModelConfig) BuildModelWithLogger(logger *slog.Logger) (model.Model, error)

v0.3.0

Jul 15, 2026

Changes in this version

type Config

+ func (c Config) Validate() error

type Harness

+ func (h *Harness) CreateAgent(name, systemPrompt string) (*engine.Agent, error)

+ func (h *Harness) CreateAgentWithTools(name, systemPrompt string, toolNames ...string) (*engine.Agent, error)

+ func (h *Harness) CreateTeam(cfg workflow.TeamConfig) (*workflow.Team, error)

+ func (h *Harness) CreateWorkflow(cfg workflow.WorkflowConfig) (*workflow.Workflow, error)

+ func (h *Harness) NewTask(options taskpkg.Options) (*Task, error)

+ func (h *Harness) RestoreTask(input taskpkg.RestoreInput, sink taskpkg.EventSink) (*Task, error)

type MCPClientConfig

+ ProtocolVersion string

type Option

+ func WithLogger(logger *slog.Logger) Option

+ func WithMCPClient(name string, client *mcp.Client) Option

+ func WithModel(runtimeModel model.Model) Option

+ type Task struct

+ func (t *Task) AnswerInteraction(ctx context.Context, requestID string, answers map[string][]string) error

+ func (t *Task) CancelTurn(_ context.Context, turnID string) error

+ func (t *Task) Close()

+ func (t *Task) StartAgent(ctx context.Context, agentName, input string, options ...engine.RunOption) (*taskpkg.Turn, error)

+ func (t *Task) StartTeam(ctx context.Context, teamName, input string) (*taskpkg.Turn, error)

+ func (t *Task) StartWorkflow(ctx context.Context, workflowName, input string) (*taskpkg.Turn, error)

+ func (t *Task) TaskID() string

+ func (t *Task) WaitTurn(ctx context.Context, turnID string) (*taskpkg.Result, error)

v0.2.0

Jul 15, 2026

Changes in this version

type Harness

+ func (h *Harness) Agent(name string) (*engine.Agent, bool)

+ func (h *Harness) RegisterAgent(runtimeAgent *engine.Agent) error

+ func (h *Harness) Team(name string) (*workflow.Team, bool)

+ func (h *Harness) Workflow(name string) (*workflow.Workflow, bool)

+ type Option func(*harnessOptions)

+ func WithInputValidator(validator security.InputValidator) Option

+ func WithOutputValidator(validator security.OutputValidator) Option

+ func WithPermissionManager(manager security.PermissionManager) Option

+ func WithSanitizer(sanitizer security.Sanitizer) Option

v0.1.0

Jul 15, 2026

Changes in this version

+ const ModeLeaderFollower

+ const ModeParallel

+ const ModeSequential

+ const NodeTypeCondition

+ const NodeTypeLoop

+ const NodeTypeParallel

+ const NodeTypeStep

+ const PermExec

+ const PermNetAccess

+ const PermReadDB

+ const PermReadFile

+ const PermSendEmail

+ const PermWriteDB

+ const PermWriteFile

+ func ResolveModelDefaults(cfg *ModelConfig)

+ type Agent = engine.Agent

+ func NewAgent(cfg AgentConfig) *Agent

+ type AgentConfig = engine.AgentConfig

+ type ConditionNode = orchestrator.ConditionNode

+ func NewConditionNode(id string, condition func(input string, state map[string]any) (bool, error), ...) *ConditionNode

+ type Config struct

+ AllowedTools []string

+ DefaultModel ModelConfig

+ LogLevel string

+ MCPClients []MCPClientConfig

+ MemoryConfig MemoryConfig

+ Name string

+ PermissionMode string

+ Security SecurityConfig

+ Version string

+ func DefaultConfig() Config

+ func LoadConfig(path string) (Config, error)

+ type Harness struct

+ Agents map[string]*engine.Agent

+ Config Config

+ InputValidator *security.InputValidator

+ Memory memory.Memory

+ Model model.Model

+ OutputValidator *security.OutputValidator

+ PermissionMgr *security.PermissionManager

+ Sanitizer *security.Sanitizer

+ Teams map[string]*orchestrator.Team

+ ToolRegistry *tool.Registry

+ Workflows map[string]*orchestrator.Workflow

+ func New(cfg Config) (*Harness, error)

+ func (h *Harness) AllowPermissions(permissions ...security.Permission)

+ func (h *Harness) CheckPermission(perm security.Permission) error

+ func (h *Harness) Close() error

+ func (h *Harness) DenyPermissions(permissions ...security.Permission)

+ func (h *Harness) InitMCPClients(ctx context.Context) error

+ func (h *Harness) NewAgent(name, systemPrompt string) *engine.Agent

+ func (h *Harness) NewTeam(cfg orchestrator.TeamConfig) *orchestrator.Team

+ func (h *Harness) NewWorkflow(cfg orchestrator.WorkflowConfig) *orchestrator.Workflow

+ func (h *Harness) RegisterTeam(team *orchestrator.Team) error

+ func (h *Harness) RegisterTool(t tool.Tool) error

+ func (h *Harness) RegisterWorkflow(workflow *orchestrator.Workflow) error

+ func (h *Harness) RunAgent(ctx context.Context, name, input string, opts ...engine.RunOption) *engine.RunOutput

+ func (h *Harness) RunTeam(ctx context.Context, name, input string) *orchestrator.TeamOutput

+ func (h *Harness) RunWorkflow(ctx context.Context, name, input string) *orchestrator.WorkflowResult

+ func (h *Harness) Sanitize(input string) string

+ func (h *Harness) ValidateInput(input string) error

+ func (h *Harness) ValidateOutput(output string) error

+ type LoopNode = orchestrator.LoopNode

+ func NewLoopNode(id string, body Node, ...) *LoopNode

+ type MCPClientConfig struct

+ BaseURL string

+ Name string

+ Timeout int

+ type MemoryConfig struct

+ Capacity int

+ Type string

+ type ModelConfig struct

+ APIFormat string

+ APIKey string

+ BaseURL string

+ ModelID string

+ Timeout int

+ Vendor string

+ func (c ModelConfig) BuildModel() (model.Model, error)

+ type Node = orchestrator.Node

+ type NodeType = orchestrator.NodeType

+ type ParallelNode = orchestrator.ParallelNode

+ func NewParallelNode(id string, nodes ...Node) *ParallelNode

+ type Permission = security.Permission

+ type RunOption = engine.RunOption

+ func WithMaxLoops(n int) RunOption

+ func WithMaxTokens(n int) RunOption

+ func WithStream(fn func(string)) RunOption

+ func WithTemperature(value float64) RunOption

+ type RunOutput = engine.RunOutput

+ type SecurityConfig struct

+ EnableInjectionCheck bool

+ MaxInputLength int

+ MaxOutputLength int

+ SanitizePII bool

+ type StepLog = orchestrator.StepLog

+ type StepNode = orchestrator.StepNode

+ func NewStepNode(id string, runtimeAgent *Agent, ...) *StepNode

+ type Team = orchestrator.Team

+ func NewTeam(cfg TeamConfig) *Team

+ type TeamConfig = orchestrator.TeamConfig

+ type TeamMode = orchestrator.TeamMode

+ type TeamOutput = orchestrator.TeamOutput

+ type Workflow = orchestrator.Workflow

+ func NewWorkflow(cfg WorkflowConfig) *Workflow

+ type WorkflowConfig = orchestrator.WorkflowConfig

+ type WorkflowResult = orchestrator.WorkflowResult

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL