store

Apr 26, 2026

Changes in this version

+ const JudgmentStatusIgnored

+ const JudgmentStatusJudged

+ const JudgmentStatusOrphaned

+ const JudgmentStatusPending

+ const RelationCompatible

+ const RelationConflictsWith

+ const RelationNotConflict

+ const RelationPending

+ const RelationRelated

+ const RelationScoped

+ const RelationSupersedes

+ type Candidate struct

+ ID int64

+ JudgmentID string

+ Score float64

+ SyncID string

+ Title string

+ TopicKey *string

+ Type string

+ type CandidateOptions struct

+ BM25Floor *float64

+ Limit int

+ Project string

+ Scope string

+ Type string

+ type JudgeRelationParams struct

+ Confidence *float64

+ Evidence *string

+ JudgmentID string

+ MarkedByActor string

+ MarkedByKind string

+ MarkedByModel string

+ Reason *string

+ Relation string

+ SessionID string

+ type ObservationRelations struct

+ AsSource []Relation

+ AsTarget []Relation

+ type Relation struct

+ Confidence *float64

+ CreatedAt string

+ Evidence *string

+ ID int64

+ JudgmentStatus string

+ MarkedByActor *string

+ MarkedByKind *string

+ MarkedByModel *string

+ Reason *string

+ Relation string

+ SessionID *string

+ SourceID string

+ SyncID string

+ TargetID string

+ UpdatedAt string

+ type SaveRelationParams struct

+ SourceID string

+ SyncID string

+ TargetID string

type Store

+ func (s *Store) CountRelationSyncMutations() (int, error)

+ func (s *Store) FindCandidates(savedID int64, opts CandidateOptions) ([]Candidate, error)

+ func (s *Store) GetRelation(syncID string) (*Relation, error)

+ func (s *Store) GetRelationsForObservations(syncIDs []string) (map[string]ObservationRelations, error)

+ func (s *Store) JudgeRelation(p JudgeRelationParams) (*Relation, error)

+ func (s *Store) ListObservationSyncPayloads() ([]any, error)

+ func (s *Store) SaveRelation(p SaveRelationParams) (*Relation, error)

Apr 24, 2026

Changes in this version

+ const LocalChunkTargetKey

+ const UpgradeReasonBlockedLegacyMutationManual

+ const UpgradeReasonRepairableLegacyMutationPayload

+ const UpgradeRepairClassBlocked

+ const UpgradeRepairClassNone

+ const UpgradeRepairClassPolicy

+ const UpgradeRepairClassReady

+ const UpgradeRepairClassRepairable

+ const UpgradeStageBootstrapEnrolled

+ const UpgradeStageBootstrapPushed

+ const UpgradeStageBootstrapVerified

+ const UpgradeStageDoctorBlocked

+ const UpgradeStageDoctorReady

+ const UpgradeStagePlanned

+ const UpgradeStageRepairApplied

+ const UpgradeStageRolledBack

+ var ErrObservationNotFound = errors.New("observation not found")

+ var ErrSessionDeleteBlocked = errors.New("session deletion is blocked while cloud sync enrollment is active")

+ type CloudUpgradeLegacyMutationFinding struct

+ Entity string

+ EntityKey string

+ Message string

+ Op string

+ Project string

+ ReasonCode string

+ RepairHint string

+ Repairable bool

+ Seq int64

+ TargetKey string

+ type CloudUpgradeLegacyMutationReport struct

+ BlockedCount int

+ Findings []CloudUpgradeLegacyMutationFinding

+ Project string

+ RepairableCount int

+ type CloudUpgradeRepairReport struct

+ Applied bool

+ Class string

+ Message string

+ PlannedAction string

+ ReasonCode string

+ type CloudUpgradeSnapshot struct

+ CloudConfigJSON string

+ CloudConfigPresent bool

+ ProjectEnrolled bool

+ type CloudUpgradeState struct

+ AppliedActions string

+ FindingsJSON string

+ LastErrorCode string

+ LastErrorMessage string

+ Project string

+ RepairClass string

+ Snapshot CloudUpgradeSnapshot

+ Stage string

+ UpdatedAt string

type Store

+ func (s *Store) ApplyPulledChunk(targetKey, chunkID string, mutations []SyncMutation) error

+ func (s *Store) CanRollbackCloudUpgrade(project string) (bool, error)

+ func (s *Store) ClearCloudUpgradeState(project string) error

+ func (s *Store) DiagnoseCloudUpgradeLegacyMutations(project string) (CloudUpgradeLegacyMutationReport, error)

+ func (s *Store) ExportProject(project string) (*ExportData, error)

+ func (s *Store) GetCloudUpgradeState(project string) (*CloudUpgradeState, error)

+ func (s *Store) GetSyncedChunksForTarget(targetKey string) (map[string]bool, error)

+ func (s *Store) HasPendingSyncMutationsForProject(project string) (bool, error)

+ func (s *Store) ListPendingSyncMutationsAfterSeq(targetKey string, afterSeq int64, limit int) ([]SyncMutation, error)

+ func (s *Store) MarkSyncAuthRequired(targetKey, message string) error

+ func (s *Store) MarkSyncBlocked(targetKey, reasonCode, message string) error

+ func (s *Store) MarkSyncPaused(targetKey, message string) error

+ func (s *Store) MarkSyncPending(targetKey string) error

+ func (s *Store) ProjectExists(name string) (bool, error)

+ func (s *Store) RecordSyncedChunkForTarget(targetKey, chunkID string) error

+ func (s *Store) RepairCloudUpgrade(project string, apply bool) (CloudUpgradeRepairReport, error)

+ func (s *Store) RollbackCloudUpgrade(project string) (CloudUpgradeState, error)

+ func (s *Store) SaveCloudUpgradeState(state CloudUpgradeState) error

type SyncState

+ ReasonCode *string

+ ReasonMessage *string

Apr 12, 2026

Changes in this version

+ var ErrPromptNotFound = errors.New("prompt not found")

+ var ErrSessionHasObservations = errors.New("session still has observations")

+ var ErrSessionNotFound = errors.New("session not found")

type Store

+ func (s *Store) DeletePrompt(id int64) error

+ func (s *Store) DeleteSession(id string) error

Mar 30, 2026

Changes in this version

+ func NormalizeProject(project string) (normalized string, warning string)

+ type MergeResult struct

+ Canonical string

+ ObservationsUpdated int64

+ PromptsUpdated int64

+ SessionsUpdated int64

+ SourcesMerged []string

+ type ProjectNameCount struct

+ Count int

+ Name string

+ type ProjectStats struct

+ Directories []string

+ Name string

+ ObservationCount int

+ PromptCount int

+ SessionCount int

+ type PruneResult struct

+ Project string

+ PromptsDeleted int64

+ SessionsDeleted int64

type Store

+ func (s *Store) CountObservationsForProject(name string) (int, error)

+ func (s *Store) ListProjectNames() ([]string, error)

+ func (s *Store) ListProjectsWithStats() ([]ProjectStats, error)

+ func (s *Store) MergeProjects(sources []string, canonical string) (*MergeResult, error)

+ func (s *Store) PruneProject(project string) (*PruneResult, error)

Mar 13, 2026

Changes in this version

+ type MigrateResult struct

+ Migrated bool

+ ObservationsUpdated int64

+ PromptsUpdated int64

+ SessionsUpdated int64

type Store

+ func (s *Store) MigrateProject(oldName, newName string) (*MigrateResult, error)

Mar 10, 2026

Changes in this version

type Config

+ func FallbackConfig(dataDir string) Config

Mar 8, 2026

Changes in this version

type Store

+ func (s *Store) MaxObservationLength() int

Mar 7, 2026

Changes in this version

+ const DefaultSyncTargetKey

+ const SyncEntityObservation

+ const SyncEntityPrompt

+ const SyncEntitySession

+ const SyncLifecycleDegraded

+ const SyncLifecycleHealthy

+ const SyncLifecycleIdle

+ const SyncLifecyclePending

+ const SyncLifecycleRunning

+ const SyncOpDelete

+ const SyncOpUpsert

+ const SyncSourceLocal

+ const SyncSourceRemote

+ type EnrolledProject struct

+ EnrolledAt string

+ Project string

type Observation

+ SyncID string

type Prompt

+ SyncID string

type Store

+ func (s *Store) AckSyncMutationSeqs(targetKey string, seqs []int64) error

+ func (s *Store) AckSyncMutations(targetKey string, lastAckedSeq int64) error

+ func (s *Store) AcquireSyncLease(targetKey, owner string, ttl time.Duration, now time.Time) (bool, error)

+ func (s *Store) ApplyPulledMutation(targetKey string, mutation SyncMutation) error

+ func (s *Store) EnrollProject(project string) error

+ func (s *Store) GetObservationBySyncID(syncID string) (*Observation, error)

+ func (s *Store) GetSyncState(targetKey string) (*SyncState, error)

+ func (s *Store) IsProjectEnrolled(project string) (bool, error)

+ func (s *Store) ListEnrolledProjects() ([]EnrolledProject, error)

+ func (s *Store) ListPendingSyncMutations(targetKey string, limit int) ([]SyncMutation, error)

+ func (s *Store) MarkSyncFailure(targetKey, message string, backoffUntil time.Time) error

+ func (s *Store) MarkSyncHealthy(targetKey string) error

+ func (s *Store) ReleaseSyncLease(targetKey, owner string) error

+ func (s *Store) SkipAckNonEnrolledMutations(targetKey string) (int64, error)

+ func (s *Store) UnenrollProject(project string) error

+ type SyncMutation struct

+ AckedAt *string

+ Entity string

+ EntityKey string

+ OccurredAt string

+ Op string

+ Payload string

+ Project string

+ Seq int64

+ Source string

+ TargetKey string

+ type SyncState struct

+ BackoffUntil *string

+ ConsecutiveFailures int

+ LastAckedSeq int64

+ LastEnqueuedSeq int64

+ LastError *string

+ LastPulledSeq int64

+ LeaseOwner *string

+ LeaseUntil *string

+ Lifecycle string

+ TargetKey string

+ UpdatedAt string

Feb 28, 2026

Changes in this version

+ func ClassifyTool(toolName string) string

+ func ExtractLearnings(text string) []string

+ func Now() string

+ func SuggestTopicKey(typ, title, content string) string

+ type AddObservationParams struct

+ Content string

+ Project string

+ Scope string

+ SessionID string

+ Title string

+ ToolName string

+ TopicKey string

+ Type string

+ type AddPromptParams struct

+ Content string

+ Project string

+ SessionID string

+ type Config struct

+ DataDir string

+ DedupeWindow time.Duration

+ MaxContextResults int

+ MaxObservationLength int

+ MaxSearchResults int

+ func DefaultConfig() Config

+ type ExportData struct

+ ExportedAt string

+ Observations []Observation

+ Prompts []Prompt

+ Sessions []Session

+ Version string

+ type ImportResult struct

+ ObservationsImported int

+ PromptsImported int

+ SessionsImported int

+ type Observation struct

+ Content string

+ CreatedAt string

+ DeletedAt *string

+ DuplicateCount int

+ ID int64

+ LastSeenAt *string

+ Project *string

+ RevisionCount int

+ Scope string

+ SessionID string

+ Title string

+ ToolName *string

+ TopicKey *string

+ Type string

+ UpdatedAt string

+ type PassiveCaptureParams struct

+ Content string

+ Project string

+ SessionID string

+ Source string

+ type PassiveCaptureResult struct

+ Duplicates int

+ Extracted int

+ Saved int

+ type Prompt struct

+ Content string

+ CreatedAt string

+ ID int64

+ Project string

+ SessionID string

+ type SearchOptions struct

+ Limit int

+ Project string

+ Scope string

+ Type string

+ type SearchResult struct

+ Rank float64

+ type Session struct

+ Directory string

+ EndedAt *string

+ ID string

+ Project string

+ StartedAt string

+ Summary *string

+ type SessionSummary struct

+ EndedAt *string

+ ID string

+ ObservationCount int

+ Project string

+ StartedAt string

+ Summary *string

+ type Stats struct

+ Projects []string

+ TotalObservations int

+ TotalPrompts int

+ TotalSessions int

+ type Store struct

+ func New(cfg Config) (*Store, error)

+ func (s *Store) AddObservation(p AddObservationParams) (int64, error)

+ func (s *Store) AddPrompt(p AddPromptParams) (int64, error)

+ func (s *Store) AllObservations(project, scope string, limit int) ([]Observation, error)

+ func (s *Store) AllSessions(project string, limit int) ([]SessionSummary, error)

+ func (s *Store) Close() error

+ func (s *Store) CreateSession(id, project, directory string) error

+ func (s *Store) DeleteObservation(id int64, hardDelete bool) error

+ func (s *Store) EndSession(id string, summary string) error

+ func (s *Store) Export() (*ExportData, error)

+ func (s *Store) FormatContext(project, scope string) (string, error)

+ func (s *Store) GetObservation(id int64) (*Observation, error)

+ func (s *Store) GetSession(id string) (*Session, error)

+ func (s *Store) GetSyncedChunks() (map[string]bool, error)

+ func (s *Store) Import(data *ExportData) (*ImportResult, error)

+ func (s *Store) PassiveCapture(p PassiveCaptureParams) (*PassiveCaptureResult, error)

+ func (s *Store) RecentObservations(project, scope string, limit int) ([]Observation, error)

+ func (s *Store) RecentPrompts(project string, limit int) ([]Prompt, error)

+ func (s *Store) RecentSessions(project string, limit int) ([]SessionSummary, error)

+ func (s *Store) RecordSyncedChunk(chunkID string) error

+ func (s *Store) Search(query string, opts SearchOptions) ([]SearchResult, error)

+ func (s *Store) SearchPrompts(query string, project string, limit int) ([]Prompt, error)

+ func (s *Store) SessionObservations(sessionID string, limit int) ([]Observation, error)

+ func (s *Store) Stats() (*Stats, error)

+ func (s *Store) Timeline(observationID int64, before, after int) (*TimelineResult, error)

+ func (s *Store) UpdateObservation(id int64, p UpdateObservationParams) (*Observation, error)

+ type TimelineEntry struct

+ Content string

+ CreatedAt string

+ DeletedAt *string

+ DuplicateCount int

+ ID int64

+ IsFocus bool

+ LastSeenAt *string

+ Project *string

+ RevisionCount int

+ Scope string

+ SessionID string

+ Title string

+ ToolName *string

+ TopicKey *string

+ Type string

+ UpdatedAt string

+ type TimelineResult struct

+ After []TimelineEntry

+ Before []TimelineEntry

+ Focus Observation

+ SessionInfo *Session

+ TotalInRange int

+ type UpdateObservationParams struct

+ Content *string

+ Project *string

+ Scope *string

+ Title *string

+ TopicKey *string

+ Type *string