tier

package
v0.1.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 22, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RecordTierDepth 

func RecordTierDepth(ctx context.Context, store Store, recorder observability.Recorder, scenario string, ns memory.Namespace)

RecordTierDepth publishes per-level record counts for a namespace.

Types

type CognitiveAdapter 

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

CognitiveAdapter implements memory.CognitiveMemory using a tier Manager.

func NewCognitiveAdapter 

func NewCognitiveAdapter(manager Manager, weights RecallWeights) *CognitiveAdapter

NewCognitiveAdapter wraps a tier Manager as a CognitiveMemory port.

func (*CognitiveAdapter) Recall 

func (a *CognitiveAdapter) Recall(ctx context.Context, ns memory.Namespace, query string, limit int) ([]memory.CognitiveRecord, error)

func (*CognitiveAdapter) Remember 

func (a *CognitiveAdapter) Remember(ctx context.Context, ns memory.Namespace, record memory.CognitiveRecord) error

type CompositeStore 

type CompositeStore struct {
	Hot  Store
	Warm Store
	Cold Store
}

CompositeStore routes tier records across hot, warm, and cold backends.

func (*CompositeStore) Count 

func (c *CompositeStore) Count(ctx context.Context, ns memory.Namespace, level Level) (int, error)

func (*CompositeStore) Delete 

func (c *CompositeStore) Delete(ctx context.Context, ns memory.Namespace, id string) error

func (*CompositeStore) Get 

func (c *CompositeStore) Get(ctx context.Context, ns memory.Namespace, id string) (Record, error)

func (*CompositeStore) List 

func (c *CompositeStore) List(ctx context.Context, ns memory.Namespace, level Level, limit int) ([]Record, error)

func (*CompositeStore) Put 

func (c *CompositeStore) Put(ctx context.Context, ns memory.Namespace, record Record) error

type Level 

type Level string

Level identifies a memory storage and recall tier. 

const (
	LevelHot  Level = "hot"
	LevelWarm Level = "warm"
	LevelCold Level = "cold"
)

type Manager 

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)
}

Manager orchestrates tiered remember, recall, and reconciliation.

func NewDualWriteManager 

func NewDualWriteManager(inner Manager, index memory.CognitiveMemory) Manager

NewDualWriteManager remembers tier records and mirrors searchable cognitive entries.

func NewManager 

func NewManager(store Store, policy Policy, observer MigrationObserver) Manager

NewManager constructs a tier Manager backed by store and policy.

func NewManagerWithWeights 

func NewManagerWithWeights(store Store, policy Policy, observer MigrationObserver, weights memory.RecallWeights) Manager

NewManagerWithWeights constructs a tier Manager with custom RankMemories weights.

type MetricsObserver 

type MetricsObserver struct {
	Recorder observability.Recorder
	Scenario string
}

MetricsObserver records tier migration and depth metrics.

func (MetricsObserver) Demoted 

func (o MetricsObserver) Demoted(ctx context.Context, ns memory.Namespace, recordID string, from, to Level)

func (MetricsObserver) Evicted 

func (o MetricsObserver) Evicted(ctx context.Context, ns memory.Namespace, recordID string, from Level)

func (MetricsObserver) Promoted 

func (o MetricsObserver) Promoted(ctx context.Context, ns memory.Namespace, recordID string, from, to Level)

type MigrationObserver 

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)
}

MigrationObserver receives tier migration notifications from a Manager.

type MigrationReport 

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

MigrationReport summarizes tier migrations from a reconcile pass.

type NoopMigrationObserver 

type NoopMigrationObserver struct{}

NoopMigrationObserver discards migration notifications.

func (NoopMigrationObserver) Demoted 

func (NoopMigrationObserver) Demoted(context.Context, memory.Namespace, string, Level, Level)

func (NoopMigrationObserver) Evicted 

func (NoopMigrationObserver) Evicted(context.Context, memory.Namespace, string, Level)

func (NoopMigrationObserver) Promoted 

func (NoopMigrationObserver) Promoted(context.Context, memory.Namespace, string, Level, Level)

type Policy 

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

Policy configures automatic promotion, demotion, and eviction between tiers.

func DefaultPolicy 

func DefaultPolicy() Policy

DefaultPolicy returns baseline hot/warm/cold promotion and demotion rules.

func (Policy) NextTierOnDemote 

func (p Policy) NextTierOnDemote(level Level) (Level, bool)

NextTierOnDemote returns the colder tier, or empty if eviction is required.

func (Policy) ShouldDemote 

func (p Policy) ShouldDemote(record Record, now time.Time, levelCount int) bool

ShouldDemote reports whether a record should move to a colder tier.

func (Policy) ShouldPromote 

func (p Policy) ShouldPromote(record Record, now time.Time) bool

ShouldPromote reports whether a record should move to a hotter tier after access.

func (Policy) TargetTier 

func (p Policy) TargetTier(record Record, now time.Time, levelCount map[Level]int) Level

TargetTier returns the tier a record should occupy after promotion or demotion.

type RecallBudget 

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

RecallBudget limits how many records to pull from each tier during recall.

func (RecallBudget) Normalize 

func (b RecallBudget) Normalize() RecallBudget

Normalize fills zero values with sensible defaults and caps per-tier limits by Total.

type RecallWeights 

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

RecallWeights configures RankMemories weighting during tier recall.

type Record 

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"`
}

Record extends a cognitive memory entry with tier lifecycle metadata.

type Settings 

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"`
}

Settings configures tiered memory for a scenario memory reference.

func SettingsFromCore 

func SettingsFromCore(ref *core.MemoryTierSettings) (Settings, bool)

SettingsFromCore converts a scenario memory tier reference into tier settings.

func (Settings) Budget 

func (s Settings) Budget() RecallBudget

Budget returns the normalized recall budget for tier recall.

func (Settings) Policy 

func (s Settings) Policy() Policy

Policy returns the effective tier policy from settings, overlaying defaults.

func (Settings) Weights 

func (s Settings) Weights() memory.RecallWeights

Weights returns normalized RankMemories weights.

type Store 

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)
}

Store persists tier-scoped memory records.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.