aixgo

Feb 8, 2026

Changes in this version

+ var ErrAgentAlreadyRegistered = errors.New("agent already registered")

+ var ErrAgentNotFound = errors.New("agent not found")

+ var ErrAgentNotReady = errors.New("agent not ready")

+ var ErrRuntimeAlreadyStarted = errors.New("runtime already started")

+ var ErrRuntimeNotStarted = errors.New("runtime not started")

+ var ErrSessionManagerNotConfigured = errors.New("session manager not configured")

+ type CheckpointConfig struct

+ AutoSave bool

+ Interval string

type Config

+ Session SessionConfig

+ type Runtime struct

+ func NewRuntime(opts ...RuntimeOption) *Runtime

+ func (r *Runtime) Broadcast(msg *agent.Message) error

+ func (r *Runtime) Call(ctx context.Context, target string, input *agent.Message) (*agent.Message, error)

+ func (r *Runtime) CallParallel(ctx context.Context, targets []string, input *agent.Message) (map[string]*agent.Message, map[string]error)

+ func (r *Runtime) CallWithSession(ctx context.Context, target string, input *pubagent.Message, sessionID string) (*pubagent.Message, error)

+ func (r *Runtime) Config() RuntimeConfig

+ func (r *Runtime) Get(name string) (agent.Agent, error)

+ func (r *Runtime) GetChannelStats(name string) (capacity, length int, err error)

+ func (r *Runtime) List() []string

+ func (r *Runtime) MessagesSent() uint64

+ func (r *Runtime) Recv(source string) (<-chan *agent.Message, error)

+ func (r *Runtime) Register(a agent.Agent) error

+ func (r *Runtime) Send(target string, msg *agent.Message) error

+ func (r *Runtime) SessionManager() session.Manager

+ func (r *Runtime) SetSessionManager(sm session.Manager)

+ func (r *Runtime) Start(ctx context.Context) error

+ func (r *Runtime) StartAgentsPhased(ctx context.Context, agentDefs map[string]agent.AgentDef) error

+ func (r *Runtime) Stop(ctx context.Context) error

+ func (r *Runtime) Unregister(name string) error

+ type RuntimeConfig struct

+ AgentStartTimeout time.Duration

+ ChannelBufferSize int

+ ChannelFullWarningThreshold int

+ EnableMetrics bool

+ EnableTracing bool

+ MaxConcurrentCalls int

+ SendTimeout time.Duration

+ func DefaultRuntimeConfig() *RuntimeConfig

+ type RuntimeOption func(*RuntimeConfig)

+ func WithAgentStartTimeout(timeout time.Duration) RuntimeOption

+ func WithChannelBufferSize(size int) RuntimeOption

+ func WithMaxConcurrentCalls(max int) RuntimeOption

+ func WithMetrics(enabled bool) RuntimeOption

+ func WithSendTimeout(timeout time.Duration) RuntimeOption

+ func WithTracing(enabled bool) RuntimeOption

+ type SessionConfig struct

+ BaseDir string

+ Checkpoint CheckpointConfig

+ Enabled bool

+ Store string

Jan 2, 2026

Changes in this version

+ type PhasedStarter interface

+ StartAgentsPhased func(ctx context.Context, agentDefs map[string]agent.AgentDef) error

type SimpleRuntime

+ func (r *SimpleRuntime) StartAgentsPhased(ctx context.Context, agentDefs map[string]agent.AgentDef) error

Dec 6, 2025

Changes in this version

+ func Run(configPath string) error

+ func RunWithConfig(config *Config) error

+ func RunWithConfigAndRuntime(config *Config, rt agent.Runtime) error

+ func RunWithMCP(configPath string, servers ...*mcp.Server) error

+ func StartAgents(agents map[string]agent.Agent, rt agent.Runtime) error

+ type Config struct

+ Agents []agent.AgentDef

+ MCPServers []MCPServerDef

+ ModelServices []ModelServiceDef

+ Supervisor SupervisorDef

+ type ConfigLoader struct

+ func NewConfigLoader(fr FileReader) *ConfigLoader

+ func NewConfigLoaderWithLimits(fr FileReader, limits security.YAMLLimits) *ConfigLoader

+ func (cl *ConfigLoader) LoadConfig(configPath string) (*Config, error)

+ type FileReader interface

+ ReadFile func(path string) ([]byte, error)

+ type MCPAuthDef struct

+ Token string

+ TokenEnv string

+ Type string

+ type MCPServerDef struct

+ Address string

+ Auth *MCPAuthDef

+ Name string

+ TLS bool

+ Transport string

+ type MockFileReader struct

+ func NewMockFileReader() *MockFileReader

+ func (m *MockFileReader) AddFile(path string, content []byte)

+ func (m *MockFileReader) ReadFile(path string) ([]byte, error)

+ func (m *MockFileReader) Reset()

+ func (m *MockFileReader) SetError(err error)

+ type ModelServiceDef struct

+ Address string

+ Config map[string]any

+ Model string

+ Name string

+ Provider string

+ Runtime string

+ Transport string

+ type OSFileReader struct

+ func (r *OSFileReader) ReadFile(path string) ([]byte, error)

+ type SimpleRuntime struct

+ func NewSimpleRuntime() *SimpleRuntime

+ func (r *SimpleRuntime) Broadcast(msg *agent.Message) error

+ func (r *SimpleRuntime) Call(ctx context.Context, target string, input *agent.Message) (*agent.Message, error)

+ func (r *SimpleRuntime) CallParallel(ctx context.Context, targets []string, input *agent.Message) (map[string]*agent.Message, map[string]error)

+ func (r *SimpleRuntime) Get(name string) (agent.Agent, error)

+ func (r *SimpleRuntime) List() []string

+ func (r *SimpleRuntime) Recv(source string) (<-chan *agent.Message, error)

+ func (r *SimpleRuntime) Register(a agent.Agent) error

+ func (r *SimpleRuntime) Send(target string, msg *agent.Message) error

+ func (r *SimpleRuntime) Start(ctx context.Context) error

+ func (r *SimpleRuntime) Stop(ctx context.Context) error

+ func (r *SimpleRuntime) Unregister(name string) error

+ type SupervisorDef struct

+ MaxRounds int

+ Model string

+ Name string