Versions in this module Expand all Collapse all v0 v0.1.1 Feb 11, 2026 v0.1.0 Feb 11, 2026 v0.0.1 Feb 11, 2026 Changes in this version + type Agent struct + CreatedAt time.Time + ID string + LastSeenAt *time.Time + Metadata json.RawMessage + Name string + Type string + type AuditEntry struct + Action string + AgentID string + Details json.RawMessage + ID int64 + ResourceID string + ResourceType string + Timestamp time.Time + type DecisionFilter struct + AgentID string + Limit int + Status string + TargetAgentID string + WorkflowID string + type Event struct + AgentID string + ID int64 + Payload json.RawMessage + Sequence int64 + StepID string + Timestamp time.Time + Type string + WorkflowID string + type EventFilter struct + EventType string + Limit int + Since *time.Time + StepID string + WorkflowID string + type EventLog struct + func NewEventLog(s *LibSQLStore) *EventLog + func (el *EventLog) AppendEvent(ctx context.Context, event *Event) error + func (el *EventLog) GetEvents(ctx context.Context, workflowID string, since int64) ([]*Event, error) + func (el *EventLog) GetEventsByType(ctx context.Context, eventType string, filter EventFilter) ([]*Event, error) + func (el *EventLog) ReplayEvents(ctx context.Context, workflowID string) (map[string]*StepState, error) + type LibSQLStore struct + func NewLibSQLStore(dbPath string) (*LibSQLStore, error) + func (s *LibSQLStore) AppendEvent(ctx context.Context, event *Event) error + func (s *LibSQLStore) CancelDecision(ctx context.Context, id string) error + func (s *LibSQLStore) Close() error + func (s *LibSQLStore) CreateDecision(ctx context.Context, dec *PendingDecision) error + func (s *LibSQLStore) CreatePlugin(ctx context.Context, plugin *Plugin) error + func (s *LibSQLStore) CreateScheduledJob(ctx context.Context, job *ScheduledJob) error + func (s *LibSQLStore) CreateWorkflow(ctx context.Context, wf *Workflow) error + func (s *LibSQLStore) DB() *sql.DB + func (s *LibSQLStore) DeleteScheduledJob(ctx context.Context, id string) error + func (s *LibSQLStore) DeleteSecret(ctx context.Context, key string) error + func (s *LibSQLStore) DeleteWorkflow(ctx context.Context, id string) error + func (s *LibSQLStore) GetAgent(ctx context.Context, id string) (*Agent, error) + func (s *LibSQLStore) GetEvents(ctx context.Context, workflowID string, since int64) ([]*Event, error) + func (s *LibSQLStore) GetEventsByType(ctx context.Context, eventType string, filter EventFilter) ([]*Event, error) + func (s *LibSQLStore) GetPlugin(ctx context.Context, id string) (*Plugin, error) + func (s *LibSQLStore) GetScheduledJob(ctx context.Context, id string) (*ScheduledJob, error) + func (s *LibSQLStore) GetSecret(ctx context.Context, key string) ([]byte, error) + func (s *LibSQLStore) GetStepState(ctx context.Context, workflowID, stepID string) (*StepState, error) + func (s *LibSQLStore) GetTemplate(ctx context.Context, name string, version string) (*WorkflowTemplate, error) + func (s *LibSQLStore) GetWorkflow(ctx context.Context, id string) (*Workflow, error) + func (s *LibSQLStore) GetWorkflowContext(ctx context.Context, workflowID string) (*WorkflowContext, error) + func (s *LibSQLStore) ListAgents(ctx context.Context) ([]*Agent, error) + func (s *LibSQLStore) ListPendingDecisions(ctx context.Context, filter DecisionFilter) ([]*PendingDecision, error) + func (s *LibSQLStore) ListPlugins(ctx context.Context) ([]*Plugin, error) + func (s *LibSQLStore) ListScheduledJobs(ctx context.Context, filter ScheduledJobFilter) ([]*ScheduledJob, error) + func (s *LibSQLStore) ListSecrets(ctx context.Context) ([]string, error) + func (s *LibSQLStore) ListStepStates(ctx context.Context, workflowID string) ([]*StepState, error) + func (s *LibSQLStore) ListTemplates(ctx context.Context, filter TemplateFilter) ([]*WorkflowTemplate, error) + func (s *LibSQLStore) ListWorkflows(ctx context.Context, filter WorkflowFilter) ([]*Workflow, error) + func (s *LibSQLStore) Migrate(ctx context.Context) error + func (s *LibSQLStore) RegisterAgent(ctx context.Context, agent *Agent) error + func (s *LibSQLStore) ResolveDecision(ctx context.Context, id string, resolution *Resolution) error + func (s *LibSQLStore) StoreSecret(ctx context.Context, key string, value []byte) error + func (s *LibSQLStore) StoreTemplate(ctx context.Context, tpl *WorkflowTemplate) error + func (s *LibSQLStore) UpdateAgentSeen(ctx context.Context, id string) error + func (s *LibSQLStore) UpdatePlugin(ctx context.Context, id string, status string, errMsg string) error + func (s *LibSQLStore) UpdateScheduledJob(ctx context.Context, id string, update ScheduledJobUpdate) error + func (s *LibSQLStore) UpdateWorkflow(ctx context.Context, id string, update WorkflowUpdate) error + func (s *LibSQLStore) UpsertStepState(ctx context.Context, state *StepState) error + func (s *LibSQLStore) UpsertWorkflowContext(ctx context.Context, wfCtx *WorkflowContext) error + func (s *LibSQLStore) Vacuum(ctx context.Context) error + type PendingDecision struct + AgentID string + Context json.RawMessage + CreatedAt time.Time + Fallback string + ID string + Options json.RawMessage + Resolution json.RawMessage + ResolvedAt *time.Time + ResolvedBy string + Status string + StepID string + TargetAgentID string + TimeoutAt *time.Time + WorkflowID string + type Plugin struct + Config json.RawMessage + CreatedAt time.Time + ErrorMessage string + ID string + LastHealthCheck *time.Time + Name string + Status string + Type string + type Resolution struct + Choice string + Data map[string]any + Reasoning string + ResolvedBy string + type ScheduledJob struct + AgentID string + CreatedAt time.Time + CronExpression string + Enabled bool + ID string + LastRunAt *time.Time + LastRunStatus string + NextRunAt *time.Time + Params json.RawMessage + TemplateName string + TemplateVersion string + type ScheduledJobFilter struct + AgentID string + Enabled *bool + Limit int + type ScheduledJobUpdate struct + Enabled *bool + LastRunAt *time.Time + LastRunStatus string + NextRunAt *time.Time + type Secret struct + CreatedAt time.Time + Key string + Value []byte + type SnapshotPayload struct + Error json.RawMessage + Output json.RawMessage + type StepState struct + CompletedAt *time.Time + DurationMs int64 + Error json.RawMessage + Input json.RawMessage + Output json.RawMessage + RetryCount int + StartedAt *time.Time + Status schema.StepStatus + StepID string + WorkflowID string + type Store interface + AppendEvent func(ctx context.Context, event *Event) error + CancelDecision func(ctx context.Context, id string) error + Close func() error + CreateDecision func(ctx context.Context, dec *PendingDecision) error + CreatePlugin func(ctx context.Context, plugin *Plugin) error + CreateScheduledJob func(ctx context.Context, job *ScheduledJob) error + CreateWorkflow func(ctx context.Context, wf *Workflow) error + DeleteScheduledJob func(ctx context.Context, id string) error + DeleteSecret func(ctx context.Context, key string) error + DeleteWorkflow func(ctx context.Context, id string) error + GetAgent func(ctx context.Context, id string) (*Agent, error) + GetEvents func(ctx context.Context, workflowID string, since int64) ([]*Event, error) + GetEventsByType func(ctx context.Context, eventType string, filter EventFilter) ([]*Event, error) + GetPlugin func(ctx context.Context, id string) (*Plugin, error) + GetScheduledJob func(ctx context.Context, id string) (*ScheduledJob, error) + GetSecret func(ctx context.Context, key string) ([]byte, error) + GetStepState func(ctx context.Context, workflowID, stepID string) (*StepState, error) + GetTemplate func(ctx context.Context, name string, version string) (*WorkflowTemplate, error) + GetWorkflow func(ctx context.Context, id string) (*Workflow, error) + GetWorkflowContext func(ctx context.Context, workflowID string) (*WorkflowContext, error) + ListAgents func(ctx context.Context) ([]*Agent, error) + ListPendingDecisions func(ctx context.Context, filter DecisionFilter) ([]*PendingDecision, error) + ListPlugins func(ctx context.Context) ([]*Plugin, error) + ListScheduledJobs func(ctx context.Context, filter ScheduledJobFilter) ([]*ScheduledJob, error) + ListSecrets func(ctx context.Context) ([]string, error) + ListStepStates func(ctx context.Context, workflowID string) ([]*StepState, error) + ListTemplates func(ctx context.Context, filter TemplateFilter) ([]*WorkflowTemplate, error) + ListWorkflows func(ctx context.Context, filter WorkflowFilter) ([]*Workflow, error) + Migrate func(ctx context.Context) error + RegisterAgent func(ctx context.Context, agent *Agent) error + ResolveDecision func(ctx context.Context, id string, resolution *Resolution) error + StoreSecret func(ctx context.Context, key string, value []byte) error + StoreTemplate func(ctx context.Context, tpl *WorkflowTemplate) error + UpdateAgentSeen func(ctx context.Context, id string) error + UpdatePlugin func(ctx context.Context, id string, status string, errMsg string) error + UpdateScheduledJob func(ctx context.Context, id string, update ScheduledJobUpdate) error + UpdateWorkflow func(ctx context.Context, id string, update WorkflowUpdate) error + UpsertStepState func(ctx context.Context, state *StepState) error + UpsertWorkflowContext func(ctx context.Context, wfCtx *WorkflowContext) error + Vacuum func(ctx context.Context) error + type TemplateFilter struct + AgentID string + Limit int + Name string + type Workflow struct + AgentID string + CompletedAt *time.Time + CreatedAt time.Time + Definition schema.WorkflowDefinition + Error json.RawMessage + ID string + InputParams map[string]any + Name string + Output json.RawMessage + ParentID string + StartedAt *time.Time + Status schema.WorkflowStatus + TemplateName string + TemplateVersion string + UpdatedAt time.Time + type WorkflowContext struct + AccumulatedData json.RawMessage + AgentID string + AgentNotes string + CreatedAt time.Time + DecisionsLog json.RawMessage + OriginalIntent string + UpdatedAt time.Time + WorkflowID string + type WorkflowFilter struct + AgentID string + Limit int + Offset int + Since *time.Time + Status *schema.WorkflowStatus + type WorkflowTemplate struct + AgentID string + CreatedAt time.Time + Definition schema.WorkflowDefinition + Description string + InputSchema json.RawMessage + Name string + OutputSchema json.RawMessage + Permissions json.RawMessage + Triggers json.RawMessage + UpdatedAt time.Time + Version string + type WorkflowUpdate struct + CompletedAt *time.Time + Error json.RawMessage + Output json.RawMessage + StartedAt *time.Time + Status *schema.WorkflowStatus
Go to main page