store

package

Go to main page

Versions in this module

v0

v0.4.11

Aug 11, 2026

Changes in this version

+ func PlanTokenRollups(ctx context.Context, db *sql.DB) (map[PlanRef]PlanTokenRollup, error)

+ func SessionsWithArtifacts(ctx context.Context, db *sql.DB) (map[string]struct{}, error)

+ type PlanRef struct

+ Project string

+ Slug string

+ type PlanTokenRollup struct

+ Sessions int

+ Shared int

+ Tokens int

+ Unreported int

type WindowVitals

+ InjectedTokens int

v0.4.10

Aug 8, 2026

Changes in this version

+ const EventMilestoneReached

+ const MilestoneRecallAnsweredThreshold

+ const PlanFinishLinePct

+ const ProposalHidden

+ const ProposalMergePlans

+ const ProposalRelocate

+ const SettingCaptureStreak

+ const SettingFeaturesConfig

+ const SettingGamificationRecords

+ const SettingProjectStages

+ const StageDeepRootedMinAgeDays

+ const StageDeepRootedMinEvents

+ const StageDeepRootedMinMemories

+ const StageDeepRootedMinReachPct

+ const StageEstablishedMinAgeDays

+ const StageEstablishedMinEvents

+ const StageEstablishedMinMemories

+ const StageSproutingMinAgeDays

+ const StageSproutingMinEvents

+ const StageSproutingMinMemories

+ var ErrIsolationHasChildren = errors.New("project has child projects")

+ var ErrIsolationStandalone = errors.New("isolation requires a standalone project")

+ var ErrNotATighten = errors.New("not a tighten")

+ var ErrProjectNotFound = errors.New("project not found")

+ var MilestoneMemoryWrittenThresholds = []int

+ func CanRead(ctx context.Context, db *sql.DB, callerProject, targetProject string) (bool, error)

+ func CanWrite(ctx context.Context, db *sql.DB, callerProject, targetProject string) (bool, error)

+ func CaptureStreak(ctx context.Context, db *sql.DB, now time.Time) (current, longest int, err error)

+ func CheckMilestones(ctx context.Context, db *sql.DB, rec OnceRecorder, base config.Features, ...) error

+ func ClearFeaturesConfig(ctx context.Context, db *sql.DB) error

+ func CountMemoriesUnsurfacedSince(ctx context.Context, db *sql.DB, cutoff time.Time) (int, error)

+ func EvaluateGamificationRecords(ctx context.Context, db *sql.DB, today DayCounts, liveAgents int, ...) (GamificationRecords, []RecordCrossing, error)

+ func FeaturesConfig(ctx context.Context, db *sql.DB, base config.Features) (cfg config.Features, overridden bool, err error)

+ func GlobalMemoriesFromProjectSessions(ctx context.Context, db *sql.DB, project string) ([]core.Memory, error)

+ func IsolationOf(ctx context.Context, db *sql.DB, slug string) (core.Isolation, error)

+ func LiveSessionCount(ctx context.Context, db *sql.DB, cutoff time.Time) (int, error)

+ func PriorWindow(w RetrievalWindow, now time.Time) (since, until time.Time, ok bool)

+ func ProposalKeyBlocks(ctx context.Context, db *sql.DB) (map[string]ProposalBlock, error)

+ func SetFeaturesConfig(ctx context.Context, db *sql.DB, f config.Features) error

+ func SetProjectIsolation(ctx context.Context, db *sql.DB, slug string, state core.Isolation) error

+ func UnhideProposal(ctx context.Context, db *sql.DB, id string) error

+ type DayCounts struct

+ MemoriesWritten int

+ NotesWritten int

+ PlansTouched int

+ Sessions int

+ TasksClosed int

+ func GamificationDayCounts(ctx context.Context, db *sql.DB, from, to time.Time) (DayCounts, error)

+ type FinishLinePlan struct

+ Project string

+ Remaining []string

+ func FinishLinePlans(ctx context.Context, db *sql.DB) ([]FinishLinePlan, error)

+ type GamificationRecords struct

+ LiveAgents RecordMark

+ MemoriesDay RecordMark

+ TasksDay RecordMark

+ type IsolationTightenEffects struct

+ Children []string

+ Families []string

+ From core.Isolation

+ Parent string

+ Project string

+ To core.Isolation

+ func PreviewIsolationTighten(ctx context.Context, db *sql.DB, slug string, state core.Isolation) (IsolationTightenEffects, error)

+ func TightenProjectIsolation(ctx context.Context, db *sql.DB, slug string, state core.Isolation, ...) (IsolationTightenEffects, error)

+ func (e IsolationTightenEffects) Blocked() bool

+ func (e IsolationTightenEffects) DetachesTopology() bool

+ type OnceRecorder interface

+ RecordOnce func(ctx context.Context, e core.Event) (id string, recorded bool, err error)

type PlanRollup

+ func (p PlanRollup) AtFinishLine() bool

+ func (p PlanRollup) FinishLinePhrase() string

+ func (p PlanRollup) StepsLeft() int

+ type PlanShippedRef struct

+ Project string

+ Slug string

+ func PlansShippedSince(ctx context.Context, db *sql.DB, since time.Time) ([]PlanShippedRef, error)

+ type ProjectIsolation struct

+ Slug string

+ State core.Isolation

+ func IsolatedSlugs(ctx context.Context, db *sql.DB, slugs []string) ([]ProjectIsolation, error)

+ type ProjectPlan struct

+ Project string

+ func AllPlanRollups(ctx context.Context, db *sql.DB) ([]ProjectPlan, error)

+ type ProjectStage string

+ const StageDeepRooted

+ const StageEstablished

+ const StageSeedling

+ const StageSprouting

+ func ComputeStage(in StageInputs, now time.Time) ProjectStage

+ func (s ProjectStage) Rank() int

+ type ProjectStageInfo struct

+ Inputs StageInputs

+ Since time.Time

+ Stage ProjectStage

type Proposal

+ func HiddenProposals(ctx context.Context, db *sql.DB) ([]Proposal, error)

+ type ProposalBlock struct

+ DismissedAt time.Time

+ Hard bool

+ type RecordCrossing struct

+ Key string

+ Label string

+ N int

+ Prev int

+ type RecordMark struct

+ Day string

+ N int

type RetrievalReport

+ SessionTrend []TrendBucket

+ SurfacedTrend []TrendBucket

+ type SpotlightMemory struct

+ Injects int

+ ItemID string

+ Kind string

+ Name string

+ Project string

+ Readers int

+ Reads int

+ Utility float64

+ func MemorySpotlight(ctx context.Context, db *sql.DB, since, now time.Time) (SpotlightMemory, bool, error)

+ type StageCrossing struct

+ From ProjectStage

+ Project string

+ To ProjectStage

+ func EvaluateProjectStages(ctx context.Context, db *sql.DB, rows []ProjectBoardRow, now time.Time) (map[string]ProjectStageInfo, []StageCrossing, error)

+ type StageInputs struct

+ CreatedAt time.Time

+ Events int

+ HasReach bool

+ Memories int

+ ReachRate int

+ func (in StageInputs) AgeDays(now time.Time) int

+ type WindowVitals struct

+ ActiveMemories int

+ CovTotal int

+ Coverage int

+ Covered int

+ Injections int

+ MemoriesSurfaced int

+ ReachRate int

+ SessionsReached int

+ func GetWindowVitals(ctx context.Context, db *sql.DB, since, until time.Time) (WindowVitals, error)

+ func GetWindowVitalsForProject(ctx context.Context, db *sql.DB, project string, since, until time.Time) (WindowVitals, error)

v0.4.9

Jul 31, 2026

Changes in this version

+ const DefaultTrialQueryLimit

+ const MaxTrialQueryLimit

+ var ErrInvalidTrialQueryLimit = errors.New("invalid trial query limit")

+ func IdentifierMatchPriority(kind IdentifierMatchKind) int

+ type IdentifierMatchKind string

+ const IdentifierMatchExactID

+ const IdentifierMatchExactIdentifier

+ const IdentifierMatchIDPrefix

+ const IdentifierMatchIdentifier

+ func IDIdentifierMatch(query, id string) IdentifierMatchKind

+ func NaturalIdentifierMatch(query, identifier string) IdentifierMatchKind

+ type KnowledgeIdentifierHit struct

+ ItemID string

+ Kind string

+ Match IdentifierMatchKind

+ Updated time.Time

+ func SearchKnowledgeIdentifiersSince(ctx context.Context, db *sql.DB, query string, kinds, projects []string, ...) ([]KnowledgeIdentifierHit, error)

type PlanRollup

+ func PlanRollupsForProject(ctx context.Context, db *sql.DB, project string) ([]PlanRollup, error)

v0.4.8

Jul 30, 2026

v0.4.7

Jul 29, 2026

v0.4.6

Jul 29, 2026

Changes in this version

+ const ProposalShipPlan

+ func RecordProposalResult(ctx context.Context, db *sql.DB, id string, result map[string]any) error

+ func ReopenProposal(ctx context.Context, db *sql.DB, id string) error

type Proposal

+ Result map[string]any

+ func RecentResolvedProposals(ctx context.Context, db *sql.DB, limit int) ([]Proposal, error)

+ type RepoMapAdoption struct

+ NewPath string

+ OldPaths []string

+ Slug string

v0.4.5

Jul 26, 2026

Changes in this version

type PlanRollup

+ LastActivity time.Time

v0.4.4

Jul 24, 2026

Changes in this version

+ const DefaultFunnelFollow

+ const ProposalRekind

+ var InjectionSurfaces = []string

+ func RecentMishapItemIDs(ctx context.Context, db *sql.DB, project string, window time.Duration) (map[string]time.Time, error)

+ type SurfaceFunnel struct

+ Injections int

+ Items int

+ ItemsRead int

+ ReadRate int

+ Surface string

+ func ReadAfterInjectFunnel(ctx context.Context, db *sql.DB, since time.Time, follow time.Duration) ([]SurfaceFunnel, error)

v0.4.3

Jul 22, 2026

v0.4.2

Jul 22, 2026

Changes in this version

+ const ProposalToolError

+ type AgentError struct

+ Args map[string]any

+ Error string

+ Key string

+ Project string

+ SessionID string

+ Surface string

+ TS time.Time

+ func HookErrorsSince(ctx context.Context, db *sql.DB, since time.Time) ([]AgentError, error)

+ func ToolErrorsSince(ctx context.Context, db *sql.DB, since time.Time) ([]AgentError, error)

v0.4.1

Jul 21, 2026

Changes in this version

+ const EmbedderModeAuto

+ const EmbedderModeOff

+ const ProposalMemoryWanted

+ const SettingEmbedderMode

+ const SettingUtilityActivation

+ const UtilityReadyMinAgeDays

+ const UtilityReadyMinEvents

+ const UtilityReadyMinMemories

+ const UtilityReadyWindow

+ func BriefingExposureSince(ctx context.Context, db *sql.DB, since time.Time) (map[string]int, error)

+ func DemandItemIDsSince(ctx context.Context, db *sql.DB, since time.Time) (map[string]struct{}, error)

+ func EmbedderMode(ctx context.Context, db *sql.DB) (string, error)

+ func SetEmbedderMode(ctx context.Context, db *sql.DB, mode string) error

+ func SetUtilityActivation(ctx context.Context, db *sql.DB, a UtilityActivation) error

+ func UtilityDemandByProject(ctx context.Context, db *sql.DB, now time.Time, window time.Duration) (map[string]UtilityProjectDemand, error)

+ func UtilityScores(ctx context.Context, db *sql.DB) (map[string]float64, error)

+ type EmbeddingModelStat struct

+ Count int

+ Dims int

+ Memories int

+ Model string

+ Notes int

+ Updated time.Time

+ type EmbeddingStats struct

+ ActiveMemories int

+ Missing int

+ Models []EmbeddingModelStat

+ Notes int

+ Total int

+ func GetEmbeddingStats(ctx context.Context, db *sql.DB) (EmbeddingStats, error)

+ type NamedScore struct

+ ID string

+ Name string

+ Score float64

type ProjectReach

+ Created int

+ Retired int

+ type RecallHitQuery struct

+ Project string

+ Query string

+ func RecallHitQueriesSince(ctx context.Context, db *sql.DB, since time.Time) ([]RecallHitQuery, error)

+ type RecallMiss struct

+ Project string

+ Query string

+ SessionID string

+ TS time.Time

+ func RecallMissesSince(ctx context.Context, db *sql.DB, since time.Time) ([]RecallMiss, error)

type RetrievalReport

+ BriefingSurfaced int

+ CreatedInWindow int

+ DeadWeight []MemoryStat

+ DemandRate int

+ DemandedOfSurfaced int

+ MissRate int

+ PromptMatches int

+ RecallMisses int

+ RetiredInWindow int

+ ToolMisses int

+ WasteShare int

type RetrievalStat

+ Components UtilityComponents

+ Utility float64

type SearchHit

+ func FTSSearchAllTerms(ctx context.Context, db *sql.DB, terms []string, kinds, projects []string, ...) ([]SearchHit, error)

+ type UtilityActivation struct

+ Projects map[string]UtilityProjectState

+ func GetUtilityActivation(ctx context.Context, db *sql.DB) (UtilityActivation, error)

+ func (a UtilityActivation) Active(project, mode string) bool

+ type UtilityComponents struct

+ Prompt float64

+ Read float64

+ Recall float64

+ func (c UtilityComponents) IsZero() bool

+ type UtilityProjectDemand struct

+ Earliest time.Time

+ RecentEvents int

+ RecentMemories int

+ func (d UtilityProjectDemand) Ready(now time.Time) bool

+ type UtilityProjectState struct

+ Forced string

+ ReadyAt *time.Time

v0.4.0

Jul 21, 2026

Changes in this version

+ func SetProjectFavorite(ctx context.Context, db *sql.DB, slug string, favorite bool) error

+ func SetSessionFavorite(ctx context.Context, db *sql.DB, id string, favorite bool) error

+ func SetTaskFavorite(ctx context.Context, db *sql.DB, id string, favorite bool) error

+ func SetTrialFavorite(ctx context.Context, db *sql.DB, id string, favorite bool) error

type PlanSearchRow

+ Favorite bool

v0.3.9

Jul 21, 2026

Changes in this version

+ var ErrFamilyExists = errors.New("store: project family already exists")

+ var ErrFamilyNoMembers = errors.New("store: project family has no members")

+ func SaveProjectFamily(ctx context.Context, db *sql.DB, previousName, name string, members []string) ([]string, error)

+ func SearchProjectsSince(ctx context.Context, db *sql.DB, q string, since time.Time, limit int) ([]core.Project, error)

+ func SearchSessionsSince(ctx context.Context, db *sql.DB, q string, since time.Time, limit int) ([]core.Session, error)

+ func SearchTasksSince(ctx context.Context, db *sql.DB, q string, since time.Time, limit int) ([]core.Task, error)

+ func SearchTrials(ctx context.Context, db *sql.DB, q string, limit int) ([]core.Trial, error)

+ func SearchTrialsSince(ctx context.Context, db *sql.DB, q string, since time.Time, limit int) ([]core.Trial, error)

+ func SetAmbientSessionTokens(ctx context.Context, db *sql.DB, externalClient, externalSessionID string, ...) (bool, error)

+ func TrialByID(ctx context.Context, db *sql.DB, id string) (core.Trial, bool, error)

+ type LabSummary struct

+ Fail int

+ FirstAt time.Time

+ Inconclusive int

+ Lab string

+ LastAt time.Time

+ Other int

+ Partial int

+ Pass int

+ Projects []string

+ Sessions int

+ Trials int

+ func ListLabs(ctx context.Context, db *sql.DB) ([]LabSummary, error)

type NavCounts

+ Labs int

+ Trials int

type PlanSearchRow

+ func SearchPlansSince(ctx context.Context, db *sql.DB, q string, since time.Time, limit int) ([]PlanSearchRow, error)

type ProjectBoardRow

+ TokensTotal int

type RetrievalReport

+ InjectedTokens int

type SearchHit

+ func CosineSearchSince(ctx context.Context, db *sql.DB, query []float32, model string, ...) ([]SearchHit, error)

+ func FTSSearchSince(ctx context.Context, db *sql.DB, query string, kinds, projects []string, ...) ([]SearchHit, error)

type SnippetHit

+ func FTSSearchSnippetsSince(ctx context.Context, db *sql.DB, query string, kinds, projects []string, ...) ([]SnippetHit, error)

type TrialFilter

+ SessionID string

v0.3.8

Jul 20, 2026

v0.3.7

Jul 20, 2026

Changes in this version

+ var ErrSessionIdentityExists = errors.New("store: ambient session identity already exists")

+ func ActiveSessionsByExternalIdentity(ctx context.Context, db *sql.DB, externalClient, externalSessionID string) ([]core.Session, error)

+ func AmbientSessionByExternalIdentity(ctx context.Context, db *sql.DB, externalClient, externalSessionID string) (core.Session, bool, error)

+ func LooksLikeSessionULID(s string) bool

+ func ReactivateAmbientSession(ctx context.Context, db *sql.DB, ...) (core.Session, bool, error)

+ func SetAmbientSessionModel(ctx context.Context, db *sql.DB, ...) error

+ func SetSessionModel(ctx context.Context, db *sql.DB, id, model string) error

+ func TouchAmbientSession(ctx context.Context, db *sql.DB, externalClient, externalSessionID string, ...) error

+ func UpdateAmbientFindings(ctx context.Context, db *sql.DB, ...) (bool, error)

v0.3.6

Jul 19, 2026

Changes in this version

type TrendBucket

+ func ProjectRetrievalTrend(ctx context.Context, db *sql.DB, w RetrievalWindow, project string) ([]TrendBucket, error)

v0.3.5

Jul 19, 2026

v0.3.4

Jul 18, 2026

v0.3.3

Jul 18, 2026

Changes in this version

+ func UpdateAmbientFindingsByName(ctx context.Context, db *sql.DB, name, findings string, now time.Time) (bool, error)

v0.3.2

Jul 17, 2026

v0.3.1

Jul 17, 2026

v0.3.0

Jul 16, 2026

Changes in this version

+ const ProposalAbandonPlan

+ const ProposalApplied

+ const ProposalArchive

+ const ProposalConsolidate

+ const ProposalDigest

+ const ProposalDismissed

+ const ProposalMerge

+ const ProposalPending

+ const ProposalReproject

+ const ProposalSplit

+ const SettingBriefingConfig

+ const SettingProjectFamilies

+ const SettingRepoProjectMap

+ const SnippetEndMark

+ const SnippetStartMark

+ var ErrFamilyNotFound = errors.New("store: project family not found")

+ var ErrSessionNameExists = errors.New("store: session name already exists")

+ var ErrSlugExists = errors.New("store: project slug already exists")

+ var ErrTaskBlocked = errors.New("task blocked")

+ var ErrTaskClaimConflict = errors.New("task already claimed")

+ var ErrTaskClosed = errors.New("task closed")

+ var ErrTaskCycle = errors.New("dependency would create a cycle")

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

+ var ProposalKinds = []string

+ var RetrievalWindowKeys = []string

+ func ActiveAmbientByCWD(ctx context.Context, db *sql.DB, cwd string) ([]core.Session, error)

+ func ActiveAmbientProjects(ctx context.Context, db *sql.DB, within time.Duration) ([]string, error)

+ func ActiveAmbientSessionsForProject(ctx context.Context, db *sql.DB, project string, within time.Duration) ([]core.Session, error)

+ func ActiveMemories(ctx context.Context, db *sql.DB, project string) ([]core.Memory, error)

+ func ActiveMemoriesForProjects(ctx context.Context, db *sql.DB, slugs []string) ([]core.Memory, error)

+ func ActiveMemoriesForScope(ctx context.Context, db *sql.DB, project string, extra []string) ([]core.Memory, error)

+ func ActiveSessionIDs(ctx context.Context, db *sql.DB, ids []string) (map[string]bool, error)

+ func ActiveSessionsByClaudeID(ctx context.Context, db *sql.DB, claudeSessionID string) ([]core.Session, error)

+ func AddFamilyMembers(ctx context.Context, db *sql.DB, family string, slugs []string) ([]string, error)

+ func AddRepoMapping(ctx context.Context, db *sql.DB, repoPath, slug string) error

+ func AllActiveMemories(ctx context.Context, db *sql.DB) ([]core.Memory, error)

+ func AllMemoriesIncludingInvalid(ctx context.Context, db *sql.DB) ([]core.Memory, error)

+ func AllProposalKeys(ctx context.Context, db *sql.DB) (map[string]struct{}, error)

+ func AllReadyTasks(ctx context.Context, db *sql.DB) ([]core.Task, error)

+ func AllRetrievalStats(ctx context.Context, db *sql.DB) (map[string]RetrievalStat, error)

+ func AllTasksByStatus(ctx context.Context, db *sql.DB, status core.TaskStatus) ([]core.Task, error)

+ func BriefingConfig(ctx context.Context, db *sql.DB, base config.Briefing) (cfg config.Briefing, overridden bool, err error)

+ func ClearBriefingConfig(ctx context.Context, db *sql.DB) error

+ func CompletedSessionsSince(ctx context.Context, db *sql.DB, since time.Time) ([]core.Session, error)

+ func Cosine(a, b []float32) float64

+ func CreateProject(ctx context.Context, db *sql.DB, p core.Project) error

+ func CreateSession(ctx context.Context, db *sql.DB, s core.Session) error

+ func CreateTask(ctx context.Context, db *sql.DB, t core.Task) error

+ func CreateTrial(ctx context.Context, db *sql.DB, tr core.Trial) error

+ func DecodeVector(b []byte) []float32

+ func DeleteSetting(ctx context.Context, db *sql.DB, key string) error

+ func DistinctPlanSlugsForProject(ctx context.Context, db *sql.DB, project string) ([]string, error)

+ func EncodeVector(vec []float32) []byte

+ func EnsureProject(ctx context.Context, db *sql.DB, slug, name string) (core.Project, error)

+ func ExpireStaleSessions(ctx context.Context, db *sql.DB, cutoff time.Time) ([]core.Session, error)

+ func ForceReleaseTask(ctx context.Context, db *sql.DB, id string, now time.Time) (core.Task, error)

+ func GetSetting(ctx context.Context, db *sql.DB, key string) (string, bool, error)

+ func LatestActiveAmbientSessionForProject(ctx context.Context, db *sql.DB, project string, within time.Duration) (core.Session, bool, error)

+ func ListNotes(ctx context.Context, db *sql.DB) ([]core.Note, error)

+ func ListProjects(ctx context.Context, db *sql.DB) ([]core.Project, error)

+ func ListSessions(ctx context.Context, db *sql.DB, status core.SessionStatus, since time.Time, ...) ([]core.Session, error)

+ func ListSessionsForProject(ctx context.Context, db *sql.DB, project string, status core.SessionStatus, ...) ([]core.Session, error)

+ func ListTasks(ctx context.Context, db *sql.DB, project string, status core.TaskStatus) ([]core.Task, error)

+ func ListTasksForPlan(ctx context.Context, db *sql.DB, project string, status core.TaskStatus, ...) ([]core.Task, error)

+ func MemoriesByIDs(ctx context.Context, db *sql.DB, ids []string) (map[string]core.Memory, error)

+ func MemoriesForSession(ctx context.Context, db *sql.DB, sessionName string) ([]core.Memory, error)

+ func MemoriesSuperseding(ctx context.Context, db *sql.DB, id string) ([]core.Memory, error)

+ func MemoryByID(ctx context.Context, db *sql.DB, id string) (core.Memory, bool, error)

+ func MemoryByName(ctx context.Context, db *sql.DB, project, name string) (core.Memory, bool, error)

+ func MemoryByNameIncludingInvalid(ctx context.Context, db *sql.DB, project, name string) (core.Memory, bool, error)

+ func NoteByID(ctx context.Context, db *sql.DB, id string) (core.Note, bool, error)

+ func NoteBySlug(ctx context.Context, db *sql.DB, project, slug string) (core.Note, bool, error)

+ func NotesByIDs(ctx context.Context, db *sql.DB, ids []string) (map[string]core.Note, error)

+ func NotesByTag(ctx context.Context, db *sql.DB, project, tag string) ([]core.Note, error)

+ func NotesByTagPrefix(ctx context.Context, db *sql.DB, project, prefix string) ([]core.Note, error)

+ func Open(dbPath string) (*sql.DB, error)

+ func ProjectBySlug(ctx context.Context, db *sql.DB, slug string) (core.Project, bool, error)

+ func ProjectFamilies(ctx context.Context, db *sql.DB) (map[string][]string, error)

+ func ProjectMemoriesIncludingInvalid(ctx context.Context, db *sql.DB, project string) ([]core.Memory, error)

+ func ProjectsByParent(ctx context.Context, db *sql.DB, parent string) ([]core.Project, error)

+ func QueryTrials(ctx context.Context, db *sql.DB, f TrialFilter) ([]core.Trial, error)

+ func ReactivateSessionByName(ctx context.Context, db *sql.DB, name, project string, now time.Time) (bool, error)

+ func ReadyTasks(ctx context.Context, db *sql.DB, project string) ([]core.Task, error)

+ func ReadyTasksForPlan(ctx context.Context, db *sql.DB, project, plan string) ([]core.Task, error)

+ func RebuildRetrievalStats(ctx context.Context, db *sql.DB) error

+ func RecentFindings(ctx context.Context, db *sql.DB, project string, limit int) ([]core.Session, error)

+ func RegisterProjectForCWD(ctx context.Context, db *sql.DB, cwd string) (string, error)

+ func ReleaseClaimsForSession(ctx context.Context, db *sql.DB, sessionID string, now time.Time) (int, error)

+ func ReleaseTask(ctx context.Context, db *sql.DB, id, sessionID string, now time.Time) (core.Task, error)

+ func RemoveFamilyMembers(ctx context.Context, db *sql.DB, family string, slugs []string) ([]string, error)

+ func RepoProjectMap(ctx context.Context, db *sql.DB) (map[string]string, error)

+ func ResolveProjectForCWD(ctx context.Context, db *sql.DB, cwd string) (string, error)

+ func ResolveProposal(ctx context.Context, db *sql.DB, id, status string, at time.Time) error

+ func RetireProject(ctx context.Context, db *sql.DB, slug string, at time.Time) error

+ func SchemaVersion(db *sql.DB) (int, error)

+ func SearchProjects(ctx context.Context, db *sql.DB, q string, limit int) ([]core.Project, error)

+ func SearchSessions(ctx context.Context, db *sql.DB, q string, limit int) ([]core.Session, error)

+ func SearchTasks(ctx context.Context, db *sql.DB, q string, limit int) ([]core.Task, error)

+ func SessionByID(ctx context.Context, db *sql.DB, id string) (core.Session, bool, error)

+ func SessionByName(ctx context.Context, db *sql.DB, name string) (core.Session, bool, error)

+ func SetBriefingConfig(ctx context.Context, db *sql.DB, b config.Briefing) error

+ func SetProjectFamilies(ctx context.Context, db *sql.DB, families map[string][]string) error

+ func SetProjectParent(ctx context.Context, db *sql.DB, slug, parent string, now time.Time) error

+ func SetSetting(ctx context.Context, db *sql.DB, key, value string) error

+ func SiblingFindings(ctx context.Context, db *sql.DB, slugs []string, limit int) ([]core.Session, error)

+ func SiblingProjects(ctx context.Context, db *sql.DB, project string) ([]string, error)

+ func StaleMemories(ctx context.Context, db *sql.DB, cutoff time.Time) ([]core.Memory, error)

+ func TableCount(db *sql.DB) (int, error)

+ func TaskByID(ctx context.Context, db *sql.DB, id string) (core.Task, error)

+ func TasksBlockedBy(ctx context.Context, db *sql.DB, id string) ([]core.Task, error)

+ func TasksClaimedBy(ctx context.Context, db *sql.DB, sessionID string) ([]core.Task, error)

+ func TouchSession(ctx context.Context, db *sql.DB, id string, now time.Time) error

+ func TouchSessionByName(ctx context.Context, db *sql.DB, name string, now time.Time) error

+ func UpdateProposalPayload(ctx context.Context, db *sql.DB, id string, payload map[string]any) error

+ func UpdateSession(ctx context.Context, db *sql.DB, s core.Session) error

+ func UpdateTask(ctx context.Context, db *sql.DB, id string, patch TaskPatch, actor string, ...) (core.Task, error)

+ func UpsertEmbedding(ctx context.Context, db *sql.DB, itemID, kind, model string, vec []float32) error

+ type BlockedTask struct

+ Blockers []core.Task

+ Task core.Task

+ func AllBlockedTasks(ctx context.Context, db *sql.DB) ([]BlockedTask, error)

+ func BlockedTasks(ctx context.Context, db *sql.DB, project string) ([]BlockedTask, error)

+ func BlockedTasksForPlan(ctx context.Context, db *sql.DB, project, plan string) ([]BlockedTask, error)

+ type ClaimResult struct

+ PriorHolder string

+ Reclaimed bool

+ Task core.Task

+ func ClaimTask(ctx context.Context, db *sql.DB, id, sessionID string, lease time.Duration, ...) (ClaimResult, error)

+ type CoverageBucket struct

+ Covered int

+ Label string

+ Total int

+ func SessionCoverageBuckets(ctx context.Context, db *sql.DB, w RetrievalWindow, now time.Time) ([]CoverageBucket, error)

+ type KindReach struct

+ Injects int

+ Kind string

+ Memories int

+ type MemoryStat struct

+ ID string

+ Injects int

+ Kind string

+ LastInjected *time.Time

+ Name string

+ Project string

+ Reads int

+ Sessions int

+ Updated time.Time

+ type MemoryVector struct

+ Description string

+ ID string

+ Kind string

+ Name string

+ Project string

+ UpdatedAt time.Time

+ Vec []float32

+ func ActiveMemoryVectors(ctx context.Context, db *sql.DB, model string) ([]MemoryVector, error)

+ type Migration struct

+ SQL string

+ Version int

+ type NamedCount struct

+ Count int

+ ID string

+ Name string

+ type NavCounts struct

+ Memories int

+ Notes int

+ OpenTasks int

+ PendingProposals int

+ Plans int

+ Projects int

+ Sessions int

+ func GetNavCounts(ctx context.Context, db *sql.DB) (NavCounts, error)

+ type PlanRollup struct

+ Claimable int

+ Done int

+ InFlight int

+ Slug string

+ Total int

+ func ActivePlans(ctx context.Context, db *sql.DB, project string) ([]PlanRollup, error)

+ type PlanSearchRow struct

+ Project string

+ Slug string

+ Title string

+ Updated time.Time

+ func SearchPlans(ctx context.Context, db *sql.DB, q string, limit int) ([]PlanSearchRow, error)

+ type ProjectBoardRow struct

+ Active int

+ Blocked int

+ LastActive time.Time

+ LiveSessions int

+ Memories int

+ Notes int

+ OpenTasks int

+ Project string

+ ReachRate int

+ Sessions int

+ Surfaced int

+ Unregistered bool

+ func ProjectsWithCounts(ctx context.Context, db *sql.DB, window RetrievalWindow, now time.Time, ...) ([]ProjectBoardRow, error)

+ type ProjectCounts struct

+ Memories int

+ Notes int

+ OpenTasks int

+ Sessions int

+ func GetProjectCounts(ctx context.Context, db *sql.DB, slug string) (ProjectCounts, error)

+ type ProjectReach struct

+ Active int

+ Injects int

+ Project string

+ ReachRate int

+ Surfaced int

+ type Proposal struct

+ CreatedAt time.Time

+ ID string

+ Kind string

+ Payload map[string]any

+ ResolvedAt *time.Time

+ Status string

+ func CreateProposal(ctx context.Context, db *sql.DB, kind string, payload map[string]any) (Proposal, error)

+ func PendingProposals(ctx context.Context, db *sql.DB, kind string) ([]Proposal, error)

+ func ProposalByID(ctx context.Context, db *sql.DB, id string) (Proposal, bool, error)

+ type RetrievalReport struct

+ ActiveMemories int

+ ByKind []KindReach

+ ByProject []ProjectReach

+ Hourly bool

+ Injected int

+ MemoriesSurfaced int

+ ReachRate int

+ SessionsReached int

+ Top []MemoryStat

+ Trend []TrendBucket

+ Window RetrievalWindow

+ func BuildRetrievalReport(ctx context.Context, db *sql.DB, w RetrievalWindow, topN int) (RetrievalReport, error)

+ type RetrievalStat struct

+ InjectCount int

+ ItemID string

+ LastInjectedAt *time.Time

+ LastReadAt *time.Time

+ ReadCount int

+ func GetRetrievalStat(ctx context.Context, db *sql.DB, itemID string) (RetrievalStat, bool, error)

+ type RetrievalWindow struct

+ Key string

+ Label string

+ Since time.Time

+ func ResolveRetrievalWindow(key string, now time.Time) RetrievalWindow

+ type SearchHit struct

+ ItemID string

+ Kind string

+ Score float64

+ func CosineSearch(ctx context.Context, db *sql.DB, query []float32, model string, ...) ([]SearchHit, error)

+ func FTSSearch(ctx context.Context, db *sql.DB, query string, kinds, projects []string, ...) ([]SearchHit, error)

+ type SessionCoverage struct

+ Covered int

+ Findings int

+ Memories int

+ Notes int

+ Total int

+ Trials int

+ func GetSessionCoverage(ctx context.Context, db *sql.DB, since time.Time) (SessionCoverage, error)

+ func GetSessionCoverageForProject(ctx context.Context, db *sql.DB, project string, since time.Time) (SessionCoverage, error)

+ type SnippetHit struct

+ Snippet string

+ func FTSSearchSnippets(ctx context.Context, db *sql.DB, query string, kinds, projects []string, ...) ([]SnippetHit, error)

+ type TaskPatch struct

+ AddDependsOn []string

+ Body *string

+ ProjectSlug *string

+ Status *core.TaskStatus

+ Title *string

+ type TrendBucket struct

+ Count int

+ Label string

+ type TrialFilter struct

+ Lab string

+ Limit int

+ MetricsEquals map[string]any

+ Outcome string

+ Project string

+ type UsageSummary struct

+ EventsByKind map[string]int

+ GardenerPending map[string]int

+ Memories struct{ ... }

+ Notes int

+ Retrieval struct{ ... }

+ Sessions map[string]int

+ Tasks map[string]int

+ func GetUsageSummary(ctx context.Context, db *sql.DB) (UsageSummary, error)

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