db

package

Go to main page

Versions in this module

v0

v0.4.3

Nov 9, 2026

Changes in this version

+ type RowScanner func(*sql.Rows) (T, error)

v0.4.2

Nov 4, 2026

Changes in this version

+ const ProxyFailAutoDisable

+ const SettingProxyPoolEnabled

+ var ErrProxyNotFound = errors.New("proxy not found")

type AssetStore

+ func (s *AssetStore) Proxies() *ProxyStore

type DB

+ func (d *DB) Proxies() *ProxyStore

+ type Proxy struct

+ Anonymity string

+ CheckCount int

+ CreatedAt string

+ Enabled bool

+ FailStreak int

+ Healthy bool

+ Host string

+ ID int64

+ Label string

+ LastCheckAt string

+ LastError string

+ LastOkAt string

+ LatencyMs int

+ OkCount int

+ Password string

+ Port int

+ Protocol string

+ Region string

+ Source string

+ Tags []string

+ Trusted bool

+ UpdatedAt string

+ Username string

+ func ParseProxyLine(line string) (Proxy, error)

+ func (p *Proxy) URL() *url.URL

+ func (p Proxy) Masked() Proxy

+ type ProxyFilter struct

+ Anonymity string

+ Limit int

+ Offset int

+ OnlyEnabled bool

+ OnlyHealthy bool

+ Protocol string

+ Region string

+ Tags []string

+ TrustedOnly bool

+ type ProxySource struct

+ Enabled bool

+ LastCount int

+ LastError string

+ LastFetchAt string

+ Name string

+ type ProxyStore struct

+ func (s *ProxyStore) CountProxies(f ProxyFilter) (int, error)

+ func (s *ProxyStore) CreateProxy(p *Proxy) (int64, error)

+ func (s *ProxyStore) DeleteProxy(id int64) error

+ func (s *ProxyStore) EnabledSources() ([]string, error)

+ func (s *ProxyStore) GetProxy(id int64) (*Proxy, error)

+ func (s *ProxyStore) ImportProxies(lines []string) (added int, invalid []string, err error)

+ func (s *ProxyStore) ListProxies(f ProxyFilter) ([]*Proxy, error)

+ func (s *ProxyStore) ListSources(names []string) ([]ProxySource, error)

+ func (s *ProxyStore) PoolEnabled() bool

+ func (s *ProxyStore) RecordFetch(name string, count int, fetchErr string) error

+ func (s *ProxyStore) SelectForHost(host string, trustedOnly bool) (*Proxy, error)

+ func (s *ProxyStore) SetProxyEnabled(id int64, enabled bool) error

+ func (s *ProxyStore) SetSourceEnabled(name string, enabled bool) error

+ func (s *ProxyStore) UpdateHealth(id int64, ok bool, latencyMs int, probeErr string) error

+ func (s *ProxyStore) UpdateProxy(p *Proxy) error

+ func (s *ProxyStore) UpsertFromSource(sourceName string, proxies []Proxy) (int, error)

v0.4.1

Nov 4, 2026

v0.4.0

Nov 4, 2026

Changes in this version

+ const ArchiveFailed

+ const ArchiveQueued

+ const ArchiveReady

+ const Archiving

+ const DeleteFailed

+ const DeleteQueued

+ const Deleting

+ const FindingConfirmed

+ const FindingDuplicate

+ const FindingFalsePositive

+ const FindingFixed

+ const FindingIgnored

+ const FindingInProgress

+ const FindingPending

+ const FindingResolved

+ const FindingRetestAgentKey

+ const FindingRiskAccepted

+ const FindingUnassignedAsset

+ const FindingUnassignedTask

+ const IntentBlockedLLMQuota

+ const KindBegin

+ const KindDigest

+ const KindFact

+ const KindFinding

+ const KindGoal

+ const KindHint

+ const KindIntent

+ const MaxCompanyScopeRawRunes

+ const MaxCompanyScopeValueRunes

+ const MaxDigestBatchSize

+ const MaxNotifyAttempts

+ const MaxTaskAssetMutationCount

+ const MaxTaskAssetSummaryRunes

+ const MaxTaskCategoryBatchSize

+ const MaxTaskCategoryNameRunes

+ const MaxTaskCompanyCount

+ const MaxTaskSourceCount

+ const MaxTaskTemplateNameRunes

+ const MaxTaskTemplateTextRunes

+ const MinPlanHeartbeatSeconds

+ const NotifyModeDigest

+ const NotifyModeRealtime

+ const NotifyStateFailed

+ const NotifyStatePending

+ const NotifyStateSending

+ const NotifyStateSent

+ const NotifyStateSkipped

+ const RelCovers

+ const RelDerivedFrom

+ const RelProves

+ const RelSpawns

+ const RelYields

+ const RestoreFailed

+ const RestoreQueued

+ const Restoring

+ const SeverityCritical

+ const SeverityHigh

+ const SeverityLow

+ const SeverityMedium

+ const StateDigestActive

+ const StateDigestSuperseded

+ const StateIntentDeleted

+ const StateOrigin

+ const TaskArchiveFormatVersion

+ const TaskArchiveLLMRecordsPath

+ const TaskArchiveLegacyFormatVersion

+ var ErrActiveLLMProfileDelete = errors.New("cannot delete the active LLM profile; activate another profile first")

+ var ErrAssetIPInvalid = errors.New("invalid asset ip")

+ var ErrCompanyNameConflict = errors.New("company name already exists")

+ var ErrCompanyNotFound = errors.New("company not found")

+ var ErrEvidenceConflict = errors.New("流量证据已变更，请刷新后重试")

+ var ErrEvidenceNotFound = errors.New("流量证据不存在")

+ var ErrFindingNotFound = errors.New("漏洞不存在")

+ var ErrFindingOriginUnavailable = errors.New("finding origin is no longer available")

+ var ErrIntentStateConflict = errors.New("intent state changed concurrently")

+ var ErrInterceptExecutionUnavailable = errors.New(...)

+ var ErrInterceptSessionDeleted = errors.New("对应会话或执行记录已被删除或不存在")

+ var ErrInterceptTaskDeleted = errors.New("任务已被删除或归档")

+ var ErrInvalidChatMentionCursor = errors.New("分页位置无效，请重新搜索")

+ var ErrLLMProfileNotFound = errors.New("LLM profile not found")

+ var ErrLLMProfileReferencesChanged = errors.New("LLM profile references changed while deleting; retry the request")

+ var ErrNotificationChannelNotFound = errors.New("通知渠道不存在")

+ var ErrRetestNotRunning = errors.New("本次复测已结束或尚未开始，请从漏洞详情发起新的复测")

+ var ErrSideBusy = errors.New("当前会话已有旁路问题正在回答")

+ var ErrSideParentGone = errors.New("旁路父会话已删除或归档")

+ var ErrTaskArchiveDeleteBlocked = errors.New("task archive is required by another archive")

+ var ErrTaskArchiveDependent = errors.New("task is inherited by a live task")

+ var ErrTaskArchiveFormatMismatch = errors.New("task archive format is not supported")

+ var ErrTaskArchiveIneligible = errors.New("task must be paused or terminal before archiving")

+ var ErrTaskArchiveNotFound = errors.New("task archive not found")

+ var ErrTaskArchiveQueued = errors.New("queued task must be paused before archiving")

+ var ErrTaskArchiveState = errors.New("task archive state does not allow this operation")

+ var ErrTaskAssetAssetNotFound = errors.New("asset not found")

+ var ErrTaskAssetInvalid = errors.New("invalid task asset association")

+ var ErrTaskAssetTaskNotFound = errors.New("task not found")

+ var ErrTaskCategoryInvalid = errors.New("invalid task category")

+ var ErrTaskCategoryNameConflict = errors.New("task category name already exists")

+ var ErrTaskCategoryNotFound = errors.New("task category not found")

+ var ErrTaskCategoryTaskNotFound = errors.New("task not found")

+ var ErrTaskCompanyIDsInvalid = errors.New("invalid task company ids")

+ var ErrTaskCompanyNotFound = errors.New("task company not found")

+ var ErrTaskTemplateInvalid = errors.New("invalid task template")

+ var ErrTaskTemplateNameConflict = errors.New("task template name already exists")

+ var ErrTaskTemplateNotFound = errors.New("task template not found")

+ func AddFindingTrafficTx(tx *sql.Tx, findingID int64, prepared []PreparedTrafficEvidence) error

+ func AssetInterceptKindLabel(kind string) string

+ func DSN() (dsn, source string, err error)

+ func DomainKey(fqdn string) string

+ func EndpointKey(siteID int64, method, urlTemplate string) string

+ func IPKey(ip string) string

+ func InsertEvidenceSnapshotTx(tx *sql.Tx, s TrafficEvidenceSnapshot) error

+ func IsTaskArchiveFormatSupported(version int) bool

+ func IsTerminal(status string) bool

+ func LockFindingEvidenceTx(tx *sql.Tx, findingID int64, version *int64) error

+ func LockTaskEvidenceTx(tx *sql.Tx, taskID int64) error

+ func NormalizeICP(value string) string

+ func NormalizeParamName(name string) string

+ func NormalizeTaskCompanyIDs(ids []int64) ([]int64, error)

+ func ParameterKey(endpointID int64, location, name string) string

+ func ParseDSL(s string) (*astNode, error)

+ func ParseExpID(s string) int64

+ func PortKey(ipID int64, proto string, port int) string

+ func RecordNotificationEventTx(ctx context.Context, tx *sql.Tx, kind string, findingID int64, ...) bool

+ func RootDomain(host string) (root string, isApex bool)

+ func ServiceKey(portID int64, svcName string) string

+ func SetFindingStatusTx(ctx context.Context, tx *sql.Tx, id int64, status string) (from string, found bool, changed bool, notified bool, err error)

+ func SiteKey(scheme, host string, port int) string

+ func SplitURL(raw, method string) (scheme, host string, port int, urlTemplate string, params []string, err error)

+ func TechKey(name, version string) string

+ func TemplatePath(path string) string

+ func TrafficSnapshotID(snapshot TrafficEvidenceSnapshot) string

+ func ValidChatMentionKind(kind string) bool

+ func ValidFindingStatus(s string) bool

+ func ValidNotifyMode(m string) bool

+ func ValidSeverity(s string) bool

+ func ValidTrafficRole(role string) bool

+ func ValidateAssetIP(value string) error

+ func ValidateCompanyScopeInputBounds(inputs []ScopeInput) error

+ func ValidateDSL(dsl string) error

+ type ActiveFindingRetest struct

+ ConversationID int64

+ FindingID int64

+ ID int64

+ Status string

+ type Activity struct

+ CacheReadTokens *int

+ CacheWriteTokens *int

+ CreatedAt time.Time

+ Detail string

+ ID int64

+ Inherited bool

+ InputTokens *int

+ IsError bool

+ Kind string

+ MainSeg *int

+ Metadata json.RawMessage

+ NodeID *int64

+ OutputTokens *int

+ SourceTaskID int64

+ Summary string

+ Tool string

+ ToolUseID string

+ Worker string

+ type ActivitySessionFilter struct

+ Main bool

+ MainSeg *int

+ NodeID *int64

+ Worker string

+ type Agent struct

+ Builtin bool

+ Description string

+ Enabled bool

+ ID int64

+ InteractiveShell bool

+ Key string

+ LLMProfileID *int64

+ MaxTurns int

+ Name string

+ Role string

+ RunSecs int

+ TaskTimeoutWrapupMaxTurns int

+ TaskTimeoutWrapupPrompt string

+ TriggerMaxParallel int

+ TriggerMergeMode string

+ TriggerRunMode string

+ WebSearch bool

+ WrapupMaxTurns int

+ WrapupPrompt string

+ type AgentTrigger struct

+ AgentKey string

+ Enabled bool

+ FindingMessage string

+ GoalMessage string

+ ID int64

+ IntervalMessage string

+ IntervalSec int

+ LastFire *time.Time

+ OnFinding bool

+ OnGoalMet bool

+ OnTaskCreate bool

+ OnTaskTimeout bool

+ OnToolCall bool

+ TaskCreateMessage string

+ TaskTimeoutMessage string

+ ToolCallMessage string

+ ToolNames []string

+ type Asset struct

+ AppDescription string

+ AppICP string

+ AppName string

+ Auth []map[string]any

+ BoundDomains []string

+ BundleID string

+ CSegment string

+ Category string

+ CompanyID *int64

+ ContentLength *int64

+ Domain string

+ Extra map[string]any

+ FaviconMMH3 string

+ ICP string

+ ID int64

+ IP string

+ LastSeen string

+ Method string

+ OpenPorts []map[string]any

+ PageTitle string

+ Params []map[string]any

+ Port *int

+ RecordType string

+ RecordValue []string

+ RootDomain string

+ ServiceName string

+ ServiceType string

+ StatusCode *int

+ TaskIDs []int64

+ TaskSource string

+ TaskSourceNodeID *int64

+ TaskSourceSummary string

+ Technologies []string

+ Type string

+ URL string

+ func (a *Asset) InterceptLabel() string

+ type AssetGateDecision struct

+ Allowed bool

+ Reason string

+ func EvaluateAssetGate(blockRules, allowRules []AssetInterceptRule, domains, ips, urls []string) AssetGateDecision

+ type AssetInterceptHit struct

+ Asset *Asset

+ Reason string

+ func (h AssetInterceptHit) Describe() string

+ type AssetInterceptRule struct

+ Action string

+ Builtin bool

+ CreatedAt time.Time

+ Enabled bool

+ ID int64

+ Kind string

+ Note string

+ Pattern string

+ UpdatedAt time.Time

+ func MatchAssetInterceptRules(rules []AssetInterceptRule, domains, ips, urls []string) (AssetInterceptRule, string, bool)

+ func (r AssetInterceptRule) Reason() string

+ type AssetRef struct

+ ID int64

+ Inherited bool

+ Kind string

+ SourceTaskID int64

+ State string

+ Summary string

+ type AssetStore struct

+ func (a *AssetStore) FindingMetaByNodeID(taskID int64) (map[int64]FindingMeta, error)

+ func (s *AssetStore) AddAgentScope(taskID int64, kind, value, reason, source string) (TaskScope, error)

+ func (s *AssetStore) AddAutoScope(taskID int64, assetType, domain, rawURL, ip string) error

+ func (s *AssetStore) AppendIPBoundDomain(ipStr, domain string) error

+ func (s *AssetStore) AppendIPPort(ipStr string, port int, serviceName string) error

+ func (s *AssetStore) AttachAssetsToTask(taskID int64, assetIDs []int64, sourceSummary string) (TaskAssetMutation, error)

+ func (s *AssetStore) BuildCoverageGraph(taskID, _ int64) (*CoverageGraphData, error)

+ func (s *AssetStore) CheckAssetsIntercept(taskID int64, ids []int64) ([]AssetInterceptHit, error)

+ func (s *AssetStore) Companies() *CompanyStore

+ func (s *AssetStore) CountByCompany(companyID int64, typ string) (int, error)

+ func (s *AssetStore) CountByTask(taskID int64, typ string) (int, error)

+ func (s *AssetStore) CountByType(typ string) (int, error)

+ func (s *AssetStore) CountDSL(dsl, typ string, taskID int64) (int, error)

+ func (s *AssetStore) CountsByType() (map[string]int, error)

+ func (s *AssetStore) CountsByTypeForTask(taskID int64) (map[string]int, error)

+ func (s *AssetStore) CoverageEnabled(taskID int64) bool

+ func (s *AssetStore) CreateTaskInterceptRule(taskID int64, action, kind, pattern, note string, enabled bool) (AssetInterceptRule, error)

+ func (s *AssetStore) DeleteByCompanyID(companyID int64) (int64, error)

+ func (s *AssetStore) DeleteByHost(host string) (map[string]int64, error)

+ func (s *AssetStore) DeleteByIDs(ids []int64) (int64, error)

+ func (s *AssetStore) DeleteByTaskID(taskID int64) (int64, error)

+ func (s *AssetStore) DeleteTaskInterceptRule(taskID, ruleID int64) (bool, error)

+ func (s *AssetStore) DeleteTaskScope(taskID, scopeID int64) (bool, error)

+ func (s *AssetStore) DetachAssetFromTask(taskID, assetID int64) (bool, error)

+ func (s *AssetStore) GetByIDs(ids []int64) ([]*Asset, error)

+ func (s *AssetStore) GetByIDsInScope(taskID int64, ids []int64) ([]*Asset, error)

+ func (s *AssetStore) HostsByTask(taskID int64) ([]string, error)

+ func (s *AssetStore) HostsByTaskWithSources(taskID int64) ([]string, error)

+ func (s *AssetStore) HostsForTaskDeletion(taskID, explorationID int64) ([]string, error)

+ func (s *AssetStore) IntentAssets(taskID int64) ([]IntentAsset, error)

+ func (s *AssetStore) ListAssetInterceptRules() ([]AssetInterceptRule, error)

+ func (s *AssetStore) ListTaskInterceptRules(taskID int64) ([]AssetInterceptRule, error)

+ func (s *AssetStore) ListTaskScope(taskID int64) ([]TaskScope, error)

+ func (s *AssetStore) ListTaskScopeWithSources(taskID int64) ([]TaskScope, error)

+ func (s *AssetStore) ListUntestedAssets(taskID, expID int64, typ string, limit, offset int) ([]CoverageAsset, int, error)

+ func (s *AssetStore) ListUntestedAssetsWithSources(taskID int64, typ string, limit, offset int) ([]CoverageAsset, int, error)

+ func (s *AssetStore) QueryByCompany(companyID int64, typ string, limit, offset int) ([]*Asset, error)

+ func (s *AssetStore) QueryByTask(taskID int64, typ string, limit, offset int) ([]*Asset, error)

+ func (s *AssetStore) QueryByType(typ string, limit, offset int) ([]*Asset, error)

+ func (s *AssetStore) QueryDSL(dsl, typ string, taskID int64, limit, offset int) ([]*Asset, error)

+ func (s *AssetStore) QueryDSLInScope(dsl, typ string, taskID int64, limit, offset int) ([]*Asset, error)

+ func (s *AssetStore) RegisterTaskAssetScopes(taskID int64, inputs []ScopeInput) (TaskAssetScopeMutation, error)

+ func (s *AssetStore) SetTaskAssetSource(taskID, assetID int64, source, summary string, sourceNodeID *int64) error

+ func (s *AssetStore) TaskCoverage(taskID, expID int64) (*Coverage, error)

+ func (s *AssetStore) TaskCoverageWithSources(taskID int64) (*Coverage, error)

+ func (s *AssetStore) TaskInterceptRulesSplit(taskID int64) (block, allow []AssetInterceptRule, err error)

+ func (s *AssetStore) ToggleTaskInterceptRule(taskID, ruleID int64, enabled bool) error

+ func (s *AssetStore) UpdateTaskInterceptRule(taskID, ruleID int64, action, kind, pattern, note string, enabled bool) (AssetInterceptRule, error)

+ func (s *AssetStore) UpsertApp(req UpsertAppReq) (int64, error)

+ func (s *AssetStore) UpsertEndpoint(req UpsertEndpointReq) (int64, error)

+ func (s *AssetStore) UpsertHTTPService(req UpsertHTTPServiceReq) (int64, error)

+ func (s *AssetStore) UpsertIP(req UpsertIPReq) (int64, error)

+ func (s *AssetStore) UpsertOtherService(req UpsertOtherServiceReq) (int64, error)

+ func (s *AssetStore) UpsertRootDomain(req UpsertRootDomainReq) (int64, error)

+ func (s *AssetStore) UpsertSubdomain(req UpsertSubdomainReq) (id int64, err error)

+ type AuthItem struct

+ Description string

+ Password string

+ Token string

+ Type string

+ Username string

+ type ChatMention struct

+ Description string

+ ID int64

+ Kind string

+ Label string

+ type ChatMentionPage struct

+ Items []ChatMention

+ NextCursor string

+ type CommandRecord struct

+ Command string

+ CreatedAt time.Time

+ ExpID int64

+ ID int64

+ IsError bool

+ Output string

+ Tool string

+ Worker string

+ type Company struct

+ CreatedAt string

+ ID int64

+ Logo *string

+ NKey string

+ Name string

+ UpdatedAt string

+ type CompanyScopeValidationError struct

+ Message string

+ func (e *CompanyScopeValidationError) Error() string

+ type CompanyStore struct

+ func (s *CompanyStore) AddScope(companyID int64, lines []string, reason string) (added, skipped, invalid int, errors []string)

+ func (s *CompanyStore) AddScopeInputs(companyID int64, inputs []ScopeInput, reason string) (added, skipped, invalid int, errors []string)

+ func (s *CompanyStore) AddScopeInputsChecked(companyID int64, inputs []ScopeInput, reason string) (added, skipped, invalid int, validationErrors []string, err error)

+ func (s *CompanyStore) CreateCompanyWithScope(name, logo string, inputs []ScopeInput, reason string) (id int64, added, skipped, invalid int, validationErrors []string, err error)

+ func (s *CompanyStore) DeleteCompany(id int64) error

+ func (s *CompanyStore) DeleteCompanyWithAssets(id int64, deleteAssets bool) (assetsDeleted int64, err error)

+ func (s *CompanyStore) GetCompany(id int64) (*Company, error)

+ func (s *CompanyStore) GetCompanyByName(name string) (*Company, error)

+ func (s *CompanyStore) GetScope(companyID int64) ([]ScopeRule, error)

+ func (s *CompanyStore) ListCompanies() ([]*CompanyWithScope, error)

+ func (s *CompanyStore) MalformedIPAssetWarning() (string, error)

+ func (s *CompanyStore) RecomputeAttribution() error

+ func (s *CompanyStore) ResolveCompany(rootDomain, ipStr string) (*int64, error)

+ func (s *CompanyStore) ResolveCompanyWithICP(rootDomain, ipStr, icp string) (*int64, error)

+ func (s *CompanyStore) UpdateScope(companyID int64, lines []string, reason string) (added, invalid int, errs []string)

+ func (s *CompanyStore) UpdateScopeInputs(companyID int64, inputs []ScopeInput, reason string) (added, invalid int, errs []string)

+ func (s *CompanyStore) UpdateScopeInputsChecked(companyID int64, inputs []ScopeInput, reason string) (added, invalid int, validationErrors []string, err error)

+ func (s *CompanyStore) UpsertByName(name string) (int64, error)

+ func (s *CompanyStore) UpsertCompany(name, logo string) (id int64, created bool, err error)

+ type CompanyWithScope struct

+ AssetCount int

+ Scope []ScopeRule

+ type Constraint struct

+ CreatedAt time.Time

+ ID int64

+ Kind string

+ Origin string

+ Text string

+ type ConvTokenSummary struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ CreatedAt string

+ InputTokens int

+ LLMProfileID *int64

+ OutputTokens int

+ type Conversation struct

+ AgentKey string

+ CreatedAt time.Time

+ ID int64

+ LLMProfileID *int64

+ Pinned bool

+ PinnedAt *time.Time

+ Title string

+ UpdatedAt time.Time

+ type ConversationPatch struct

+ Pinned *bool

+ Title *string

+ type Coverage struct

+ ByType []CoverageByType

+ Denominator int

+ Enabled bool

+ Pct *float64

+ ScopeRows int

+ Tested int

+ type CoverageAsset struct

+ ID int64

+ Label string

+ Type string

+ type CoverageByType struct

+ Tested int

+ Total int

+ Type string

+ type CoverageGraphData struct

+ Edges []CoverageGraphEdge

+ Nodes []CoverageGraphNode

+ type CoverageGraphEdge struct

+ Dst string

+ Src string

+ type CoverageGraphNode struct

+ AppName string

+ AssetID int64

+ CompanyID int64

+ Domain string

+ IP string

+ InScope bool

+ Key string

+ Kind string

+ Label string

+ PageTitle string

+ Port int

+ RootDomain string

+ ServiceType string

+ StatusCode int

+ Tested bool

+ URL string

+ type DB struct

+ func Open(dsn string) (*DB, error)

+ func (d *DB) ActiveProfile() (*LLMProfile, error)

+ func (d *DB) AddAgentToToolBinding(agentKey string, keys []string) error

+ func (d *DB) AddFinding(taskID, nodeID int64, ...) (int64, error)

+ func (d *DB) AddNotificationEvent(ctx context.Context, kind string, findingID int64, snap notify.Snapshot) (int64, error)

+ func (d *DB) AgentBindingCounts() (mcp map[int64]int, skill map[int64]int, tools map[string]int, err error)

+ func (d *DB) AgentSkillNames(agentID int64) ([]string, error)

+ func (d *DB) AgentVisible(agentID int64, kind string) ([]int64, error)

+ func (d *DB) AppendConvActivity(convID int64, a Activity) (int64, error)

+ func (d *DB) AppendTaskArchiveWarning(id int64, warning string) error

+ func (d *DB) ArchivedAggregateStats() ([]json.RawMessage, error)

+ func (d *DB) Assets() *AssetStore

+ func (d *DB) BuildFindingAssetTree(f FindingFilter) (*FindingAssetTree, error)

+ func (d *DB) ClaimDigestBatch(ctx context.Context, channelID int64, limit int, lease time.Duration) ([]*NotificationDelivery, error)

+ func (d *DB) ClaimRealtimeDeliveries(ctx context.Context, channelID int64, limit int, lease time.Duration) ([]*NotificationDelivery, error)

+ func (d *DB) ClaimTaskArchiveJob(ctx context.Context) (*TaskArchive, error)

+ func (d *DB) ClearLLMHealth(profileID int64) error

+ func (d *DB) ClearSideHistory(ctx context.Context, key string) error

+ func (d *DB) Companies() *CompanyStore

+ func (d *DB) CompleteIntercept(id int64, runID, toolUseID, status, output string, truncated bool) error

+ func (d *DB) CompleteTaskArchive(archiveID int64, snapshot *TaskArchiveSnapshot, archivePath, sha256 string, ...) error

+ func (d *DB) CompleteTaskArchiveRestore(archiveID int64) error

+ func (d *DB) ConvActivityDetail(convID, id int64) (string, error)

+ func (d *DB) ConvActivityList(convID, sinceID int64, limit int) ([]Activity, int64, error)

+ func (d *DB) ConvActivityPage(convID, before int64, limit int) ([]Activity, bool, error)

+ func (d *DB) ConversationTokenSummaries() ([]ConvTokenSummary, error)

+ func (d *DB) CreateAgent(key, name, description string) (*Agent, error)

+ func (d *DB) CreateAssetInterceptRule(kind, pattern, note string, enabled bool) (AssetInterceptRule, error)

+ func (d *DB) CreateConversation(agentKey, title string, llmProfileID *int64) (*Conversation, error)

+ func (d *DB) CreateCustomTool(t *Tool) error

+ func (d *DB) CreateDecidedIntercept(ruleID, convID int64, taskID, agentName, toolName string, input []byte, ...) (int64, error)

+ func (d *DB) CreateExploration(description, goal string) (int64, error)

+ func (d *DB) CreateFindingRetest(ctx context.Context, findingID int64, notes string) (*FindingRetest, *Conversation, bool, error)

+ func (d *DB) CreateInterceptPending(ruleID, convID int64, taskID, agentName, toolName string, input []byte, ...) (int64, error)

+ func (d *DB) CreateInterceptRule(name, matchTarget, matchType, pattern, action, message string, priority int, ...) (InterceptRule, error)

+ func (d *DB) CreateTask(description, goal string, llmProfileID *int64, ...) (*Task, error)

+ func (d *DB) CreateTaskCategory(name string) (*TaskCategory, error)

+ func (d *DB) CreateTaskTemplate(in TaskTemplateInput) (*TaskTemplate, error)

+ func (d *DB) CreateTaskWithOptions(description, goal string, opts TaskCreateOptions) (*Task, error)

+ func (d *DB) CreateTrigger(t *AgentTrigger) (*AgentTrigger, error)

+ func (d *DB) CurrentPrompt(agentID int64) (string, error)

+ func (d *DB) CurrentSideRequest(ctx context.Context, key string) (*sidequestion.Exchange, error)

+ func (d *DB) DecideInterceptPending(id int64, status string) error

+ func (d *DB) DeferDeliveries(ctx context.Context, ids []int64, reason string) error

+ func (d *DB) DeleteAgent(key string) error

+ func (d *DB) DeleteAssetInterceptRule(id int64) error

+ func (d *DB) DeleteConversation(id int64) error

+ func (d *DB) DeleteConversations(ids []int64) ([]int64, error)

+ func (d *DB) DeleteCustomTool(key string) error

+ func (d *DB) DeleteFinding(id int64) (n int64, err error)

+ func (d *DB) DeleteFindingsByTask(taskID int64) (int64, error)

+ func (d *DB) DeleteInterceptRule(id int64) error

+ func (d *DB) DeleteLLMRecords(task string) (int64, error)

+ func (d *DB) DeleteMCP(id int64) error

+ func (d *DB) DeleteNotificationChannel(ctx context.Context, id int64) error

+ func (d *DB) DeleteProfile(id int64) error

+ func (d *DB) DeleteProfileContext(ctx context.Context, id int64) error

+ func (d *DB) DeleteSkillVisibility(skillName string) error

+ func (d *DB) DeleteTask(id int64) error

+ func (d *DB) DeleteTaskArchiveStub(archiveID int64) error

+ func (d *DB) DeleteTaskCascade(id int64, deleteAssets, deleteFindings bool, deleteLLMRecords ...bool) (TaskDeleteResult, error)

+ func (d *DB) DeleteTaskCascadePrepared(id int64, deleteAssets, deleteFindings, deleteLLMRecords bool, ...) (TaskDeleteResult, error)

+ func (d *DB) DeleteTaskCategory(id int64) (bool, error)

+ func (d *DB) DeleteTaskTemplate(id int64) (bool, error)

+ func (d *DB) DeleteTrigger(id int64) error

+ func (d *DB) DeleteTriggersForAgent(agentKey string) error

+ func (d *DB) Dequeue(id int64, clearMode bool) error

+ func (d *DB) DigestBatchDue(ctx context.Context, channelID int64, minAge time.Duration) (bool, error)

+ func (d *DB) EditFindingTraffic(ctx context.Context, findingID, bindingID, version int64, role, note *string, ...) error

+ func (d *DB) Enqueue(id int64, mode string) error

+ func (d *DB) EnsureLLMRecordsTable() error

+ func (d *DB) EnsureLLMUsageTable() error

+ func (d *DB) ExistingSideRequest(ctx context.Context, key, client string) (*sidequestion.Exchange, error)

+ func (d *DB) Exploration(id int64) *ExplorationStore

+ func (d *DB) ExplorationDiag(expID int64) (expExists bool, taskRefs int, maxExpID int64, err error)

+ func (d *DB) FailDeliveries(ctx context.Context, ids []int64, errMsg string) error

+ func (d *DB) FailPendingRetestForConversation(conversationID int64, reason string) error

+ func (d *DB) FailTaskArchiveJob(id int64, activeState string, cause error) error

+ func (d *DB) FanOutPendingEvents(ctx context.Context, limit int) (eventCount, deliveryCount int, err error)

+ func (d *DB) FindingIDByNodeID(nodeID int64) (id int64, err error)

+ func (d *DB) FindingMetaByNodeID(taskID int64) (map[int64]FindingMeta, error)

+ func (d *DB) FindingRetestForConversation(ctx context.Context, conversationID int64) (*FindingRetest, error)

+ func (d *DB) FindingStats() (*FindingStats, error)

+ func (d *DB) FinishFindingRetest(id int64, status, reason string) error

+ func (d *DB) GetAgentByKey(key string) (*Agent, error)

+ func (d *DB) GetBool(key string, def bool) bool

+ func (d *DB) GetConversation(id int64) (*Conversation, error)

+ func (d *DB) GetFinding(id int64) (*DBFinding, error)

+ func (d *DB) GetFindingTraffic(ctx context.Context, findingID int64) (out *FindingTraffic, err error)

+ func (d *DB) GetInterceptDetail(id int64) (*InterceptDetail, error)

+ func (d *DB) GetInterceptExecution(id int64) (*InterceptExecution, error)

+ func (d *DB) GetInterceptPending(id int64) (*InterceptPending, error)

+ func (d *DB) GetLLMRecord(id int64) (*LLMRecord, error)

+ func (d *DB) GetSchedState(key string) (string, error)

+ func (d *DB) GetSetting(key string) (value string, ok bool, err error)

+ func (d *DB) GetTask(id int64) (*Task, error)

+ func (d *DB) GetTaskArchive(id int64) (*TaskArchive, error)

+ func (d *DB) GetTaskArchiveByTask(taskID int64) (*TaskArchive, error)

+ func (d *DB) GetTaskCategory(id int64) (*TaskCategory, error)

+ func (d *DB) GetTaskTemplate(id int64) (*TaskTemplate, error)

+ func (d *DB) GetTool(key string) (*Tool, error)

+ func (d *DB) GoalCountsAll() (map[int64]GoalCounts, error)

+ func (d *DB) InsertLLMRecord(r *LLMRecord) error

+ func (d *DB) InsertLLMUsage(u *LLMUsage) error

+ func (d *DB) InsertLog(level, tag, text string) (int64, error)

+ func (d *DB) InsertSettingIfAbsent(key, value string) (inserted bool, err error)

+ func (d *DB) InsertSkillUsage(u *SkillUsage) error

+ func (d *DB) InsertToolUsage(u *ToolUsage) error

+ func (d *DB) InterruptSideRequests(ctx context.Context) error

+ func (d *DB) IsTaskArchiveRestored(id int64) (bool, error)

+ func (d *DB) JudgeUsageStats(days int) (JudgeUsage, error)

+ func (d *DB) LLMRetryPolicy() LLMRetryPolicy

+ func (d *DB) LLMTasks() ([]LLMTask, error)

+ func (d *DB) LastActivityAll() (map[int64]int64, error)

+ func (d *DB) ListActiveFindingRetests(ctx context.Context) ([]ActiveFindingRetest, error)

+ func (d *DB) ListAgents() ([]*Agent, error)

+ func (d *DB) ListAllIntercepts(limit int) ([]InterceptApprovalRow, error)

+ func (d *DB) ListAllInterceptsPage(page, size int, filter InterceptApprovalFilter) ([]InterceptApprovalRow, int, error)

+ func (d *DB) ListAssetInterceptRules() ([]AssetInterceptRule, error)

+ func (d *DB) ListCommands(expID *int64, q string, page, size int) ([]CommandRecord, int, error)

+ func (d *DB) ListConversations() ([]*Conversation, error)

+ func (d *DB) ListCustomTools() ([]*Tool, error)

+ func (d *DB) ListEnabledTriggers() ([]*AgentTrigger, error)

+ func (d *DB) ListFindingGroups(f FindingFilter, page, pageSize int) ([]FindingGroup, int, int, error)

+ func (d *DB) ListFindingRetests(findingID int64) ([]*FindingRetest, error)

+ func (d *DB) ListFindings(limit int) ([]*DBFinding, error)

+ func (d *DB) ListFindingsForExport(f FindingFilter, ids []int64) ([]*DBFinding, error)

+ func (d *DB) ListFindingsPage(f FindingFilter, page, pageSize int) ([]*DBFinding, int, error)

+ func (d *DB) ListInterceptRules() ([]InterceptRule, error)

+ func (d *DB) ListLLMRecords(model, session, task string, page, size int) ([]LLMRecord, int, error)

+ func (d *DB) ListLogsBefore(beforeID int64, limit int) ([]*DBLog, error)

+ func (d *DB) ListMCP() ([]*MCPServer, error)

+ func (d *DB) ListNotificationChannels(ctx context.Context) ([]*NotificationChannel, error)

+ func (d *DB) ListNotificationDeliveries(ctx context.Context, f NotificationDeliveryFilter, page, pageSize int) ([]*NotificationDelivery, int, error)

+ func (d *DB) ListPendingIntercepts() ([]InterceptPending, error)

+ func (d *DB) ListProfiles() ([]*LLMProfile, error)

+ func (d *DB) ListPromptVersions(agentID int64) ([]PromptVersion, error)

+ func (d *DB) ListTaskArchives(search, state string, page, size int) (TaskArchivePage, error)

+ func (d *DB) ListTaskCategories() ([]*TaskCategory, error)

+ func (d *DB) ListTaskIntercepts(taskID string) ([]InterceptApprovalRow, error)

+ func (d *DB) ListTaskInterceptsPage(taskID string, page, size int, filter InterceptApprovalFilter) ([]InterceptApprovalRow, int, error)

+ func (d *DB) ListTaskTemplates() ([]*TaskTemplate, error)

+ func (d *DB) ListTasks() ([]*Task, error)

+ func (d *DB) ListTools() ([]*Tool, error)

+ func (d *DB) ListTriggersFor(agentKey string) ([]*AgentTrigger, error)

+ func (d *DB) LoadLLMHealth() ([]LLMHealth, error)

+ func (d *DB) MCPToolNames(serverID int64) ([]string, error)

+ func (d *DB) MCPToolsDetailed(serverID int64) ([]MCPTool, error)

+ func (d *DB) MarkDeliveriesSent(ctx context.Context, ids []int64) error

+ func (d *DB) MarkTaskLLMProfileQuotaExhausted(taskID, profileID int64, reason string) (TaskLLMTransition, error)

+ func (d *DB) MarkTaskLLMProfileQuotaExhaustedAtRevision(taskID, profileID, revision int64, reason string) (TaskLLMTransition, error)

+ func (d *DB) MetGoals() ([]TaskEvent, error)

+ func (d *DB) MissingSkillStats(limit int) ([]SkillStat, error)

+ func (d *DB) NewFindingsSince(lastID int64) ([]TaskEvent, error)

+ func (d *DB) NewTasksSince(lastID int64) ([]TaskEvent, error)

+ func (d *DB) NewToolCallsSince(lastID int64) ([]TaskEvent, error)

+ func (d *DB) NotificationAssetNames(ctx context.Context, ids []int64) ([]string, error)

+ func (d *DB) NotificationChannelByID(ctx context.Context, id int64) (*NotificationChannel, error)

+ func (d *DB) NotificationStatsSnapshot(ctx context.Context) (*NotificationStats, error)

+ func (d *DB) PatchTaskTemplate(id int64, patch TaskTemplatePatch) (*TaskTemplate, error)

+ func (d *DB) PoolProfiles() ([]*LLMProfile, error)

+ func (d *DB) ProfileByID(id int64) (*LLMProfile, error)

+ func (d *DB) PromptVars(agentID int64) ([]PromptVar, error)

+ func (d *DB) QueueTaskArchive(taskID int64) (*TaskArchive, error)

+ func (d *DB) QueueTaskArchiveDelete(id int64) (*TaskArchive, error)

+ func (d *DB) QueueTaskArchiveRestore(id int64) (*TaskArchive, error)

+ func (d *DB) RecentLogs(limit int) ([]*DBLog, error)

+ func (d *DB) RecentSkillCalls(skill string, limit int) ([]SkillCall, error)

+ func (d *DB) RecordFindingRetestResult(ctx context.Context, conversationID int64, verdict, summary, evidence string) error

+ func (d *DB) RecoverFindingRetests() error

+ func (d *DB) RecoverTaskArchiveJobs() error

+ func (d *DB) RefreshToolDefaults(key, desc string, schema json.RawMessage) error

+ func (d *DB) RemoveAgentFromTool(agentKey, toolKey string) error

+ func (d *DB) RemoveAgentFromToolBindings(agentKey string) error

+ func (d *DB) RenameConversation(id int64, title string) error

+ func (d *DB) RenameTaskCategory(id int64, name string) (*TaskCategory, error)

+ func (d *DB) ReplaceTaskLLMProfiles(taskID int64, profileIDs []int64, activeProfileID int64) error

+ func (d *DB) RescheduleDeliveries(ctx context.Context, ids []int64, delay time.Duration, errMsg string) error

+ func (d *DB) ResetPromptToDefault(agentID int64, tmpl string) (int, error)

+ func (d *DB) ResolveIntercept(id int64, status, action, reason string) (bool, error)

+ func (d *DB) ResourceAgents(kind string, resourceID int64) ([]int64, error)

+ func (d *DB) RestoreTaskArchive(archiveID int64, snapshot *TaskArchiveSnapshot, remainingTimeoutSeconds int64) ([]string, error)

+ func (d *DB) RestoreTaskArchiveWithLLMRecords(archiveID int64, snapshot *TaskArchiveSnapshot, remainingTimeoutSeconds int64, ...) ([]string, error)

+ func (d *DB) RetryNotificationDelivery(ctx context.Context, id int64) error

+ func (d *DB) SaveLLMHealth(h LLMHealth) error

+ func (d *DB) SaveMCP(m *MCPServer) (int64, error)

+ func (d *DB) SaveMCPTools(serverID int64, tools []MCPTool) error

+ func (d *DB) SaveNotificationChannel(ctx context.Context, c *NotificationChannel) (int64, error)

+ func (d *DB) SaveProfile(p *LLMProfile) (int64, error)

+ func (d *DB) SavePrompt(agentID int64, template, note, by string) (int, error)

+ func (d *DB) SaveSideMemory(ctx context.Context, e sidequestion.Exchange, memory sidequestion.Memory) error

+ func (d *DB) SaveSideSnapshot(ctx context.Context, s sidequestion.Snapshot) error

+ func (d *DB) SearchChatMentions(ctx context.Context, kind, query string) ([]ChatMention, error)

+ func (d *DB) SearchChatMentionsPage(ctx context.Context, kind, query, cursor string) (ChatMentionPage, error)

+ func (d *DB) SeedPromptIfEmpty(agentID int64, tmpl string) error

+ func (d *DB) SeedTool(key, desc string, schema, agents json.RawMessage) error

+ func (d *DB) SetActiveProfile(id int64) error

+ func (d *DB) SetAgentInteractiveShell(key string, on bool) error

+ func (d *DB) SetAgentLLMProfile(key string, id *int64) error

+ func (d *DB) SetAgentMaxTurns(key string, maxTurns int) error

+ func (d *DB) SetAgentRunSeconds(key string, runSecs int) error

+ func (d *DB) SetAgentSkillVisibility(agentID int64, names []string) error

+ func (d *DB) SetAgentTaskTimeoutWrapup(key, prompt string, maxTurns int) error

+ func (d *DB) SetAgentTriggerBehavior(key, runMode, mergeMode string, maxParallel int) error

+ func (d *DB) SetAgentVisibilityKind(agentID int64, kind string, resourceIDs []int64) error

+ func (d *DB) SetAgentWebSearch(key string, on bool) error

+ func (d *DB) SetAgentWrapupMaxTurns(key string, n int) error

+ func (d *DB) SetAgentWrapupPrompt(key, prompt string) error

+ func (d *DB) SetBool(key string, val bool) error

+ func (d *DB) SetFindingName(id int64, name string) (int64, error)

+ func (d *DB) SetFindingReportByNodeID(nodeID int64, report string) (int64, error)

+ func (d *DB) SetFindingReportVersionByNodeID(ctx context.Context, nodeID int64, report string, version *int64) (n int64, err error)

+ func (d *DB) SetFindingSeverity(id int64, severity string) (int64, error)

+ func (d *DB) SetFindingStatus(id int64, status string) (int64, error)

+ func (d *DB) SetFindingStatusWithNotify(ctx context.Context, id int64, status string) (from string, found bool, notified bool, err error)

+ func (d *DB) SetFindingVulnClass(id int64, vulnclass string) (int64, error)

+ func (d *DB) SetLLMRetryPolicy(p LLMRetryPolicy) error

+ func (d *DB) SetNotificationChannelEnabled(ctx context.Context, id int64, enabled bool) error

+ func (d *DB) SetParentRef(id int64, parentRef string) error

+ func (d *DB) SetPaused(id int64, paused bool) error

+ func (d *DB) SetQueued(id int64, queued bool) error

+ func (d *DB) SetSchedState(key, value string) error

+ func (d *DB) SetSetting(key, value string) error

+ func (d *DB) SetStatus(id int64, status string) error

+ func (d *DB) SetTaskCategory(taskID int64, categoryID *int64) (*TaskCategory, error)

+ func (d *DB) SetTasksCategory(taskIDs []int64, categoryID *int64) ([]int64, *TaskCategory, error)

+ func (d *DB) SetTerminalStatusGuarded(id int64, status string) (won bool, err error)

+ func (d *DB) SideHistory(ctx context.Context, key string, before int64, limit int) ([]sidequestion.Exchange, error)

+ func (d *DB) SideMemory(ctx context.Context, e sidequestion.Exchange) (sidequestion.Memory, error)

+ func (d *DB) SideReplay(ctx context.Context, key string) ([]sidequestion.Exchange, error)

+ func (d *DB) SideReplayPage(ctx context.Context, e sidequestion.Exchange, after int64) ([]sidequestion.Exchange, error)

+ func (d *DB) SideRequest(ctx context.Context, id string) (*sidequestion.Exchange, error)

+ func (d *DB) SideSnapshot(ctx context.Context, key string) (*sidequestion.Snapshot, error)

+ func (d *DB) SkillAgents(skillName string) ([]int64, error)

+ func (d *DB) SkillCallsByTask(taskID int64) ([]SkillStat, error)

+ func (d *DB) SkillStats() ([]SkillStat, error)

+ func (d *DB) SnapshotTaskArchive(taskID int64) (*TaskArchiveSnapshot, error)

+ func (d *DB) SnapshotTaskArchiveWithLLMRecords(taskID int64, llmRecords io.Writer) (*TaskArchiveSnapshot, error)

+ func (d *DB) StampFirstRun(id int64, timeoutSeconds int) (*time.Time, error)

+ func (d *DB) StartFindingRetest(ctx context.Context, id int64) (bool, error)

+ func (d *DB) StartSideRequest(ctx context.Context, s sidequestion.Snapshot, clientID, question string) (*sidequestion.Exchange, bool, error)

+ func (d *DB) TaskArchiveBlockers() (map[int64]int64, error)

+ func (d *DB) TaskCompanyIDs(taskID int64) ([]int64, error)

+ func (d *DB) TaskLLMProfiles(taskID int64) ([]TaskLLMProfile, error)

+ func (d *DB) TaskListMetricsAll() (map[int64]TaskListMetrics, error)

+ func (d *DB) TaskSourceIDs(taskID int64) ([]int64, error)

+ func (d *DB) TaskSources(taskID int64) ([]TaskSource, error)

+ func (d *DB) TimedOutTasksSince(lastID int64) ([]TaskEvent, error)

+ func (d *DB) ToggleAssetInterceptRule(id int64, enabled bool) error

+ func (d *DB) ToggleInterceptRule(id int64, enabled bool) error

+ func (d *DB) ToggleSkillVisibility(agentID int64, skillName string, on bool) error

+ func (d *DB) ToggleVisibility(agentID int64, kind string, resourceID int64, on bool) error

+ func (d *DB) TokenByModel(taskID string) ([]ModelTokenStat, error)

+ func (d *DB) TokenDailyAll(days int) ([]DailyTokenBucket, error)

+ func (d *DB) TokenTotalsAll() (map[int64]TokenUsage, error)

+ func (d *DB) ToolStats(expID *int64, q string) ([]ToolStat, error)

+ func (d *DB) ToolUsageCounts() (map[string]int, error)

+ func (d *DB) TouchConversation(id int64) error

+ func (d *DB) TouchTriggerFire(id int64) error

+ func (d *DB) UpdateAgentMeta(key, name, description string) error

+ func (d *DB) UpdateAssetInterceptRule(id int64, kind, pattern, note string, enabled bool) (AssetInterceptRule, error)

+ func (d *DB) UpdateConversation(id int64, patch ConversationPatch) (*Conversation, error)

+ func (d *DB) UpdateConversationProfile(id int64, llmProfileID *int64) error

+ func (d *DB) UpdateCustomTool(t *Tool) error

+ func (d *DB) UpdateInterceptRule(id int64, name, matchTarget, matchType, pattern, action, message string, ...) (InterceptRule, error)

+ func (d *DB) UpdateSideRequest(ctx context.Context, e sidequestion.Exchange) (bool, error)

+ func (d *DB) UpdateTask(id int64, patch TaskPatch) (*Task, error)

+ func (d *DB) UpdateTaskArchiveProgress(id int64, phase string, progress int) error

+ func (d *DB) UpdateTaskTemplate(id int64, in TaskTemplateInput) (*TaskTemplate, error)

+ func (d *DB) UpdateTool(key, desc string, schema, agents json.RawMessage, enabled bool) error

+ func (d *DB) UpdateTrigger(t *AgentTrigger) error

+ func (d *DB) UpsertToolForce(key, desc string, schema, agents json.RawMessage) error

+ func (d *DB) UsageByProfile() ([]ProfileUsage, error)

+ func (d *DB) UsageDaily(days int) ([]ProfileDayUsage, error)

+ func (d *DB) WithEvidenceTx(ctx context.Context, fn func(*sql.Tx) error) error

+ type DBFinding struct

+ AssetIDs []int64

+ CreatedAt time.Time

+ Evidence string

+ EvidenceVersion int64

+ ID int64

+ Name string

+ NodeID *int64

+ Report string

+ ReportEvidenceVersion int64

+ Severity string

+ Status string

+ Summary string

+ TaskDescription string

+ TaskID *int64

+ TrafficBindings []FindingTrafficBinding

+ TrafficCount int

+ VulnClass string

+ Worker string

+ type DBLog struct

+ CreatedAt time.Time

+ ID int64

+ Level string

+ Tag string

+ Text string

+ type DailyTokenBucket struct

+ CacheReadTokens int

+ Day string

+ InputTokens int

+ OutputTokens int

+ type DirectSourceStore struct

+ Store *ExplorationStore

+ Task TaskSource

+ type Edge struct

+ From int64

+ Rel string

+ To int64

+ type ExplorationStore struct

+ func (s *ExplorationStore) ActiveDigests() ([]*Node, error)

+ func (s *ExplorationStore) ActivityByIDs(ids []int64) ([]Activity, error)

+ func (s *ExplorationStore) ActivityByIDsForTerminalIntents(ids []int64) ([]Activity, error)

+ func (s *ExplorationStore) ActivityByIDsWithSources(ids []int64) ([]Activity, error)

+ func (s *ExplorationStore) ActivityDetail(id int64) (string, error)

+ func (s *ExplorationStore) ActivityDetailWithSources(id int64) (string, error)

+ func (s *ExplorationStore) ActivityList(nodeID *int64, sinceID int64, limit int) ([]Activity, int64, error)

+ func (s *ExplorationStore) ActivityListForTerminalIntent(nodeID, sinceID int64, limit int) ([]Activity, int64, error)

+ func (s *ExplorationStore) ActivityListWithSources(nodeID, sinceID int64, limit int) ([]Activity, int64, error)

+ func (s *ExplorationStore) ActivityMaxID() (int64, error)

+ func (s *ExplorationStore) ActivityPage(f ActivitySessionFilter, before int64, limit int) ([]Activity, bool, error)

+ func (s *ExplorationStore) ActivityPageForTerminalIntent(nodeID, before int64, limit int) ([]Activity, bool, error)

+ func (s *ExplorationStore) ActivityTrace(nodeID int64, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceForTerminalIntent(nodeID int64, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceSearch(nodeID *int64, q string, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceSearchAllWithSources(excludeNodeID int64, q string, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceSearchExcluding(excludeNodeID int64, q string, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceSearchForTerminalIntent(nodeID int64, q string, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceSearchTerminalIntents(q string, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceSearchWithSources(nodeID int64, q string, limit int) ([]Activity, error)

+ func (s *ExplorationStore) ActivityTraceWithSources(nodeID int64, limit int) ([]Activity, error)

+ func (s *ExplorationStore) AddConstraint(kind, text, origin string) (int64, error)

+ func (s *ExplorationStore) AddDigest(payload map[string]any, memberIDs []int64) (int64, error)

+ func (s *ExplorationStore) AddFindingFollowUpIntent(findingID, findingNodeID int64, description string, audit Activity) (int64, Activity, error)

+ func (s *ExplorationStore) AddGoal(payload map[string]any, origin string) (int64, error)

+ func (s *ExplorationStore) AddIntent(payload map[string]any, priority int, anchors []int64, origin string) (int64, error)

+ func (s *ExplorationStore) AddNode(kind string, payload map[string]any, priority int, state, origin string, ...) (int64, error)

+ func (s *ExplorationStore) AddStandaloneFinding(taskID, nodeID int64, ...) (int64, error)

+ func (s *ExplorationStore) Anchor(nodeID, assetID int64) error

+ func (s *ExplorationStore) AppendActivity(a Activity) (int64, error)

+ func (s *ExplorationStore) ApplyStampOps(ops []StampOp) error

+ func (s *ExplorationStore) AssetRefs(assetID int64) ([]AssetRef, error)

+ func (s *ExplorationStore) AssetRefsWithSources(assetID int64) ([]AssetRef, error)

+ func (s *ExplorationStore) BumpRound() (int64, error)

+ func (s *ExplorationStore) CancelIntent(id int64) (IntentCleanup, error)

+ func (s *ExplorationStore) ClaimIntent(id int64, owner string) (bool, error)

+ func (s *ExplorationStore) ColdStamps() (map[int64]*int64, error)

+ func (s *ExplorationStore) CompareAndSetIntentState(id int64, expected, state string) (bool, error)

+ func (s *ExplorationStore) ContentVersions() (map[int64]int, error)

+ func (s *ExplorationStore) CountFinishedIntents() (int, error)

+ func (s *ExplorationStore) CountOpenIntents() (int, error)

+ func (s *ExplorationStore) CoveredMembers() (map[int64]int64, error)

+ func (s *ExplorationStore) CurrentMainSeg() (int, error)

+ func (s *ExplorationStore) DeleteConstraint(id int64) error

+ func (s *ExplorationStore) DeleteGoal(id int64) error

+ func (s *ExplorationStore) DigestMembers(digestID int64) ([]int64, error)

+ func (s *ExplorationStore) DirectSourceStores() ([]DirectSourceStore, error)

+ func (s *ExplorationStore) DiscardOpenIntent(id int64) error

+ func (s *ExplorationStore) Edges(limit int) ([]Edge, error)

+ func (s *ExplorationStore) EdgesTouching(ids []int64) ([]Edge, error)

+ func (s *ExplorationStore) FactsYielded(intentID int64) ([]int64, error)

+ func (s *ExplorationStore) FindingIntents() (map[int64]int64, error)

+ func (s *ExplorationStore) FindingIntentsTerminal() (map[int64]int64, error)

+ func (s *ExplorationStore) FindingIntentsWithSources() (map[int64]int64, error)

+ func (s *ExplorationStore) FindingLineage(nodeID int64) ([]*Node, []Edge, error)

+ func (s *ExplorationStore) Frontier(limit int) ([]*Node, error)

+ func (s *ExplorationStore) GetNode(id int64) (*Node, error)

+ func (s *ExplorationStore) GetNodeWithSources(id int64) (*Node, error)

+ func (s *ExplorationStore) HasActiveIntent() (bool, error)

+ func (s *ExplorationStore) HasOpenGoal() (bool, error)

+ func (s *ExplorationStore) ID() int64

+ func (s *ExplorationStore) Link(from int64, rel string, to int64) error

+ func (s *ExplorationStore) ListByKind(kind string, limit int) ([]*Node, error)

+ func (s *ExplorationStore) ListByKindPage(kind string, before int64, limit int) ([]*Node, bool, error)

+ func (s *ExplorationStore) ListByKindPageWithSources(kind string, before int64, limit int, q string) (nodes []*Node, hasMore bool, total int, err error)

+ func (s *ExplorationStore) ListByKindWithSources(kind string, limit int) ([]*Node, error)

+ func (s *ExplorationStore) ListConstraints() ([]Constraint, error)

+ func (s *ExplorationStore) ListMainSessions() ([]MainSession, error)

+ func (s *ExplorationStore) NewMainSession() (MainSession, error)

+ func (s *ExplorationStore) NodeAssets(ids []int64) (map[int64][]int64, error)

+ func (s *ExplorationStore) Nodes(limit int) ([]*Node, error)

+ func (s *ExplorationStore) NodesByIDs(ids []int64) ([]*Node, error)

+ func (s *ExplorationStore) NodesPage(f NodeFilter, page, size int) ([]*Node, int, error)

+ func (s *ExplorationStore) OriginFactID() (int64, error)

+ func (s *ExplorationStore) PopulateFindingTrafficIDs(nodes []*Node) error

+ func (s *ExplorationStore) RecordFinding(ctx context.Context, in RecordFindingInput) (out *RecordedFinding, err error)

+ func (s *ExplorationStore) ReopenBlockedIntents() (int64, error)

+ func (s *ExplorationStore) ReopenIntent(id int64) (bool, error)

+ func (s *ExplorationStore) ReopenIntentsByBlockedReason(reason string) (int64, error)

+ func (s *ExplorationStore) ResetRunningIntents() (int64, error)

+ func (s *ExplorationStore) Root() (description, goal string, err error)

+ func (s *ExplorationStore) RoundNo() (int64, error)

+ func (s *ExplorationStore) SetIntentBlockedReason(id int64, reason string) error

+ func (s *ExplorationStore) SetIntentState(id int64, state string) error

+ func (s *ExplorationStore) SetNodeState(id int64, state string) error

+ func (s *ExplorationStore) SoftDeleteIntent(id int64, reason string) (string, error)

+ func (s *ExplorationStore) Stats() (map[string]int, error)

+ func (s *ExplorationStore) SupersedeDigests(ids []int64) error

+ func (s *ExplorationStore) TaskID() (int64, error)

+ func (s *ExplorationStore) TokenStatsBySession() ([]SessionTokenUsage, error)

+ func (s *ExplorationStore) TokenStatsByWorker() ([]TokenUsage, error)

+ func (s *ExplorationStore) TokenTotal() (TokenUsage, error)

+ func (s *ExplorationStore) UpdateConstraint(id int64, kind, text string) error

+ func (s *ExplorationStore) UpdateGoalPayload(id int64, text, vulnclass string) error

+ type Expr struct

+ Field string

+ Op string

+ Value string

+ type FindingAssetNode struct

+ AssetID int64

+ CompanyID int64

+ Critical int

+ High int

+ Key string

+ Kind string

+ Label string

+ LastFoundAt time.Time

+ Low int

+ Medium int

+ Parent string

+ Self int

+ Total int

+ type FindingAssetTree struct

+ DroppedKinds []string

+ FindingTotal int

+ Nodes []FindingAssetNode

+ Truncated bool

+ type FindingFilter struct

+ AssetScope string

+ Query string

+ Severity string

+ Sort string

+ Status string

+ TaskID string

+ VulnClass string

+ type FindingGroup struct

+ Count int

+ Critical int

+ High int

+ LastFoundAt time.Time

+ Low int

+ Medium int

+ TaskDescription string

+ TaskID *int64

+ TaskName string

+ TaskStatus string

+ type FindingMeta struct

+ AssetIDs []int64

+ ID int64

+ Status string

+ TrafficCount int

+ type FindingRetest struct

+ ConversationID *int64

+ CreatedAt time.Time

+ Error string

+ Evidence string

+ FindingID int64

+ FinishedAt *time.Time

+ ID int64

+ Notes string

+ Snapshot json.RawMessage

+ StartedAt *time.Time

+ Status string

+ Summary string

+ Verdict string

+ func (r *FindingRetest) InitialMessage() string

+ type FindingSeverityCounts struct

+ Critical int

+ High int

+ Low int

+ Medium int

+ type FindingStats struct

+ Critical int

+ High int

+ Low int

+ Medium int

+ Pending int

+ Tasks []FindingTaskOption

+ Total int

+ VulnClasses []string

+ type FindingTaskOption struct

+ Count int

+ Description string

+ ID int64

+ Name string

+ type FindingTraffic struct

+ Bindings []FindingTrafficBinding

+ FindingID int64

+ ReportVersion int64

+ Version int64

+ func FindingTrafficTx(tx *sql.Tx, findingID int64) (*FindingTraffic, error)

+ type FindingTrafficBinding struct

+ CreatedAt time.Time

+ FindingID int64

+ ID int64

+ Note string

+ Position int

+ Role string

+ Snapshot TrafficEvidenceSnapshot

+ SnapshotID string

+ type GoalCounts struct

+ Met int

+ Total int

+ type IntentAsset struct

+ AssetID int64

+ Inherited bool

+ IntentID int64

+ Label string

+ Source string

+ SourceNodeID *int64

+ SourceSummary string

+ SourceTaskID int64

+ Type string

+ type IntentCleanup struct

+ Activities int64

+ Facts int64

+ Findings int64

+ Intents int64

+ type InterceptApprovalFilter struct

+ DecisionSource string

+ Status string

+ type InterceptApprovalRow struct

+ ConvAgentKey string

+ ConvTitle string

+ RuleName string

+ type InterceptAudit struct

+ CapturedAt time.Time

+ ConfigDigest string

+ Context []InterceptContextEntry

+ ContextTruncated bool

+ Correlation string

+ DecisionReason string

+ EffectiveAction string

+ ExecutionEndedAt *time.Time

+ ExecutionStatus string

+ InitialAction string

+ InitialReason string

+ InputDigest string

+ ModelFallback bool

+ ModelInput json.RawMessage

+ ModelInputDigest string

+ Output string

+ OutputTruncated bool

+ ProfileID int64

+ RuleName string

+ RunID string

+ ToolUseID string

+ UserMessage string

+ UserTruncated bool

+ type InterceptContextEntry struct

+ IsError bool

+ Kind string

+ Text string

+ Tool string

+ ToolUseID string

+ Truncated bool

+ type InterceptDetail struct

+ Audit *InterceptAudit

+ type InterceptExecution struct

+ ConversationID *int64

+ Items []Activity

+ Seq int64

+ Session string

+ TaskID *string

+ type InterceptPending struct

+ AgentName string

+ ConversationID *int64

+ CreatedAt time.Time

+ DecidedAt *time.Time

+ DecisionSource string

+ ID int64

+ Reason string

+ RuleID *int64

+ Status string

+ TaskID *string

+ ToolInput json.RawMessage

+ ToolName string

+ type InterceptRule struct

+ Action string

+ CreatedAt time.Time

+ Enabled bool

+ ID int64

+ MatchTarget string

+ MatchType string

+ Message string

+ Name string

+ Pattern string

+ Priority int

+ TimeoutAction string

+ TimeoutEnabled bool

+ TimeoutSeconds int

+ UpdatedAt time.Time

+ type JudgeDayUsage struct

+ Calls int

+ Date string

+ InputTokens int

+ OutputTokens int

+ type JudgeUsage struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ Calls int

+ Daily []JudgeDayUsage

+ InputTokens int

+ OutputTokens int

+ type LLMHealth struct

+ Fails int

+ LastAt time.Time

+ LastError string

+ OpenUntil *time.Time

+ ProfileID int64

+ Trips int

+ type LLMProfile struct

+ APIKey string

+ APIKeyHint string

+ BaseURL string

+ ContextWindowK int

+ Format string

+ ID int64

+ IsDefault bool

+ MaxTokens int

+ MaxTokensField string

+ Model string

+ Name string

+ PoolExclude bool

+ Priority int

+ Proxy string

+ RatePerMinute float64

+ RatePerSecond float64

+ ReasoningEffort string

+ Retry RetryOverride

+ SessionHeaderKey string

+ Streaming bool

+ ThinkingType string

+ type LLMRecord struct

+ CacheRead int

+ CacheWrite int

+ Error string

+ ID int64

+ InputTokens int

+ LatencyMs int

+ Model string

+ OutputTokens int

+ ProfileName string

+ RawRequest string

+ RawResponse string

+ RequestBody string

+ ResponseBody string

+ SessionID string

+ Status string

+ TaskID string

+ Ts time.Time

+ Worker string

+ type LLMRetryPolicy struct

+ Breaker RetryRule

+ Connect RetryRule

+ Empty RetryRule

+ Intent RetryRule

+ Stream RetryRule

+ func (p LLMRetryPolicy) Clamped() LLMRetryPolicy

+ type LLMTask struct

+ Count int

+ TaskID string

+ type LLMUsage struct

+ CacheRead int

+ CacheWrite int

+ ExplorationID int64

+ InputTokens int

+ LatencyMs int

+ Model string

+ OutputTokens int

+ ProfileName string

+ Status string

+ TaskID string

+ Worker string

+ type MCPServer struct

+ Args json.RawMessage

+ Command string

+ Enabled bool

+ Env json.RawMessage

+ ID int64

+ Insecure bool

+ Name string

+ Tools []string

+ Transport string

+ URL string

+ type MCPTool struct

+ Description string

+ Name string

+ type MainSession struct

+ CreatedAt time.Time

+ Seq int

+ type ModelTokenStat struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ Calls int

+ InputTokens int

+ Model string

+ OutputTokens int

+ type Node struct

+ Anchors []int64

+ BlockedReason string

+ CreatedAt time.Time

+ DeleteReason string

+ FindingID int64

+ FindingNodeID int64

+ ID int64

+ Inherited bool

+ Kind string

+ Origin string

+ Owner string

+ Payload json.RawMessage

+ Priority int

+ SourceTaskID int64

+ State string

+ TrafficCount int

+ type NodeFilter struct

+ Asc bool

+ Kinds []string

+ Query string

+ States []string

+ type NotificationChannel struct

+ Config json.RawMessage

+ CreatedAt time.Time

+ Enabled *bool

+ Filter json.RawMessage

+ ID int64

+ Kind string

+ Mode string

+ Name string

+ RatePerMin int

+ UpdatedAt time.Time

+ func (c *NotificationChannel) IsEnabled() bool

+ type NotificationDelivery struct

+ Attempts int

+ BatchID *int64

+ Channel *NotificationChannel

+ ChannelID int64

+ ChannelKind string

+ ChannelName string

+ CreatedAt time.Time

+ EventID int64

+ EventKind string

+ FindingID int64

+ ID int64

+ LastError string

+ NextAttemptAt time.Time

+ SentAt *time.Time

+ Snapshot json.RawMessage

+ State string

+ type NotificationDeliveryFilter struct

+ ChannelID int64

+ EventKind string

+ State string

+ type NotificationEvent struct

+ CreatedAt time.Time

+ FindingID int64

+ ID int64

+ Kind string

+ Snapshot json.RawMessage

+ type NotificationStats struct

+ BacklogAgeMS int64

+ Channels int

+ ChannelsOn int

+ Failed int

+ Pending int

+ SentToday int

+ type ParamItem struct

+ Location string

+ Name string

+ Type string

+ Value string

+ type ParsedScope struct

+ Domain string

+ Kind string

+ Net string

+ Raw string

+ Value string

+ func ParseAutoScopeLine(line string) (ParsedScope, error)

+ func ParseScopeInput(input ScopeInput) (ParsedScope, error)

+ func ParseScopeLine(line string) (ParsedScope, error)

+ type PortService struct

+ Port int

+ Service string

+ type PreparedTrafficEvidence struct

+ Ref TrafficRef

+ Snapshot TrafficEvidenceSnapshot

+ type ProfileDayUsage struct

+ CacheReadTokens int

+ Date string

+ InputTokens int

+ OutputTokens int

+ ProfileName string

+ type ProfileUsage struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ Calls int

+ InputTokens int

+ OutputTokens int

+ ProfileName string

+ Tasks int

+ type PromptVar struct

+ Description string

+ Example string

+ Name string

+ Source string

+ type PromptVersion struct

+ CreatedAt time.Time

+ Note string

+ Template string

+ Version int

+ type RecordFindingInput struct

+ AssetIDs []int64

+ Evidence string

+ ExplorationID int64

+ IntentID int64

+ Name string

+ Severity string

+ Summary string

+ TaskID int64

+ VulnClass string

+ Worker string

+ type RecordedFinding struct

+ FindingID int64

+ NodeID int64

+ Traffic *FindingTraffic

+ func RecordFindingTx(ctx context.Context, tx *sql.Tx, in RecordFindingInput, ...) (*RecordedFinding, error)

+ type RetryOverride struct

+ Connect RetryRule

+ Empty RetryRule

+ Stream RetryRule

+ func (o RetryOverride) Clamped() RetryOverride

+ type RetryRule struct

+ Attempts int

+ IntervalMS int

+ func (r RetryRule) Clamped() RetryRule

+ func (r RetryRule) Interval() time.Duration

+ func (r RetryRule) Or(fallback RetryRule) RetryRule

+ type ScopeInput struct

+ Kind string

+ Value string

+ type ScopeRule struct

+ CompanyID int64

+ Domain string

+ ID int64

+ Kind string

+ Net string

+ Raw string

+ Reason string

+ Value string

+ type SessionTokenUsage struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ InputTokens int

+ OutputTokens int

+ Session string

+ type SkillCall struct

+ AgentKey string

+ ArgsLen int

+ SessionID string

+ TS time.Time

+ TaskID int64

+ type SkillStat struct

+ Agents []string

+ Calls int

+ LastUsed *time.Time

+ Skill string

+ Tasks int

+ type SkillUsage struct

+ AgentKey string

+ ArgsLen int

+ ExplorationID int64

+ Found bool

+ IntentID int64

+ SessionID string

+ Skill string

+ TaskID int64

+ type StampOp struct

+ ID int64

+ Round int64

+ Set bool

+ type Task struct

+ ActiveLLMProfileID *int64

+ CategoryID *int64

+ CategoryName string

+ CompanyIDs []int64

+ CompletedAt *time.Time

+ CoverageEnabled bool

+ CreatedAt time.Time

+ DeadlineAt *time.Time

+ Description string

+ ExplorationID int64

+ FirstRunAt *time.Time

+ Goal string

+ ID int64

+ LLMChainRevision int64

+ LLMFailoverReason string

+ LLMFailoverState string

+ LLMProfileID *int64

+ LLMProfileIDs []int64

+ Name string

+ ParentRef string

+ Paused bool

+ Pinned bool

+ PinnedAt *time.Time

+ PlanHeartbeatSeconds int

+ QueueMode string

+ Queued bool

+ QueuedAt *time.Time

+ SourceTaskIDs []int64

+ Status string

+ TimeoutSeconds int

+ type TaskArchive struct

+ AggregateStats json.RawMessage

+ ArchivePath string

+ ArchivedAt *time.Time

+ CategoryIDSnapshot *int64

+ CategoryNameSnapshot string

+ CompressedSize int64

+ CreatedAt time.Time

+ DataCounts json.RawMessage

+ Error string

+ FormatVersion int

+ ID int64

+ OriginalSize int64

+ OriginalStatus string

+ Phase string

+ Progress int

+ RemainingTimeoutSeconds int64

+ RequestedAt time.Time

+ SHA256 string

+ SourceTaskIDs []int64

+ State string

+ TaskDescription string

+ TaskGoal string

+ TaskID int64

+ TaskName string

+ UpdatedAt time.Time

+ Warnings json.RawMessage

+ type TaskArchivePage struct

+ Items []TaskArchive

+ Page int

+ Size int

+ Total int

+ type TaskArchiveSnapshot struct

+ AggregateStats map[string]any

+ CreatedAt time.Time

+ DataCounts map[string]int64

+ ExclusiveAssetIDs []int64

+ ExclusiveHosts []string

+ ExplorationID int64

+ FormatVersion int

+ Hosts []string

+ SourceTaskIDs []int64

+ StreamedTables map[string]string

+ Tables map[string]json.RawMessage

+ TaskID int64

+ type TaskAssetMutation struct

+ Attached int

+ Existing int

+ Requested int

+ type TaskAssetScopeMutation struct

+ AssetsExisting int

+ AssetsLinked int

+ Requested int

+ ScopesAdded int

+ ScopesExisting int

+ type TaskCategory struct

+ CreatedAt time.Time

+ ID int64

+ NKey string

+ Name string

+ TaskCount int

+ UpdatedAt time.Time

+ type TaskCreateOptions struct

+ CategoryID *int64

+ CompanyIDs []int64

+ CoverageEnabled *bool

+ InterceptRules []TaskInterceptRuleInput

+ LLMProfileIDs []int64

+ Name string

+ PlanHeartbeatSeconds int

+ SourceTaskIDs []int64

+ TimeoutSeconds int

+ type TaskDeletePreparation struct

+ ExplorationID int64

+ TrafficHosts []string

+ type TaskDeleteResult struct

+ AssetsDeleted int64

+ AssetsDetached int64

+ FindingsDeleted int64

+ LLMRecordsDeleted int64

+ type TaskEvent struct

+ NodeID int64

+ Severity string

+ Summary string

+ TaskDesc string

+ TaskGoal string

+ TaskID int64

+ Tool string

+ ToolInput string

+ ToolIsErr bool

+ ToolOutput string

+ VulnClass string

+ type TaskInterceptRuleInput struct

+ Action string

+ Enabled bool

+ Kind string

+ Note string

+ Pattern string

+ type TaskLLMProfile struct

+ ExhaustedAt *time.Time

+ LastError string

+ Position int

+ ProfileID int64

+ Status string

+ type TaskLLMTransition struct

+ Advanced bool

+ ChainExhausted bool

+ NextProfileID *int64

+ PreviousProfileID int64

+ Stale bool

+ type TaskListMetrics struct

+ Findings FindingSeverityCounts

+ Goals GoalCounts

+ LastActivity int64

+ RunningIntents int

+ Tokens TokenUsage

+ type TaskPatch struct

+ Name *string

+ Pinned *bool

+ type TaskScope struct

+ CompanyID *int64

+ CompanyName string

+ Domain string

+ ID int64

+ Kind string

+ Net string

+ Reason string

+ Source string

+ TaskID int64

+ Value string

+ type TaskSource struct

+ Description string

+ ExplorationID int64

+ Goal string

+ Status string

+ TaskID int64

+ type TaskTemplate struct

+ CategoryID *int64

+ CreatedAt time.Time

+ Description string

+ Goal string

+ ID int64

+ InterceptRules []TaskInterceptRuleInput

+ NKey string

+ Name string

+ UpdatedAt time.Time

+ type TaskTemplateInput struct

+ CategoryID *int64

+ Description string

+ Goal string

+ InterceptRules []TaskInterceptRuleInput

+ Name string

+ type TaskTemplatePatch struct

+ CategoryID *int64

+ Description *string

+ Goal *string

+ InterceptRules []TaskInterceptRuleInput

+ Name *string

+ SetCategoryID bool

+ SetInterceptRules bool

+ type TokenUsage struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ InputTokens int

+ OutputTokens int

+ Worker string

+ type Tool struct

+ Agents []string

+ Calls int

+ Deferred bool

+ Description string

+ Enabled bool

+ Exec json.RawMessage

+ Key string

+ Kind string

+ Schema json.RawMessage

+ System bool

+ type ToolStat struct

+ Errors int

+ Tool string

+ Total int

+ type ToolUsage struct

+ AgentKey string

+ ExplorationID int64

+ IntentID int64

+ SessionID string

+ TaskID int64

+ ToolKey string

+ type TrafficEvidenceSnapshot struct

+ CapturedAt int64

+ ContentType string

+ CreatedAt time.Time

+ ID string

+ Method string

+ ReqHash string

+ ReqHead string

+ ReqLen int64

+ RespHash string

+ RespHead string

+ RespLen int64

+ SourceTrafficID string

+ Status int

+ URL string

+ func ArchiveEvidenceSnapshots(snapshot *TaskArchiveSnapshot) ([]TrafficEvidenceSnapshot, error)

+ func (s TrafficEvidenceSnapshot) Normalize() TrafficEvidenceSnapshot

+ type TrafficRef struct

+ Note string

+ Role string

+ TrafficID string

+ func NormalizeTrafficRefs(refs []TrafficRef) ([]TrafficRef, error)

+ type UpsertAppReq struct

+ BundleID string

+ Category string

+ CompanyID *int64

+ Description string

+ ICP string

+ Name string

+ TaskID int64

+ type UpsertEndpointReq struct

+ IP string

+ Method string

+ Params []map[string]any

+ TaskID int64

+ URL string

+ type UpsertHTTPServiceReq struct

+ Auth []map[string]any

+ ContentLength *int64

+ FaviconMMH3 string

+ IP string

+ PageTitle string

+ StatusCode *int

+ TaskID int64

+ Technologies []string

+ URL string

+ type UpsertIPReq struct

+ BoundDomains []string

+ IP string

+ OpenPorts []PortService

+ TaskID int64

+ type UpsertOtherServiceReq struct

+ Auth []map[string]any

+ Domain string

+ IP string

+ Port int

+ ServiceName string

+ TaskID int64

+ type UpsertRootDomainReq struct

+ Domain string

+ ICP string

+ TaskID int64

+ type UpsertSubdomainReq struct

+ Domain string

+ ICP string

+ RecordType string

+ RecordValue []string

+ TaskID int64

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