tier

type ChainedMigrationObserver struct {
	Observers []MigrationObserver
}

type CognitiveAdapter struct {
	Manager Manager
	Weights RecallWeights
	Budget  func(limit int) RecallBudget
}

type ColdSummaryBackend interface {
	Archive(ctx context.Context, ns memory.Namespace, record *Record) error
	SearchRecordIDs(ctx context.Context, ns memory.Namespace, query string, limit int) ([]string, error)
	Delete(ctx context.Context, ns memory.Namespace, recordID string) error
}

type ColdSummaryIndexer interface {
	UpsertSummary(ctx context.Context, ns memory.Namespace, record Record, summary string) error
	SearchSummaries(ctx context.Context, ns memory.Namespace, query string, limit int) ([]string, error)
	DeleteSummary(ctx context.Context, ns memory.Namespace, recordID string) error
}

type ColdSummarySettings struct {
	Enabled         bool   `json:"enabled,omitempty" yaml:"enabled"`
	MinBytes        int64  `json:"min_bytes,omitempty" yaml:"min_bytes"`
	MaxSummaryChars int    `json:"max_summary_chars,omitempty" yaml:"max_summary_chars"`
	SummaryProfile  string `json:"summary_profile,omitempty" yaml:"summary_profile"`
}

type CompositeStore struct {
	Hot  Store
	Warm Store
	Cold Store
}

type ContentSummarizer interface {
	Summarize(ctx context.Context, content string, maxChars int) (string, error)
}

type EventSinkMigrationObserver struct {
	Sink     core.EventSink
	Scenario string
}

type Level string

type Manager interface {
	Remember(ctx context.Context, ns memory.Namespace, record Record) error
	Recall(ctx context.Context, ns memory.Namespace, query string, budget RecallBudget) ([]Record, error)
	Reconcile(ctx context.Context, ns memory.Namespace, now time.Time) (MigrationReport, error)
}

type MetricsObserver struct {
	Recorder observability.Recorder
	Scenario string
}

type MigrationObserver interface {
	Promoted(ctx context.Context, ns memory.Namespace, recordID string, from, to Level)
	Demoted(ctx context.Context, ns memory.Namespace, recordID string, from, to Level)
	Evicted(ctx context.Context, ns memory.Namespace, recordID string, from Level)
}

type MigrationReport struct {
	Promoted int `json:"promoted"`
	Demoted  int `json:"demoted"`
	Evicted  int `json:"evicted"`
}

type NoopColdSummaryBackend struct{}

type NoopMigrationObserver struct{}

type Policy struct {
	HotCapacity   int
	WarmCapacity  int
	ColdCapacity  int
	HotTTL        time.Duration
	WarmTTL       time.Duration
	PromoteAccess int
	DemoteIdle    time.Duration
}

type RecallBudget struct {
	Total int `json:"total"`
	Hot   int `json:"hot"`
	Warm  int `json:"warm"`
	Cold  int `json:"cold"`
}

type RecallWeights struct {
	Semantic   float64 `json:"semantic,omitempty" yaml:"semantic"`
	Recency    float64 `json:"recency,omitempty" yaml:"recency"`
	Importance float64 `json:"importance,omitempty" yaml:"importance"`
}

type Record struct {
	memory.CognitiveRecord
	Tier         Level     `json:"tier"`
	AccessCount  int       `json:"access_count"`
	LastAccessAt time.Time `json:"last_access_at"`
	PromotedAt   time.Time `json:"promoted_at"`
	SizeBytes    int64     `json:"size_bytes,omitempty"`
	Pinned       bool      `json:"pinned,omitempty"`
}

type Settings struct {
	Enabled       bool                `json:"enabled,omitempty" yaml:"enabled"`
	HotCapacity   int                 `json:"hot_capacity,omitempty" yaml:"hot_capacity"`
	WarmCapacity  int                 `json:"warm_capacity,omitempty" yaml:"warm_capacity"`
	ColdCapacity  int                 `json:"cold_capacity,omitempty" yaml:"cold_capacity"`
	HotTTL        time.Duration       `json:"hot_ttl,omitempty" yaml:"hot_ttl"`
	WarmTTL       time.Duration       `json:"warm_ttl,omitempty" yaml:"warm_ttl"`
	PromoteAccess int                 `json:"promote_access,omitempty" yaml:"promote_access"`
	DemoteIdle    time.Duration       `json:"demote_idle,omitempty" yaml:"demote_idle"`
	RecallBudget  RecallBudget        `json:"recall_budget,omitempty" yaml:"recall_budget"`
	RecallWeights RecallWeights       `json:"recall_weights,omitempty" yaml:"recall_weights"`
	ColdSummary   ColdSummarySettings `json:"cold_summary,omitempty" yaml:"cold_summary"`
}

type Store interface {
	Put(ctx context.Context, ns memory.Namespace, record Record) error
	Get(ctx context.Context, ns memory.Namespace, id string) (Record, error)
	List(ctx context.Context, ns memory.Namespace, level Level, limit int) ([]Record, error)
	Delete(ctx context.Context, ns memory.Namespace, id string) error
	Count(ctx context.Context, ns memory.Namespace, level Level) (int, error)
}

type TruncateColdSummaryBackend struct {
	Settings   ColdSummarySettings
	Vector     ColdSummaryIndexer
	Summarizer ContentSummarizer
}