orchestrator

package

Go to main page

Versions in this module

v0

v0.12.2

Jul 5, 2026

v0.12.1

Jul 4, 2026

v0.12.0

Jun 30, 2026

v0.11.0

Jun 30, 2026

Changes in this version

+ var ErrServiceUnavailable = errors.New("orchestrator: required service not available")

+ func IsNull(svc any) bool

+ type ApprovalService interface

+ Approve func(ctx context.Context, id, comment string) error

+ CreateApproval func(ctx context.Context, agentID, taskID, action, reason, details string) (string, error)

+ Get func(ctx context.Context, id string) (*Approval, error)

+ Reject func(ctx context.Context, id, comment string) error

+ WaitForResolution func(ctx context.Context, id string, timeout time.Duration) (*Approval, error)

+ type BlackboardService interface

+ Post func(ctx context.Context, artifact Artifact) error

+ Read func(ctx context.Context, phase, artifactType string) ([]Artifact, error)

+ ReadLatest func(ctx context.Context, phase string) (*Artifact, error)

+ type ContainerService interface

+ EnsureContainer func(ctx context.Context, projectID, workspacePath string, spec sandboxSpec) (string, error)

+ ExecInContainer func(ctx context.Context, projectID, command, workDir string, timeout int) (stdout, stderr string, exitCode int, err error)

+ GetContainerStatus func(ctx context.Context, projectID string) (string, error)

+ IsAvailable func() bool

+ RemoveContainer func(ctx context.Context, projectID string) error

+ StopContainer func(ctx context.Context, projectID string) error

+ type HumanRequestService interface

+ Cancel func(ctx context.Context, id, comment string) error

+ CreateRequest func(ctx context.Context, ...) (string, error)

+ Get func(ctx context.Context, id string) (*HumanRequest, error)

+ Resolve func(ctx context.Context, id, responseData, comment, resolvedBy string) error

+ WaitForResolution func(ctx context.Context, id string, timeout time.Duration) (*HumanRequest, error)

+ type MemoryStoreService interface

+ ExtractAndSave func(ctx context.Context, agentID, transcript string, embedder provider.Embedder) error

+ Save func(ctx context.Context, entry MemoryEntry) error

+ Search func(ctx context.Context, agentID, query string, limit int) ([]MemoryEntry, error)

+ type NullApproval struct

+ func (NullApproval) Approve(_ context.Context, _, _ string) error

+ func (NullApproval) CreateApproval(_ context.Context, _, _, _, _, _ string) (string, error)

+ func (NullApproval) Get(_ context.Context, _ string) (*Approval, error)

+ func (NullApproval) Reject(_ context.Context, _, _ string) error

+ func (NullApproval) WaitForResolution(_ context.Context, _ string, _ time.Duration) (*Approval, error)

+ type NullBlackboard struct

+ func (NullBlackboard) Post(_ context.Context, _ Artifact) error

+ func (NullBlackboard) Read(_ context.Context, _, _ string) ([]Artifact, error)

+ func (NullBlackboard) ReadLatest(_ context.Context, _ string) (*Artifact, error)

+ type NullContainer struct

+ func (NullContainer) EnsureContainer(_ context.Context, _, _ string, _ sandboxSpec) (string, error)

+ func (NullContainer) ExecInContainer(_ context.Context, _, _, _ string, _ int) (string, string, int, error)

+ func (NullContainer) GetContainerStatus(_ context.Context, _ string) (string, error)

+ func (NullContainer) IsAvailable() bool

+ func (NullContainer) RemoveContainer(_ context.Context, _ string) error

+ func (NullContainer) StopContainer(_ context.Context, _ string) error

+ type NullHumanRequest struct

+ func (NullHumanRequest) Cancel(_ context.Context, _, _ string) error

+ func (NullHumanRequest) CreateRequest(_ context.Context, _, _, _, _, _, _, _, _ string) (string, error)

+ func (NullHumanRequest) Get(_ context.Context, _ string) (*HumanRequest, error)

+ func (NullHumanRequest) Resolve(_ context.Context, _, _, _, _ string) error

+ func (NullHumanRequest) WaitForResolution(_ context.Context, _ string, _ time.Duration) (*HumanRequest, error)

+ type NullMemoryStore struct

+ func (NullMemoryStore) ExtractAndSave(_ context.Context, _, _ string, _ provider.Embedder) error

+ func (NullMemoryStore) Save(_ context.Context, _ MemoryEntry) error

+ func (NullMemoryStore) Search(_ context.Context, _, _ string, _ int) ([]MemoryEntry, error)

+ type NullSecretGuard struct

+ func (NullSecretGuard) AddKnownSecret(_, _ string)

+ func (NullSecretGuard) CheckAndRedact(_ *provider.Message) bool

+ func (NullSecretGuard) LoadAllSecrets(_ context.Context) error

+ func (NullSecretGuard) LoadSecrets(_ context.Context, _ []string) error

+ func (NullSecretGuard) Provider() secrets.Provider

+ func (NullSecretGuard) Redact(text string) string

+ type NullSkill struct

+ func (NullSkill) BuildSkillPrompt(_ context.Context, _ string) (string, error)

+ func (NullSkill) GetAgentSkills(_ context.Context, _ string) ([]Skill, error)

+ func (NullSkill) GetSkill(_ context.Context, _ string) (*Skill, error)

+ func (NullSkill) ListSkills(_ context.Context) ([]Skill, error)

+ type NullSubAgent struct

+ func (NullSubAgent) CancelChildren(_ context.Context, _ string) error

+ func (NullSubAgent) CheckTask(_ context.Context, _ string) (string, string, error)

+ func (NullSubAgent) CountActive(_ context.Context, _ string) (int, error)

+ func (NullSubAgent) Spawn(_ context.Context, _, _, _, _ string) (string, error)

+ func (NullSubAgent) WaitTasks(_ context.Context, _ []string, _ time.Duration) (map[string]tools.SubTaskResult, error)

+ type NullToolRegistry struct

+ func (NullToolRegistry) AllDefs() []provider.ToolDef

+ func (NullToolRegistry) Execute(_ context.Context, _ string, _ map[string]any) (any, error)

+ func (NullToolRegistry) Get(_ string) (any, bool)

+ func (NullToolRegistry) Names() []string

+ func (NullToolRegistry) SetPaginator(_ *ResponsePaginator)

+ type NullTranscript struct

+ func (NullTranscript) Record(_ context.Context, _ TranscriptEntry) error

+ type NullWebhook struct

+ func (NullWebhook) ExtractEventType(_ string, _ map[string]string, _ map[string]any) string

+ func (NullWebhook) GetBySource(_ context.Context, _ string) ([]Webhook, error)

+ func (NullWebhook) MatchesFilter(_, _, _ string) bool

+ func (NullWebhook) RenderTaskTemplate(_ string, _ map[string]any) (string, string, error)

+ func (NullWebhook) VerifySignature(_, _ string, _ []byte, _, _ string) bool

type SecretGuard

+ func (sg *SecretGuard) AttachLazyVault(app modular.Application, vaultModuleKey string)

+ type SecretGuardService interface

+ AddKnownSecret func(name, value string)

+ CheckAndRedact func(msg *provider.Message) bool

+ LoadAllSecrets func(ctx context.Context) error

+ LoadSecrets func(ctx context.Context, names []string) error

+ Provider func() secrets.Provider

+ Redact func(text string) string

+ type SkillService interface

+ BuildSkillPrompt func(ctx context.Context, agentID string) (string, error)

+ GetAgentSkills func(ctx context.Context, agentID string) ([]Skill, error)

+ GetSkill func(ctx context.Context, id string) (*Skill, error)

+ ListSkills func(ctx context.Context) ([]Skill, error)

+ type SubAgentService interface

+ CancelChildren func(ctx context.Context, parentAgentID string) error

+ CheckTask func(ctx context.Context, taskID string) (status, result string, err error)

+ CountActive func(ctx context.Context, parentAgentID string) (int, error)

+ Spawn func(ctx context.Context, parentAgentID, name, taskDesc, systemPrompt string) (string, error)

+ WaitTasks func(ctx context.Context, taskIDs []string, timeout time.Duration) (map[string]tools.SubTaskResult, error)

+ type ToolRegistryService interface

+ AllDefs func() []provider.ToolDef

+ Execute func(ctx context.Context, name string, args map[string]any) (any, error)

+ Get func(name string) (any, bool)

+ Names func() []string

+ SetPaginator func(rp *ResponsePaginator)

+ type TranscriptService interface

+ Record func(ctx context.Context, entry TranscriptEntry) error

+ type UnionAdapter struct

+ func NewUnionAdapter() *UnionAdapter

+ func (u *UnionAdapter) CreateModule(typeName, name string, config map[string]any) (sdk.ModuleInstance, error)

+ func (u *UnionAdapter) CreateStep(typeName, name string, config map[string]any) (sdk.StepInstance, error)

+ func (u *UnionAdapter) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error)

+ func (u *UnionAdapter) CreateTypedStep(typeName, name string, config *anypb.Any) (sdk.StepInstance, error)

+ func (u *UnionAdapter) Manifest() sdk.PluginManifest

+ func (u *UnionAdapter) ModuleTypes() []string

+ func (u *UnionAdapter) StepTypes() []string

+ func (u *UnionAdapter) TypedModuleTypes() []string

+ func (u *UnionAdapter) TypedStepTypes() []string

+ type WebhookService interface

+ ExtractEventType func(source string, headers map[string]string, payload map[string]any) string

+ GetBySource func(ctx context.Context, source string) ([]Webhook, error)

+ MatchesFilter func(source, eventType, filter string) bool

+ RenderTaskTemplate func(tmpl string, payload map[string]any) (title, description string, err error)

+ VerifySignature func(source, secret string, payload []byte, signature, timestamp string) bool

v0.10.0

Jun 29, 2026

v0.9.6

May 24, 2026

v0.9.5

May 24, 2026

v0.9.4

May 24, 2026

v0.9.3

May 16, 2026

v0.9.2

May 2, 2026

v0.9.1

Apr 13, 2026

Changes in this version

+ type ResponsePaginator struct

+ func NewResponsePaginator(contextWindow int) *ResponsePaginator

+ func (rp *ResponsePaginator) Paginate(toolName string, args map[string]any, result string) string

type ToolRegistry

+ func (tr *ToolRegistry) SetPaginator(rp *ResponsePaginator)

v0.9.0

Apr 13, 2026

v0.8.9

Apr 13, 2026

Changes in this version

type ContextManager

+ func (cm *ContextManager) SetModelLimitFromProvider(limit int)

type GuardrailsModule

+ func (g *GuardrailsModule) FilterTools(tools []provider.ToolDef) []provider.ToolDef

v0.8.8

Apr 13, 2026

v0.8.7

Apr 13, 2026

v0.8.6

Apr 13, 2026

v0.8.5

Apr 13, 2026

v0.8.4

Apr 13, 2026

Changes in this version

type MCPProvider

+ ListToolSchemas func() []wfmcp.ToolSchema

v0.8.3

Apr 13, 2026

Changes in this version

+ type MCPProvider interface

+ CallTool func(ctx context.Context, toolName string, args map[string]any) (any, error)

+ ListTools func() []string

v0.8.2

Apr 13, 2026

Changes in this version

+ func InjectBlackboardInput(ctx context.Context, app modular.Application, cfg InputFromBlackboard, ...) (string, error)

+ type Artifact struct

+ AgentID string

+ Content map[string]any

+ CreatedAt time.Time

+ ID string

+ Phase string

+ Tags []string

+ Type string

+ type Blackboard struct

+ func NewBlackboard(db *sql.DB, sseHub *SSEHub) *Blackboard

+ func (b *Blackboard) Migrate(ctx context.Context) error

+ func (b *Blackboard) Post(ctx context.Context, artifact Artifact) error

+ func (b *Blackboard) Read(ctx context.Context, phase, artifactType string) ([]Artifact, error)

+ func (b *Blackboard) ReadLatest(ctx context.Context, phase string) (*Artifact, error)

+ func (b *Blackboard) Subscribe(ctx context.Context, phase string) <-chan Artifact

+ type BlackboardPostStep struct

+ func (s *BlackboardPostStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *BlackboardPostStep) Name() string

+ type BlackboardReadStep struct

+ func (s *BlackboardReadStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *BlackboardReadStep) Name() string

+ type DeployStrategy string

+ const DeployStrategyCanary

+ const DeployStrategyGitPR

+ const DeployStrategyHotReload

+ type GuardrailsDefaults struct

+ AllowedTools []string

+ BlockedTools []string

+ CommandPolicy safety.Policy

+ DeployStrategy string

+ EnableIacModification bool

+ EnableSelfImprovement bool

+ MaxIterationsPerCycle int

+ RequireDiffReview bool

+ RequireHumanApproval bool

+ type GuardrailsModule struct

+ func NewGuardrailsModule(name string, defaults GuardrailsDefaults) *GuardrailsModule

+ func (g *GuardrailsModule) CheckCommand(cmd string) (bool, string)

+ func (g *GuardrailsModule) CheckImmutableSection(path string) (protected bool, override string)

+ func (g *GuardrailsModule) CheckTool(toolName string) (bool, string)

+ func (g *GuardrailsModule) CheckToolScoped(toolName string, sc ScopeContext) (bool, string)

+ func (g *GuardrailsModule) Defaults() GuardrailsDefaults

+ func (g *GuardrailsModule) Evaluate(_ context.Context, toolName string, _ map[string]any) executor.Action

+ func (g *GuardrailsModule) EvaluateCommand(cmd string) executor.Action

+ func (g *GuardrailsModule) EvaluatePath(_ string) executor.Action

+ func (g *GuardrailsModule) Init(app modular.Application) error

+ func (g *GuardrailsModule) Name() string

+ func (g *GuardrailsModule) ProvidesServices() []modular.ServiceProvider

+ func (g *GuardrailsModule) RequiresServices() []modular.ServiceDependency

+ type ImmutabilityViolation struct

+ Override string

+ Path string

+ type ImmutableSection struct

+ Override string

+ Path string

+ type InputFromBlackboard struct

+ ArtifactType string

+ InjectAs string

+ LatestOnly bool

+ Phase string

+ type LSPDiagnoseStep struct

+ func (s *LSPDiagnoseStep) Execute(_ context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *LSPDiagnoseStep) Name() string

+ type LSPDiagnostic struct

+ Message string

+ Range string

+ Severity string

+ type LSPProvider interface

+ DiagnoseContent func(yaml string) ([]LSPDiagnostic, error)

+ type OverrideConfig struct

+ AdminSecretEnv string

+ Fallback string

+ Mechanism string

+ type ReviewPipelineConfig struct

+ DesignerProvider string

+ ImplementerProvider string

+ RequireApproval bool

+ ReviewerProvider string

+ SecurityProvider string

+ type ScopeContext struct

+ Agent string

+ Model string

+ Provider string

+ Team string

+ type ScopeMatch struct

+ Agent string

+ Model string

+ Provider string

+ Team string

+ type ScopeOverride struct

+ AllowedTools []string

+ BlockedTools []string

+ CommandPolicy *safety.Policy

+ EnableIacModification *bool

+ MaxIterationsPerCycle *int

+ RequireHumanApproval *bool

+ type ScopeRule struct

+ Match ScopeMatch

+ Override ScopeOverride

+ type SelfImproveDeployStep struct

+ func (s *SelfImproveDeployStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *SelfImproveDeployStep) Name() string

+ type SelfImproveDiffStep struct

+ func (s *SelfImproveDiffStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *SelfImproveDiffStep) Name() string

+ type SelfImproveValidateStep struct

+ func (s *SelfImproveValidateStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *SelfImproveValidateStep) Name() string

v0.8.1

Apr 7, 2026

v0.7.2

Apr 8, 2026

v0.7.1

Apr 8, 2026

v0.7.0

Apr 8, 2026

Changes in this version

+ func NewContainerManagerAdapter(cm *ContainerManager) executor.ContainerExecutor

+ type ContainerManagerAdapter struct

+ func (a *ContainerManagerAdapter) EnsureContainer(ctx context.Context, projectID, workspacePath string, ...) (string, error)

+ func (a *ContainerManagerAdapter) ExecInContainer(ctx context.Context, projectID, command, workDir string, timeout int) (string, string, int, error)

+ func (a *ContainerManagerAdapter) IsAvailable() bool

+ type MountSpec struct

+ ReadOnly bool

+ Source string

+ Target string

type WorkspaceSpec

+ Mounts []MountSpec

v0.6.16

Apr 7, 2026

v0.6.15

Apr 7, 2026

v0.6.14

Apr 7, 2026

v0.6.13

Apr 7, 2026

v0.6.12

Apr 7, 2026

v0.6.11

Apr 7, 2026

v0.6.10

Apr 7, 2026

v0.6.9

Apr 7, 2026

v0.6.8

Apr 7, 2026

v0.6.7

Apr 7, 2026

v0.6.6

Apr 7, 2026

v0.6.5

Apr 7, 2026

v0.6.4

Apr 7, 2026

v0.6.3

Apr 7, 2026

v0.6.2

Apr 7, 2026

v0.6.1

Apr 7, 2026

v0.6.0

Apr 5, 2026

v0.5.9

Apr 5, 2026

v0.5.8

Mar 30, 2026

v0.5.7

Mar 30, 2026

v0.5.6

Mar 30, 2026

v0.5.5

Mar 30, 2026

v0.5.4

Mar 28, 2026

Changes in this version

+ func DeleteVaultConfig(dir string) error

+ func EstimateTokens(messages []provider.Message) int

+ func SaveVaultConfig(dir string, cfg *VaultConfigFile) error

+ func TeamIDFromContext(ctx context.Context) string

+ func WithTeamID(ctx context.Context, teamID string) context.Context

+ type AIProviderModule struct

+ func (m *AIProviderModule) Agents() []AgentSeed

+ func (m *AIProviderModule) Init(app modular.Application) error

+ func (m *AIProviderModule) Name() string

+ func (m *AIProviderModule) Provider() provider.Provider

+ func (m *AIProviderModule) ProvidesServices() []modular.ServiceProvider

+ func (m *AIProviderModule) RequiresServices() []modular.ServiceDependency

+ func (m *AIProviderModule) Start(_ context.Context) error

+ func (m *AIProviderModule) Stop(_ context.Context) error

+ func (m *AIProviderModule) TestHTTPSource() *HTTPSource

+ type AgentExecuteStep struct

+ func (s *AgentExecuteStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *AgentExecuteStep) Name() string

+ type AgentPermissionCheck struct

+ func (c *AgentPermissionCheck) Name() string

+ func (c *AgentPermissionCheck) Run(ctx context.Context) []AuditFinding

+ type AgentSeed struct

+ ID string

+ IsLead bool

+ Model string

+ Name string

+ Provider string

+ Role string

+ SystemPrompt string

+ TeamID string

+ type Approval struct

+ Action string

+ AgentID string

+ CreatedAt time.Time

+ Details string

+ ID string

+ Reason string

+ ResolvedAt *time.Time

+ ReviewerComment string

+ Status ApprovalStatus

+ TaskID string

+ TimeoutMinutes int

+ type ApprovalManager struct

+ func NewApprovalManager(db *sql.DB) *ApprovalManager

+ func (am *ApprovalManager) Approve(ctx context.Context, id string, comment string) error

+ func (am *ApprovalManager) CheckTimeout(ctx context.Context) error

+ func (am *ApprovalManager) Create(ctx context.Context, approval Approval) error

+ func (am *ApprovalManager) CreateApproval(ctx context.Context, agentID, taskID, action, reason, details string) (string, error)

+ func (am *ApprovalManager) Get(ctx context.Context, id string) (*Approval, error)

+ func (am *ApprovalManager) ListPending(ctx context.Context) ([]Approval, error)

+ func (am *ApprovalManager) Reject(ctx context.Context, id string, comment string) error

+ func (am *ApprovalManager) SetSSEHub(hub *SSEHub)

+ func (am *ApprovalManager) WaitForResolution(ctx context.Context, id string, timeout time.Duration) (*Approval, error)

+ type ApprovalResolveStep struct

+ func (s *ApprovalResolveStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *ApprovalResolveStep) Name() string

+ type ApprovalStatus string

+ const ApprovalApproved

+ const ApprovalPending

+ const ApprovalRejected

+ const ApprovalTimeout

+ type AuditCheck interface

+ Name func() string

+ Run func(ctx context.Context) []AuditFinding

+ type AuditFinding struct

+ Check string

+ Description string

+ Remediation string

+ Severity AuditSeverity

+ Title string

+ type AuditReport struct

+ Findings []AuditFinding

+ Score int

+ Summary map[AuditSeverity]int

+ Timestamp time.Time

+ type AuditSeverity string

+ const SeverityCritical

+ const SeverityHigh

+ const SeverityInfo

+ const SeverityLow

+ const SeverityMedium

+ type AuthCheck struct

+ func (c *AuthCheck) Name() string

+ func (c *AuthCheck) Run(_ context.Context) []AuditFinding

+ type BcryptCheckStep struct

+ func (s *BcryptCheckStep) Execute(_ context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *BcryptCheckStep) Name() string

+ type BcryptHashStep struct

+ func (s *BcryptHashStep) Execute(_ context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *BcryptHashStep) Name() string

+ type BrowserManager struct

+ func NewBrowserManager(headless bool) *BrowserManager

+ func (bm *BrowserManager) GetPage(agentID string) (*rod.Page, error)

+ func (bm *BrowserManager) IsAvailable() bool

+ func (bm *BrowserManager) ReleasePage(agentID string)

+ func (bm *BrowserManager) Shutdown() error

+ type CORSCheck struct

+ func (c *CORSCheck) Name() string

+ func (c *CORSCheck) Run(_ context.Context) []AuditFinding

+ type ChannelSource struct

+ func NewChannelSource() (source *ChannelSource, interactionsCh <-chan Interaction, ...)

+ func (cs *ChannelSource) GetResponse(ctx context.Context, interaction Interaction) (*InteractionResponse, error)

+ type ContainerControlStep struct

+ func (s *ContainerControlStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *ContainerControlStep) Name() string

+ type ContainerManager struct

+ func NewContainerManager(db *sql.DB) *ContainerManager

+ func (cm *ContainerManager) Close() error

+ func (cm *ContainerManager) EnsureContainer(ctx context.Context, projectID, workspacePath string, spec WorkspaceSpec) (string, error)

+ func (cm *ContainerManager) ExecInContainer(ctx context.Context, projectID, command, workDir string, timeout int) (stdout, stderr string, exitCode int, err error)

+ func (cm *ContainerManager) GetContainerStatus(ctx context.Context, projectID string) (string, error)

+ func (cm *ContainerManager) IsAvailable() bool

+ func (cm *ContainerManager) RemoveContainer(ctx context.Context, projectID string) error

+ func (cm *ContainerManager) StopContainer(ctx context.Context, projectID string) error

+ type ContainerSecurityCheck struct

+ func (c *ContainerSecurityCheck) Name() string

+ func (c *ContainerSecurityCheck) Run(ctx context.Context) []AuditFinding

+ type ContextManager struct

+ func NewContextManager(providerName string, compactionThreshold float64) *ContextManager

+ func (cm *ContextManager) Compact(ctx context.Context, messages []provider.Message, aiProvider provider.Provider) []provider.Message

+ func (cm *ContextManager) Compactions() int

+ func (cm *ContextManager) ContextLimitTokens() int

+ func (cm *ContextManager) NeedsCompaction(messages []provider.Message) bool

+ func (cm *ContextManager) SetModelLimit(model string, limit int)

+ func (cm *ContextManager) TokenUsage(messages []provider.Message) (estimated, limit int)

+ type DatabaseSecurityCheck struct

+ func (c *DatabaseSecurityCheck) Name() string

+ func (c *DatabaseSecurityCheck) Run(_ context.Context) []AuditFinding

+ type DefaultCredentialCheck struct

+ func (c *DefaultCredentialCheck) Name() string

+ func (c *DefaultCredentialCheck) Run(_ context.Context) []AuditFinding

+ type HTTPSource struct

+ func NewHTTPSource(hub *SSEHub) *HTTPSource

+ func (h *HTTPSource) GetInteraction(id string) (*Interaction, error)

+ func (h *HTTPSource) GetResponse(ctx context.Context, interaction Interaction) (*InteractionResponse, error)

+ func (h *HTTPSource) ListPending() []InteractionSummary

+ func (h *HTTPSource) PendingCount() int

+ func (h *HTTPSource) Respond(id string, resp InteractionResponse) error

+ func (h *HTTPSource) SetSSEHub(hub *SSEHub)

+ type HumanRequest struct

+ AgentID string

+ CreatedAt time.Time

+ Description string

+ ID string

+ Metadata string

+ ProjectID string

+ RequestType RequestType

+ ResolvedAt *time.Time

+ ResolvedBy string

+ ResponseComment string

+ ResponseData string

+ Status RequestStatus

+ TaskID string

+ TimeoutMinutes int

+ Title string

+ Urgency string

+ type HumanRequestManager struct

+ func NewHumanRequestManager(db *sql.DB) *HumanRequestManager

+ func (m *HumanRequestManager) Cancel(ctx context.Context, id, comment string) error

+ func (m *HumanRequestManager) CheckExpired(ctx context.Context) error

+ func (m *HumanRequestManager) Create(ctx context.Context, req HumanRequest) error

+ func (m *HumanRequestManager) CreateRequest(ctx context.Context, ...) (string, error)

+ func (m *HumanRequestManager) Get(ctx context.Context, id string) (*HumanRequest, error)

+ func (m *HumanRequestManager) GetRequest(ctx context.Context, id string) (map[string]any, error)

+ func (m *HumanRequestManager) ListByAgent(ctx context.Context, agentID string) ([]HumanRequest, error)

+ func (m *HumanRequestManager) ListPending(ctx context.Context) ([]HumanRequest, error)

+ func (m *HumanRequestManager) Resolve(ctx context.Context, id, responseData, comment, resolvedBy string) error

+ func (m *HumanRequestManager) SetSSEHub(hub *SSEHub)

+ func (m *HumanRequestManager) WaitForResolution(ctx context.Context, id string, timeout time.Duration) (*HumanRequest, error)

+ type HumanRequestResolveStep struct

+ func (s *HumanRequestResolveStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *HumanRequestResolveStep) Name() string

+ type Interaction struct

+ CreatedAt time.Time

+ ID string

+ Messages []provider.Message

+ Tools []provider.ToolDef

+ type InteractionResponse struct

+ Content string

+ Error string

+ ToolCalls []provider.ToolCall

+ Usage provider.Usage

+ type InteractionSummary struct

+ CreatedAt time.Time

+ ID string

+ MsgCount int

+ ToolCount int

+ type JWTDecodeStep struct

+ func (s *JWTDecodeStep) Execute(_ context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *JWTDecodeStep) Name() string

+ type JWTGenerateStep struct

+ func (s *JWTGenerateStep) Execute(_ context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *JWTGenerateStep) Name() string

+ type LLMProviderConfig struct

+ Alias string

+ BaseURL string

+ ID string

+ IsDefault int

+ MaxTokens int

+ Model string

+ SecretName string

+ Settings string

+ Type string

+ type LoopDetector struct

+ func NewLoopDetector(cfg LoopDetectorConfig) *LoopDetector

+ func (ld *LoopDetector) Check() (LoopStatus, string)

+ func (ld *LoopDetector) Record(toolName string, args map[string]any, result string, isError bool)

+ func (ld *LoopDetector) Reset()

+ type LoopDetectorConfig struct

+ MaxAlternating int

+ MaxConsecutive int

+ MaxErrors int

+ MaxNoProgress int

+ type LoopStatus int

+ const LoopStatusBreak

+ const LoopStatusOK

+ const LoopStatusWarning

+ type MCPClientModule struct

+ func (m *MCPClientModule) Init(app modular.Application) error

+ func (m *MCPClientModule) Name() string

+ func (m *MCPClientModule) ProvidesServices() []modular.ServiceProvider

+ func (m *MCPClientModule) ReloadServers(configs []mcpServerConfig) (int, []string)

+ func (m *MCPClientModule) RequiresServices() []modular.ServiceDependency

+ func (m *MCPClientModule) Start(ctx context.Context) error

+ func (m *MCPClientModule) Stop(_ context.Context) error

+ type MCPReloadStep struct

+ func (s *MCPReloadStep) Execute(ctx context.Context, _ *module.PipelineContext) (*module.StepResult, error)

+ func (s *MCPReloadStep) Name() string

+ type MCPServerCheck struct

+ func (c *MCPServerCheck) Name() string

+ func (c *MCPServerCheck) Run(ctx context.Context) []AuditFinding

+ type MCPServerModule struct

+ func (m *MCPServerModule) Init(app modular.Application) error

+ func (m *MCPServerModule) Name() string

+ func (m *MCPServerModule) Path() string

+ func (m *MCPServerModule) ProvidesServices() []modular.ServiceProvider

+ func (m *MCPServerModule) RequiresServices() []modular.ServiceDependency

+ func (m *MCPServerModule) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (m *MCPServerModule) Start(_ context.Context) error

+ func (m *MCPServerModule) Stop(_ context.Context) error

+ type MCPToolAdapter struct

+ func (t *MCPToolAdapter) Definition() provider.ToolDef

+ func (t *MCPToolAdapter) Description() string

+ func (t *MCPToolAdapter) Execute(ctx context.Context, args map[string]any) (any, error)

+ func (t *MCPToolAdapter) Name() string

+ type MemoryEntry struct

+ AgentID string

+ Category string

+ Content string

+ CreatedAt time.Time

+ Embedding []float32

+ ID string

+ type MemoryExtractStep struct

+ func (s *MemoryExtractStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *MemoryExtractStep) Name() string

+ type MemoryStore struct

+ func NewMemoryStore(db *sql.DB) *MemoryStore

+ func (ms *MemoryStore) ExtractAndSave(ctx context.Context, agentID, transcript string, embedder provider.Embedder) error

+ func (ms *MemoryStore) InitTables() error

+ func (ms *MemoryStore) Save(ctx context.Context, entry MemoryEntry) error

+ func (ms *MemoryStore) SaveMemory(ctx context.Context, agentID, content, category string) error

+ func (ms *MemoryStore) Search(ctx context.Context, agentID, query string, limit int) ([]MemoryEntry, error)

+ func (ms *MemoryStore) SearchHybrid(ctx context.Context, agentID, query string, queryEmbedding []float32, ...) ([]MemoryEntry, error)

+ func (ms *MemoryStore) SearchMemory(ctx context.Context, agentID, query string, limit int) ([]tools.MemoryEntryResult, error)

+ type OAuthExchangeStep struct

+ func (s *OAuthExchangeStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *OAuthExchangeStep) Name() string

+ type PolicyAction string

+ const PolicyAllow

+ const PolicyDeny

+ type PolicyScope string

+ const PolicyScopeAgent

+ const PolicyScopeGlobal

+ const PolicyScopeTeam

+ type ProviderFactory func(apiKey string, cfg LLMProviderConfig) (provider.Provider, error)

+ type ProviderModelsStep struct

+ func (s *ProviderModelsStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *ProviderModelsStep) Name() string

+ type ProviderRegistry struct

+ func NewProviderRegistry(db *sql.DB, secretsProvider secrets.Provider) *ProviderRegistry

+ func (r *ProviderRegistry) GetByAlias(ctx context.Context, alias string) (provider.Provider, error)

+ func (r *ProviderRegistry) GetDefault(ctx context.Context) (provider.Provider, error)

+ func (r *ProviderRegistry) InvalidateCache()

+ func (r *ProviderRegistry) InvalidateCacheAlias(alias string)

+ func (r *ProviderRegistry) InvalidateCacheBySecret(secretName string)

+ func (r *ProviderRegistry) TestConnection(ctx context.Context, alias string) (bool, string, time.Duration, error)

+ func (r *ProviderRegistry) UpdateSecretsProvider(p secrets.Provider)

+ type ProviderSecurityCheck struct

+ func (c *ProviderSecurityCheck) Name() string

+ func (c *ProviderSecurityCheck) Run(ctx context.Context) []AuditFinding

+ type ProviderTestStep struct

+ func (s *ProviderTestStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *ProviderTestStep) Name() string

+ type RatchetPlugin struct

+ func New() *RatchetPlugin

+ func (p *RatchetPlugin) Capabilities() []capability.Contract

+ func (p *RatchetPlugin) ModuleFactories() map[string]plugin.ModuleFactory

+ func (p *RatchetPlugin) ModuleSchemas() []*schema.ModuleSchema

+ func (p *RatchetPlugin) StepFactories() map[string]plugin.StepFactory

+ func (p *RatchetPlugin) WiringHooks() []plugin.WiringHook

+ type RateLimitCheck struct

+ func (c *RateLimitCheck) Name() string

+ func (c *RateLimitCheck) Run(_ context.Context) []AuditFinding

+ type RequestStatus string

+ const RequestCancelled

+ const RequestExpired

+ const RequestPending

+ const RequestResolved

+ type RequestType string

+ const RequestTypeAccess

+ const RequestTypeBinary

+ const RequestTypeCustom

+ const RequestTypeInfo

+ const RequestTypeToken

+ type ResponseSource interface

+ GetResponse func(ctx context.Context, interaction Interaction) (*InteractionResponse, error)

+ type SSEHub struct

+ func (h *SSEHub) Broadcast(event []byte)

+ func (h *SSEHub) BroadcastEvent(eventType, data string)

+ func (h *SSEHub) Init(app modular.Application) error

+ func (h *SSEHub) Name() string

+ func (h *SSEHub) Path() string

+ func (h *SSEHub) ProvidesServices() []modular.ServiceProvider

+ func (h *SSEHub) RequiresServices() []modular.ServiceDependency

+ func (h *SSEHub) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *SSEHub) Start(_ context.Context) error

+ func (h *SSEHub) Stop(_ context.Context) error

+ type ScriptedScenario struct

+ Description string

+ Loop bool

+ Name string

+ Steps []ScriptedStep

+ func LoadScenario(path string) (*ScriptedScenario, error)

+ type ScriptedSource struct

+ func NewScriptedSource(steps []ScriptedStep, loop bool) *ScriptedSource

+ func NewScriptedSourceFromScenario(scenario *ScriptedScenario) *ScriptedSource

+ func (s *ScriptedSource) GetResponse(ctx context.Context, interaction Interaction) (*InteractionResponse, error)

+ func (s *ScriptedSource) Remaining() int

+ type ScriptedStep struct

+ Content string

+ Delay time.Duration

+ Error string

+ ToolCalls []provider.ToolCall

+ type SecretExposureCheck struct

+ func (c *SecretExposureCheck) Name() string

+ func (c *SecretExposureCheck) Run(ctx context.Context) []AuditFinding

+ type SecretGuard struct

+ func NewSecretGuard(p secrets.Provider, backend string) *SecretGuard

+ func (sg *SecretGuard) AddKnownSecret(name, value string)

+ func (sg *SecretGuard) BackendName() string

+ func (sg *SecretGuard) CheckAndRedact(msg *provider.Message) bool

+ func (sg *SecretGuard) LoadAllSecrets(ctx context.Context) error

+ func (sg *SecretGuard) LoadSecrets(ctx context.Context, names []string) error

+ func (sg *SecretGuard) Provider() secrets.Provider

+ func (sg *SecretGuard) Redact(text string) string

+ func (sg *SecretGuard) SetProvider(p secrets.Provider, backend string)

+ type SecretManageStep struct

+ func (s *SecretManageStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *SecretManageStep) Name() string

+ type SecurityAuditStep struct

+ func (s *SecurityAuditStep) Execute(ctx context.Context, _ *module.PipelineContext) (*module.StepResult, error)

+ func (s *SecurityAuditStep) Name() string

+ type SecurityAuditor struct

+ func NewSecurityAuditor(db *sql.DB, app modular.Application) *SecurityAuditor

+ func (sa *SecurityAuditor) RunAll(ctx context.Context) *AuditReport

+ type Skill struct

+ Category string

+ Content string

+ CreatedAt time.Time

+ Description string

+ ID string

+ Name string

+ RequiredTools []string

+ type SkillManager struct

+ func NewSkillManager(db *sql.DB, skillDir string) *SkillManager

+ func (sm *SkillManager) AssignToAgent(ctx context.Context, agentID, skillID string) error

+ func (sm *SkillManager) BuildSkillPrompt(ctx context.Context, agentID string) (string, error)

+ func (sm *SkillManager) GetAgentSkills(ctx context.Context, agentID string) ([]Skill, error)

+ func (sm *SkillManager) GetSkill(ctx context.Context, id string) (*Skill, error)

+ func (sm *SkillManager) InitTables() error

+ func (sm *SkillManager) ListSkills(ctx context.Context) ([]Skill, error)

+ func (sm *SkillManager) LoadFromDirectory() error

+ func (sm *SkillManager) RemoveFromAgent(ctx context.Context, agentID, skillID string) error

+ type SubAgentManager struct

+ func NewSubAgentManager(db *sql.DB, maxPerParent, maxDepth int) *SubAgentManager

+ func (sm *SubAgentManager) CancelChildren(ctx context.Context, parentAgentID string) error

+ func (sm *SubAgentManager) CheckTask(ctx context.Context, taskID string) (status string, result string, err error)

+ func (sm *SubAgentManager) CountActive(ctx context.Context, parentAgentID string) (int, error)

+ func (sm *SubAgentManager) Spawn(ctx context.Context, parentAgentID string, name string, taskDesc string, ...) (taskID string, err error)

+ func (sm *SubAgentManager) WaitTasks(ctx context.Context, taskIDs []string, timeout time.Duration) (map[string]tools.SubTaskResult, error)

+ type TestInteractStep struct

+ func (s *TestInteractStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *TestInteractStep) Name() string

+ type TestProvider struct

+ func NewTestProvider(source ResponseSource, opts ...TestProviderOption) *TestProvider

+ func (tp *TestProvider) AuthModeInfo() provider.AuthModeInfo

+ func (tp *TestProvider) Chat(ctx context.Context, messages []provider.Message, tools []provider.ToolDef) (*provider.Response, error)

+ func (tp *TestProvider) InteractionCount() int64

+ func (tp *TestProvider) Name() string

+ func (tp *TestProvider) Source() ResponseSource

+ func (tp *TestProvider) Stream(ctx context.Context, messages []provider.Message, tools []provider.ToolDef) (<-chan provider.StreamEvent, error)

+ type TestProviderOption func(*TestProvider)

+ func WithName(s string) TestProviderOption

+ func WithTimeout(d time.Duration) TestProviderOption

+ type ToolPolicy struct

+ Action PolicyAction

+ CreatedAt time.Time

+ ID string

+ Scope PolicyScope

+ ScopeID string

+ ToolPattern string

+ type ToolPolicyEngine struct

+ DefaultPolicy PolicyAction

+ func NewToolPolicyEngine(db *sql.DB) *ToolPolicyEngine

+ func (tpe *ToolPolicyEngine) AddPolicy(ctx context.Context, policy ToolPolicy) error

+ func (tpe *ToolPolicyEngine) InitTable() error

+ func (tpe *ToolPolicyEngine) IsAllowed(ctx context.Context, toolName string, agentID string, teamID string) (bool, string)

+ func (tpe *ToolPolicyEngine) ListPolicies(ctx context.Context) ([]ToolPolicy, error)

+ func (tpe *ToolPolicyEngine) RemovePolicy(ctx context.Context, id string) error

+ type ToolRegistry struct

+ func NewToolRegistry() *ToolRegistry

+ func (tr *ToolRegistry) AllDefs() []provider.ToolDef

+ func (tr *ToolRegistry) Execute(ctx context.Context, name string, args map[string]any) (any, error)

+ func (tr *ToolRegistry) Get(name string) (plugin.Tool, bool)

+ func (tr *ToolRegistry) Names() []string

+ func (tr *ToolRegistry) Register(tool plugin.Tool)

+ func (tr *ToolRegistry) RegisterMCP(serverName string, tools []plugin.Tool)

+ func (tr *ToolRegistry) SetPolicyEngine(engine *ToolPolicyEngine)

+ func (tr *ToolRegistry) UnregisterMCP(serverName string)

+ type TranscriptEntry struct

+ AgentID string

+ Content string

+ CreatedAt string

+ ID string

+ Iteration int

+ ProjectID string

+ Redacted bool

+ Role provider.Role

+ TaskID string

+ ToolCallID string

+ ToolCalls []provider.ToolCall

+ type TranscriptRecorder struct

+ func NewTranscriptRecorder(db *sql.DB, guard *SecretGuard) *TranscriptRecorder

+ func (tr *TranscriptRecorder) GetByAgent(ctx context.Context, agentID string) ([]TranscriptEntry, error)

+ func (tr *TranscriptRecorder) GetByTask(ctx context.Context, taskID string) ([]TranscriptEntry, error)

+ func (tr *TranscriptRecorder) Record(ctx context.Context, entry TranscriptEntry) error

+ type VaultCheck struct

+ func (c *VaultCheck) Name() string

+ func (c *VaultCheck) Run(_ context.Context) []AuditFinding

+ type VaultConfigFile struct

+ Address string

+ Backend string

+ MountPath string

+ Namespace string

+ Token string

+ func LoadVaultConfig(dir string) (*VaultConfigFile, error)

+ type VaultConfigStep struct

+ func (s *VaultConfigStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *VaultConfigStep) Name() string

+ type Webhook struct

+ CreatedAt time.Time

+ Enabled bool

+ Filter string

+ ID string

+ Name string

+ SecretName string

+ Source string

+ TaskTemplate string

+ type WebhookManager struct

+ func NewWebhookManager(db *sql.DB, guard *SecretGuard) *WebhookManager

+ func (wm *WebhookManager) Create(ctx context.Context, wh Webhook) error

+ func (wm *WebhookManager) Delete(ctx context.Context, id string) error

+ func (wm *WebhookManager) ExtractEventType(source string, headers map[string]string, payload map[string]any) string

+ func (wm *WebhookManager) GetBySource(ctx context.Context, source string) ([]Webhook, error)

+ func (wm *WebhookManager) List(ctx context.Context) ([]Webhook, error)

+ func (wm *WebhookManager) MatchesFilter(source string, eventType string, filter string) bool

+ func (wm *WebhookManager) RenderTaskTemplate(tmpl string, payload map[string]any) (title string, description string, err error)

+ func (wm *WebhookManager) VerifySignature(source string, secret string, payload []byte, signature string, ...) bool

+ type WebhookProcessStep struct

+ func (s *WebhookProcessStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *WebhookProcessStep) Name() string

+ type WebhookSecurityCheck struct

+ func (c *WebhookSecurityCheck) Name() string

+ func (c *WebhookSecurityCheck) Run(ctx context.Context) []AuditFinding

+ type WorkspaceInitStep struct

+ func (s *WorkspaceInitStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *WorkspaceInitStep) Name() string

+ type WorkspaceSpec struct

+ CPULimit float64

+ Env map[string]string

+ Image string

+ InitCommands []string

+ MemoryLimit int64

+ NetworkMode string

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