Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.4.3

Nov 9, 2026

v0.4.2

Nov 4, 2026

Changes in this version

type Manager

+ func (m *Manager) Proxies() *pgdb.ProxyStore

+ func (m *Manager) ProxyEgressTrustedOnly() bool

+ func (m *Manager) ProxyIntervals() (fetchMin, checkMin int)

+ func (m *Manager) ProxyPool() *proxypool.Pool

+ func (m *Manager) ProxyPoolEnabled() bool

+ func (m *Manager) SetProxyEgressTrustedOnly(on bool) error

+ func (m *Manager) SetProxyIntervals(fetchMin, checkMin int) error

+ func (m *Manager) SetProxyPoolEnabled(on bool) error

v0.4.1

Nov 4, 2026

v0.4.0

Nov 4, 2026

Changes in this version

+ var BuildVersion = "dev"

+ func RestartRequested() <-chan struct

+ func SetBootUpdateState(st selfupdate.State)

+ func StartLogCapture()

+ type ActivityDTO struct

+ CacheReadTokens *int

+ CacheWriteTokens *int

+ Detail string

+ Inherited bool

+ InputTokens *int

+ IntentID string

+ IsError bool

+ Kind string

+ MainSeg *int

+ Metadata json.RawMessage

+ OutputTokens *int

+ Seq int64

+ SourceTaskID string

+ Summary string

+ TS string

+ Tool string

+ ToolUseID string

+ Worker string

+ type AgentDTO struct

+ Builtin bool

+ Description string

+ Enabled bool

+ ID string

+ InteractiveShell bool

+ Key string

+ LLMProfileID *int64

+ MaxTurns int

+ McpCount int

+ Name string

+ Role string

+ RunSecs int

+ SkillCount int

+ ToolCount int

+ TriggerMaxParallel int

+ TriggerMergeMode string

+ TriggerRunMode string

+ WebSearch bool

+ type Broadcaster struct

+ func NewBroadcaster() *Broadcaster

+ func (b *Broadcaster) Publish(task string, a db.Activity)

+ func (b *Broadcaster) Subscribe(task string) (<-chan db.Activity, func())

+ type ConstraintDTO struct

+ ID string

+ Kind string

+ Origin string

+ TS string

+ Text string

+ type CoverageAssetRefDTO struct

+ ID int64

+ Inherited bool

+ Kind string

+ SourceTaskID string

+ State string

+ Summary string

+ type DeleteTaskOptions struct

+ DeleteAssets bool

+ DeleteFiles bool

+ DeleteFindings bool

+ DeleteLLMRecords bool

+ DeleteTraffic bool

+ type DeleteTaskResult struct

+ AssetsDeleted int64

+ AssetsDetached int64

+ CleanupWarning string

+ Deleted string

+ FilesDeleted bool

+ FindingsDeleted int64

+ LLMRecordsDeleted int64

+ TrafficDeleted int64

+ type EdgeDTO struct

+ Dst string

+ Rel string

+ Src string

+ type Engine struct

+ func NewEngine(m *Manager) *Engine

+ func (e *Engine) AbortDelete(taskID string, keepPaused bool)

+ func (e *Engine) ActiveLLMCalls(taskID string) int64

+ func (e *Engine) BeginDelete(taskID string) bool

+ func (e *Engine) BeginLLMCall(taskID string)

+ func (e *Engine) Broadcaster() *Broadcaster

+ func (e *Engine) ControlWork(ctx context.Context, intentID int64, action string) error

+ func (e *Engine) EndLLMCall(taskID string)

+ func (e *Engine) IsDeleting(taskID string) bool

+ func (e *Engine) IsPaused(taskID string) bool

+ func (e *Engine) KillWork(intentID int64) error

+ func (e *Engine) LastActivity(taskID string) int64

+ func (e *Engine) Pause(taskID string, cause error)

+ func (e *Engine) Ready() bool

+ func (e *Engine) ReadyFor(t *Task) bool

+ func (e *Engine) Resume(t *Task)

+ func (e *Engine) Run(ctx context.Context, t *Task)

+ func (e *Engine) SetAgentResolver(fn func(t *Task) (*agent.Planner, *agent.Worker))

+ func (e *Engine) SetAuthoritativeAgentResolver(fn func(t *Task) (*agent.Planner, *agent.Worker))

+ func (e *Engine) SetReadiness(fn func() bool)

+ func (e *Engine) Started(taskID string) bool

+ func (e *Engine) SteerWork(intentID int64, msg string) error

+ func (e *Engine) StopTask(taskID string)

+ type FindingAssetDTO struct

+ ID string

+ Label string

+ Type string

+ type FindingDTO struct

+ Assets []FindingAssetDTO

+ Evidence string

+ EvidenceVersion int64

+ FindingID string

+ ID string

+ Inherited bool

+ IntentID string

+ Name string

+ ParamID string

+ Report string

+ ReportEvidenceVersion int64

+ ReportStale bool

+ Severity string

+ SourceTaskID string

+ Status string

+ Summary string

+ TS string

+ TaskDescription string

+ TaskID string

+ TrafficBindings []db.FindingTrafficBinding

+ TrafficCount int

+ VulnClass string

+ type FindingSeverityDTO struct

+ Critical int

+ High int

+ Low int

+ Medium int

+ type GoalDTO struct

+ ID string

+ Origin string

+ State string

+ TS string

+ Text string

+ VulnClass string

+ type LLMPoolMemberStatus struct

+ Active bool

+ CooldownSecs int

+ Excluded bool

+ Fails int

+ Format string

+ LastAt string

+ LastError string

+ Model string

+ Name string

+ Priority int

+ ProfileID string

+ State string

+ Trips int

+ type LLMProfileDTO struct

+ APIKeyHint string

+ BaseURL string

+ ContextWindowK int

+ Format string

+ ID string

+ IsDefault bool

+ MaxTokens int

+ MaxTokensField string

+ Model string

+ Name string

+ PoolExclude bool

+ Priority int

+ Proxy string

+ RatePerMinute float64

+ RatePerSecond float64

+ ReasoningEffort string

+ Retry db.RetryOverride

+ SessionHeaderKey string

+ Streaming bool

+ ThinkingType string

+ type LogLine struct

+ DBID int64

+ Level string

+ Seq int64

+ TS string

+ Tag string

+ Text string

+ type Manager struct

+ func NewManager(dir, proxyAddr string) (*Manager, error)

+ func (m *Manager) ActiveTask() *Task

+ func (m *Manager) ApplyTaskAdmission(id, expectedStatus, status string, queued bool, mode string, ...) error

+ func (m *Manager) ApplyTaskPause(id string) error

+ func (m *Manager) Assets() *pgdb.AssetStore

+ func (m *Manager) Close() error

+ func (m *Manager) ConcurrencyLimit() (enabled bool, limit int)

+ func (m *Manager) CreateTask(description, goal string, llmProfileID *int64, ...) (*Task, error)

+ func (m *Manager) CreateTaskWithOptions(description, goal string, opts pgdb.TaskCreateOptions) (*Task, error)

+ func (m *Manager) DeleteCompanyWithAssets(id int64, deleteAssets bool) (int64, error)

+ func (m *Manager) DeleteTask(id string, opts DeleteTaskOptions) (DeleteTaskResult, error)

+ func (m *Manager) DeleteTaskCategory(id int64) (bool, error)

+ func (m *Manager) DequeueTask(id string, clearMode bool) error

+ func (m *Manager) EnqueueTask(id, mode string) error

+ func (m *Manager) Enrich() *enrich.Engine

+ func (m *Manager) GlobalProxy() string

+ func (m *Manager) HostTools() []actool.CoreTool

+ func (m *Manager) LLMPoolBindFallback() bool

+ func (m *Manager) LLMPoolEnabled() bool

+ func (m *Manager) LLMRecordEnabled() bool

+ func (m *Manager) List() []*Task

+ func (m *Manager) LoadExisting() []*Task

+ func (m *Manager) NoaCompactionEnabled() bool

+ func (m *Manager) PG() *pgdb.DB

+ func (m *Manager) ProxyAddr() string

+ func (m *Manager) ProxyCACert() string

+ func (m *Manager) RenameTaskCategory(id int64, name string) (*pgdb.TaskCategory, error)

+ func (m *Manager) ReplaceTaskLLMProfiles(id string, profileIDs []int64, activeProfileID int64) (int64, error)

+ func (m *Manager) ResolveTask(id string) *Task

+ func (m *Manager) SetActive(id string) bool

+ func (m *Manager) SetConcurrency(enabled bool, limit int) error

+ func (m *Manager) SetGlobalProxy(raw string) error

+ func (m *Manager) SetLLMPoolBindFallback(on bool) error

+ func (m *Manager) SetLLMPoolEnabled(on bool) error

+ func (m *Manager) SetLLMRecordEnabled(on bool) error

+ func (m *Manager) SetNoaCompaction(on bool) error

+ func (m *Manager) SetTaskCategory(taskID string, categoryID *int64) (*pgdb.TaskCategory, error)

+ func (m *Manager) SetTaskPaused(id string, paused bool) error

+ func (m *Manager) SetTaskStatus(id, status string) error

+ func (m *Manager) SetTaskStatusGuarded(id, status string) (won bool, err error)

+ func (m *Manager) SetTasksCategory(taskIDs []string, categoryID *int64) (map[string]bool, *pgdb.TaskCategory, error)

+ func (m *Manager) SetTrafficEnabled(on bool) error

+ func (m *Manager) SetWebSearch(on bool, backend string, braveKey, tavilyKey, proxy *string) error

+ func (m *Manager) SetWorkers(n int) error

+ func (m *Manager) StampTaskFirstRun(id string) (int64, error)

+ func (m *Manager) Task(id string) (*Task, bool)

+ func (m *Manager) TaskStatus(id string) string

+ func (m *Manager) Traffic() *traffic.Traffic

+ func (m *Manager) TrafficEnabled() bool

+ func (m *Manager) UpdateTaskMetadata(taskID string, patch pgdb.TaskPatch) (*Task, error)

+ func (m *Manager) WebSearch() (on bool, backend, braveKey, tavilyKey, proxy string)

+ func (m *Manager) WebSearchOpts() agent.WebSearchOpts

+ func (m *Manager) Workers() int

+ type Notifier struct

+ func (n *Notifier) Run(ctx context.Context)

+ type Scheduler struct

+ func (sc *Scheduler) Run(ctx context.Context)

+ type Server struct

+ func New(ctx context.Context, m *Manager, skillDir string, dataDir string, ...) *Server

+ func (s *Server) Handler() http.Handler

+ func (s *Server) StartTriggeredRun(agentKey, title, message string, taskID int64, mergeable bool, ...)

+ type Task struct

+ ActiveLLMProfileID *int64

+ CategoryID *int64

+ CategoryName string

+ CompanyIDs []int64

+ CompletedAt int64

+ CoverageEnabled bool

+ CreatedAt int64

+ DeadlineAt int64

+ Description string

+ ExpID int64

+ FirstRunAt int64

+ Goal string

+ Guard *guard.Guard

+ ID string

+ LLMChainRevision int64

+ LLMFailoverReason string

+ LLMFailoverState string

+ LLMProfileID *int64

+ LLMProfileIDs []int64

+ Name string

+ ParentRef string

+ Paused bool

+ PinnedAt int64

+ PlanHeartbeatSeconds int

+ QueueMode string

+ Queued bool

+ QueuedAt int64

+ SourceTaskIDs []int64

+ Status string

+ Store *pgdb.ExplorationStore

+ TimeoutSeconds int

+ func (t *Task) Notify()

+ func (t *Task) NotifyCancelled(intentID int64, summary, reason string)

+ func (t *Task) NotifyDone(intentID int64)

+ func (t *Task) NotifyFinding(intentID int64, summary string)

+ func (t *Task) NotifyGoal(texts []string)

+ func (t *Task) NotifyGoalDeleted(text string)

+ func (t *Task) NotifyGoalEdited(oldText, newText string)

+ func (t *Task) NotifyHint(texts []string)

+ type TaskDTO struct

+ ActiveLLMProfileID *int64

+ ArchiveBlockedBy string

+ CategoryID *int64

+ CategoryName string

+ CompanyIDs []int64

+ CompletedAt string

+ CompletedUnix int64

+ CoverageEnabled bool

+ CreatedAt string

+ CreatedUnix int64

+ Description string

+ ExplorationID int64

+ Findings FindingSeverityDTO

+ Goal string

+ GoalsMet int

+ GoalsTotal int

+ ID string

+ InFlight int

+ LLMFailoverReason string

+ LLMFailoverState string

+ LLMProfileID *int64

+ LLMProfileIDs []int64

+ LastActivity int64

+ Name string

+ Paused bool

+ Pinned bool

+ PinnedAt string

+ Queued bool

+ SourceTaskIDs []string

+ Status string

+ Tokens TokenTotalDTO

+ type TaskNodeDTO struct

+ DeleteReason string

+ ID string

+ Inherited bool

+ Origin string

+ Payload string

+ Priority int

+ SourceTaskID string

+ State string

+ TS string

+ Type string

+ type TokenTotalDTO struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ InputTokens int

+ OutputTokens int

+ type TrafficExchangeDTO struct

+ ContentType string

+ Host string

+ ID string

+ Method string

+ RespLen int

+ Status int

+ TS string

+ URL string