Documentation
¶
Overview ¶
Package controller implements the single-writer orchestrator that coordinates agentic loops, manages executions, and communicates with local and remote agents.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Registry *Registry
EventLogBuilder eventlog.EventLogBuilder
}
Config configures the controller.
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is the main controller that coordinates all components. It acts as a single-writer system for managing agentic loops.
func New ¶
func New(ctx context.Context, cfg Config) (*Controller, error)
New creates a new controller instance.
func (*Controller) Close ¶
func (d *Controller) Close() error
Close gracefully shuts down the controller.
func (*Controller) Delete ¶
func (d *Controller) Delete(ctx context.Context, conversationID string) error
Delete deletes all events for a specific conversation ID.
func (*Controller) Exec ¶
func (d *Controller) Exec(ctx context.Context, req *proto.ExecRequest, handler ExecHandler) error
Exec executes a new agentic loop execution or resumes an existing one. If id is empty, a UUID will be generated. If the execution already exists, it will be resumed with optional new inputs.
func (*Controller) Registry ¶
func (d *Controller) Registry() *Registry
Registry returns the agent registry.
type ExecHandler ¶
type ExecHandler func(resp *proto.ExecResponse) error
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry manages a collection of harnesses.
func (*Registry) RegisterHarness ¶ added in v0.2.0
RegisterHarness registers a harness under the given id.
func (*Registry) SetDefaultHarness ¶ added in v0.2.0
SetDefaultHarness marks a registered harness id as the default.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package eventlog contains an AX event log.
|
Package eventlog contains an AX event log. |