stack

Documentation

Index

• type DBAccessor
• type EntityDetector
• type EssentialLayer
  • func NewEssentialLayer(store DBAccessor, logger *slog.Logger) *EssentialLayer
  • func (l *EssentialLayer) CacheHits() int64
  • func (l *EssentialLayer) CacheMisses() int64
  • func (l *EssentialLayer) Invalidate(projectID string)
  • func (l *EssentialLayer) Render(projectID string) string
• type IdentityLayer
  • func NewIdentityLayer(path string, logger *slog.Logger, budget int) *IdentityLayer
  • func (l *IdentityLayer) Reload() error
  • func (l *IdentityLayer) Render() string
  • func (l *IdentityLayer) Start() error
  • func (l *IdentityLayer) Stop()
• type LayerOutput
• type OnDemandLayer
  • func NewOnDemandLayer(store DBAccessor, entityDetector EntityDetector, ...) *OnDemandLayer
  • func (l *OnDemandLayer) Render(query, projectID string) string
• type OnDemandLayerConfig
• type ProjectLayer
  • func NewProjectLayer(getStoryFn func() string) *ProjectLayer
  • func NewProjectLayerWithEssential(store DBAccessor, projectID string, logger *slog.Logger) *ProjectLayer
  • func (l *ProjectLayer) Invalidate()
  • func (l *ProjectLayer) Render() string
• type Stack
  • func NewStack(identity *IdentityLayer, project *ProjectLayer, ondemand *OnDemandLayer, ...) *Stack
  • func (s *Stack) Metrics() StackMetrics
  • func (s *Stack) Render() string
• type StackMetrics
• type TopicChangeChecker

Types

type DBAccessor

type DBAccessor interface {
	DB() *sql.DB
}

type EntityDetector

type EntityDetector interface {
	Detect(text string) []string
}

EntityDetector extracts known entities from text.

type EssentialLayer

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

func NewEssentialLayer

func NewEssentialLayer(store DBAccessor, logger *slog.Logger) *EssentialLayer

func (*EssentialLayer) CacheHits

func (l *EssentialLayer) CacheHits() int64

CacheHits returns the number of cache hits since creation.

func (*EssentialLayer) CacheMisses

func (l *EssentialLayer) CacheMisses() int64

CacheMisses returns the number of cache misses since creation.

func (*EssentialLayer) Invalidate

func (l *EssentialLayer) Invalidate(projectID string)

func (*EssentialLayer) Render

func (l *EssentialLayer) Render(projectID string) string

type IdentityLayer

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

func NewIdentityLayer

func NewIdentityLayer(path string, logger *slog.Logger, budget int) *IdentityLayer

func (*IdentityLayer) Reload

func (l *IdentityLayer) Reload() error

func (*IdentityLayer) Render

func (l *IdentityLayer) Render() string

func (*IdentityLayer) Start

func (l *IdentityLayer) Start() error

func (*IdentityLayer) Stop

func (l *IdentityLayer) Stop()

type LayerOutput

type LayerOutput struct {
	Label   string
	Content string
	Bytes   int
}

type OnDemandLayer

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

OnDemandLayer retrieves contextual memories based on entities detected in the current query. Composes an EntityDetector with FTS5 search and optional topic change detection.

func NewOnDemandLayer

func NewOnDemandLayer(store DBAccessor, entityDetector EntityDetector, topicDetector TopicChangeChecker, logger *slog.Logger, cfg OnDemandLayerConfig) *OnDemandLayer

NewOnDemandLayer creates a real on-demand retrieval layer. store provides DB access for FTS5 queries. entityDetector extracts entities from query text. topicDetector may be nil — topic change detection is optional.

func (*OnDemandLayer) Render

func (l *OnDemandLayer) Render(query, projectID string) string

Render retrieves memories relevant to the query entities and returns a formatted markdown snippet. If query is empty, returns "".

type OnDemandLayerConfig

type OnDemandLayerConfig struct {
	Budget     int
	MaxResults int
}

OnDemandLayerConfig holds optional configuration.

type ProjectLayer

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

func NewProjectLayer

func NewProjectLayer(getStoryFn func() string) *ProjectLayer

func NewProjectLayerWithEssential

func NewProjectLayerWithEssential(store DBAccessor, projectID string, logger *slog.Logger) *ProjectLayer

func (*ProjectLayer) Invalidate

func (l *ProjectLayer) Invalidate()

func (*ProjectLayer) Render

func (l *ProjectLayer) Render() string

type Stack

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

func NewStack

func NewStack(identity *IdentityLayer, project *ProjectLayer, ondemand *OnDemandLayer, budget int, logger *slog.Logger) *Stack

func (*Stack) Metrics

func (s *Stack) Metrics() StackMetrics

func (*Stack) Render

func (s *Stack) Render() string

type StackMetrics

type StackMetrics struct {
	LayerBytesL0  int64
	LayerBytesL1  int64
	LayerBytesL2  int64
	L1CacheHits   int64
	L1CacheMisses int64
	TotalRenders  int64
}

type TopicChangeChecker

type TopicChangeChecker interface {
	Check(ctx context.Context, query string) (bool, error)
}

TopicChangeChecker detects whether the topic has shifted between queries.