Versions in this module Expand all Collapse all v0 v0.3.0 Jun 11, 2026 Changes in this version + type Agent struct + Capabilities []string + Config map[string]string + ID string + Role AgentRole + Status AgentStatus + type AgentFinderAdapter struct + func NewAgentFinderAdapter(agentSystem *AgentSystem) *AgentFinderAdapter + func (f *AgentFinderAdapter) FindAgentsByRole(ctx context.Context, role string) ([]string, error) + type AgentRole string + type AgentStatus string + const StatusAvailable + const StatusBusy + const StatusOffline + type AgentSystem struct + func NewAgentSystem(ctx context.Context) (*AgentSystem, error) + func (s *AgentSystem) Engine() *engine.PolicyEngine + func (s *AgentSystem) EvaluateCondition(ctx context.Context, condition string, contextData map[string]string) (bool, error) + func (s *AgentSystem) FindAgentsForTask(ctx context.Context, task string) ([]*Agent, error) + func (s *AgentSystem) GetAgent(ctx context.Context, agentID string) (*Agent, error) + func (s *AgentSystem) GetAgentRoles(ctx context.Context) ([]string, error) + func (s *AgentSystem) GetAgentsByRole(ctx context.Context, role string) ([]*Agent, error) + func (s *AgentSystem) GetRoleCapabilities(ctx context.Context, role string) ([]string, error) + func (s *AgentSystem) GetWorkflow(ctx context.Context, workflowName string) (*Workflow, error) + func (s *AgentSystem) GetWorkflowEdges(ctx context.Context, workflowName, nodeID string) ([]WorkflowEdge, error) + func (s *AgentSystem) GetWorkflows(ctx context.Context) ([]*Workflow, error) + func (s *AgentSystem) LoadAgentDefinitions(ctx context.Context) error + func (s *AgentSystem) Query(ctx context.Context, facts []string, query string) ([]map[string]string, error) + func (s *AgentSystem) QueryWithAudit(ctx context.Context, facts []string, query string) ([]map[string]string, *core.AuditTrail, error) + func (s *AgentSystem) SetAgentStatus(ctx context.Context, agentID string, status AgentStatus) error + type ConditionEvaluatorAdapter struct + func NewConditionEvaluatorAdapter(agentSystem *AgentSystem) *ConditionEvaluatorAdapter + func (e *ConditionEvaluatorAdapter) EvaluateCondition(ctx context.Context, condition string, facts map[string]interface{}) (bool, error) + type DatalogWorkflowLoader struct + func NewDatalogWorkflowLoader(agentSystem *AgentSystem) *DatalogWorkflowLoader + func (l *DatalogWorkflowLoader) LoadWorkflow(ctx context.Context, workflowID string) (*core.WorkflowDef, error) + type DefaultNodeExecutor struct + func (e *DefaultNodeExecutor) Execute(ctx context.Context, node *WorkflowNode, input interface{}, agent *Agent) (interface{}, error) + type Envelope = core.Envelope + type HydratedWorkflowExecutor struct + func NewHydratedWorkflowExecutor(workflowDef *core.WorkflowDef) *HydratedWorkflowExecutor + func (e *HydratedWorkflowExecutor) Execute(ctx context.Context, initialInput interface{}) (*core.WorkflowResult, error) + func (e *HydratedWorkflowExecutor) ExecuteWithSession(ctx context.Context, initialInput interface{}) (*core.WorkflowResult, *core.WorkflowInstance, error) + func (e *HydratedWorkflowExecutor) WithAgentFinder(finder ports.AgentFinder) *HydratedWorkflowExecutor + func (e *HydratedWorkflowExecutor) WithConditionEvaluator(eval ports.ConditionEvaluator) *HydratedWorkflowExecutor + func (e *HydratedWorkflowExecutor) WithMaxRetries(retries int) *HydratedWorkflowExecutor + func (e *HydratedWorkflowExecutor) WithNodeExecutor(exec NodeExecutor) *HydratedWorkflowExecutor + func (e *HydratedWorkflowExecutor) WithSessionStore(store ports.SessionStateStore, sessionID string) *HydratedWorkflowExecutor + func (e *HydratedWorkflowExecutor) WithTimeout(timeout time.Duration) *HydratedWorkflowExecutor + type NodeExecutor interface + Execute func(ctx context.Context, node *WorkflowNode, input interface{}, agent *Agent) (interface{}, error) + type NodeResult struct + AgentID string + EndTime time.Duration + Error error + Input interface{} + NodeID string + Output interface{} + RetryCount int + StartTime time.Time + type ParallelWorkflowExecutor struct + func NewParallelWorkflowExecutor(agentSystem *AgentSystem) *ParallelWorkflowExecutor + func (e *ParallelWorkflowExecutor) ExecuteParallel(ctx context.Context, workflow *Workflow, initialInput interface{}) (*WorkflowResult, error) + func (e *ParallelWorkflowExecutor) WithBarrierSync(barrier bool) *ParallelWorkflowExecutor + func (e *ParallelWorkflowExecutor) WithMaxParallel(max int) *ParallelWorkflowExecutor + type Workflow struct + Edges []WorkflowEdge + ID string + Name string + Nodes []WorkflowNode + Version string + type WorkflowContext map[string]interface + type WorkflowEdge struct + Condition string + From string + To string + type WorkflowExecutor struct + func NewWorkflowExecutor(agentSystem *AgentSystem) *WorkflowExecutor + func (e *WorkflowExecutor) Execute(ctx context.Context, workflowName string, initialInput interface{}) (*WorkflowResult, error) + func (e *WorkflowExecutor) ExecuteWorkflow(ctx context.Context, workflow *Workflow, initialInput interface{}) (*WorkflowResult, error) + func (e *WorkflowExecutor) WithLogger(logger core.Logger) *WorkflowExecutor + func (e *WorkflowExecutor) WithMaxRetries(retries int) *WorkflowExecutor + func (e *WorkflowExecutor) WithNodeExecutor(exec NodeExecutor) *WorkflowExecutor + func (e *WorkflowExecutor) WithTimeout(timeout time.Duration) *WorkflowExecutor + type WorkflowNode struct + Agent string + Config map[string]string + ID string + Type string + type WorkflowResult struct + EndTime time.Time + Error error + NodeResults map[string]*NodeResult + Output interface{} + StartTime time.Time + Status WorkflowStatus + WorkflowID string + type WorkflowStatus string + const WorkflowStatusCancelled + const WorkflowStatusCompleted + const WorkflowStatusFailed + const WorkflowStatusPending + const WorkflowStatusRunning
Go to main page