maintenance

type BackfillConfidenceReport struct {
	Inspected int `json:"inspected"`
	Seeded    int `json:"seeded"`
	Skipped   int `json:"skipped"`
}

type ClusterAction struct {
	RepresentativeID string   `json:"representative_id"`
	TombstonedIDs    []string `json:"tombstoned_ids"`
	Size             int      `json:"size"`
}

type DedupJob struct {
	// contains filtered or unexported fields
}

type DedupOptions struct {
	// Similarity is the minimum cosine-like score (the store's vector
	// distance-to-score mapping) for two memories to join a cluster.
	// 0 falls back to defaultDedupSimilarity. Negative disables dedup and
	// the call returns an empty report.
	Similarity float64
	// MinClusterSize is the smallest cluster acted on. A pair of near-
	// duplicates below this is left alone. 0 falls back to
	// defaultDedupMinClusterSize.
	MinClusterSize int
	// Tiers restricts the pass to these tiers; nil/empty means all tiers.
	Tiers []memory.Tier
	// Namespaces restricts the pass to these namespaces; nil/empty means every
	// namespace. Clusters never span namespaces, so scoping the pass to one
	// (the post-import case) is both cheaper and avoids touching other tenants.
	Namespaces []string
	// NeighboursPerAnchor bounds the per-anchor vector-search fan-out. Larger
	// values tighten clusters at higher vector-search cost. 0 falls back to
	// defaultDedupNeighboursAnchor.
	NeighboursPerAnchor int
	// DryRun reports what would be done without tombstoning anything.
	DryRun bool
	// Now is the instant retention scoring and expiry filtering are evaluated
	// at. Zero means time.Now().UTC().
	Now time.Time
	// Log receives progress messages; nil falls back to slog.Default().
	Log *slog.Logger
}

type DedupReport struct {
	Namespaces    int             `json:"namespaces"`
	MemoriesSeen  int             `json:"memories_seen"`
	ClustersFound int             `json:"clusters_found"`
	Tombstoned    int             `json:"tombstoned"`
	DryRun        bool            `json:"dry_run"`
	Actions       []ClusterAction `json:"actions,omitempty"`
}

type RenamespaceReport struct {
	Moved   int            `json:"moved"`
	Targets map[string]int `json:"targets,omitempty"` // memories moved into each destination
	Skipped int            `json:"skipped"`           // left in place (no grouping key, or already in place)
	DryRun  bool           `json:"dry_run"`
}

type Report struct {
	ExpiredPurged    int        `json:"expired_purged"`
	ShortTermEvicted int        `json:"short_term_evicted"`
	Namespaces       int        `json:"namespaces"`
	DuplicateGroups  [][]string `json:"duplicate_groups,omitempty"`
}

type Sweeper struct {
	// contains filtered or unexported fields
}

type SweeperConfig struct {
	// Interval is how often the sweep runs.
	Interval time.Duration
	// ShortTermCap bounds working+episodic memories per namespace; the lowest-
	// retention ones over the cap are evicted. 0 disables it.
	ShortTermCap int
	// TombstoneTTL hard-deletes superseded memories last updated before now-TTL,
	// reclaiming space. 0 disables it (tombstones are kept indefinitely but stay
	// excluded from recall).
	TombstoneTTL time.Duration
	// DemoteAfter demotes never-recalled, low-importance durable memories older
	// than this to the episodic tier so unused debris ages out. 0 disables it.
	DemoteAfter time.Duration
}