Versions in this module Expand all Collapse all v0 v0.1.0 Feb 24, 2026 Changes in this version + type BleveObservationStore struct + func NewBleveObservationStore(store *BleveStore) *BleveObservationStore + func (s *BleveObservationStore) QueryRelevantObservations(ctx context.Context, query string, limit int) ([]interface{}, error) + func (s *BleveObservationStore) StoreObservation(ctx context.Context, obsRaw interface{}) error + type BleveStore struct + func NewBleveStore(cfg BleveStoreConfig) (*BleveStore, error) + func (s *BleveStore) Close() error + func (s *BleveStore) ConsolidateSession(ctx context.Context, sessionID string, transcript []Message) error + func (s *BleveStore) Get(key string) (string, error) + func (s *BleveStore) List(prefix string) ([]string, error) + func (s *BleveStore) ListAll(ctx context.Context, category string, limit int) ([]ObservationItem, error) + func (s *BleveStore) Recall(ctx context.Context, queryText string, opts RecallOpts) ([]MemoryResult, error) + func (s *BleveStore) RecallByCategory(ctx context.Context, queryText, category string, limit int) ([]string, error) + func (s *BleveStore) RecallFIL(ctx context.Context, queryText string, limitPerCategory int) (*FILResult, error) + func (s *BleveStore) RememberFIL(ctx context.Context, findings, insights, lessons []string, source string) ([]string, error) + func (s *BleveStore) RememberObservation(ctx context.Context, content, category, source string) (string, error) + func (s *BleveStore) RetrieveByID(ctx context.Context, id string) (*ObservationItem, error) + func (s *BleveStore) Search(queryStr string) ([]SearchResult, error) + func (s *BleveStore) Set(key, value string) error + type BleveStoreConfig struct + BasePath string + type Consolidator interface + Extract func(ctx context.Context, transcript []Message) ([]string, error) + type FILResult struct + Findings []string + Insights []string + Lessons []string + type InMemoryStore struct + func NewInMemoryStore() *InMemoryStore + func (s *InMemoryStore) Close() error + func (s *InMemoryStore) ConsolidateSession(ctx context.Context, sessionID string, transcript []Message) error + func (s *InMemoryStore) Get(key string) (string, error) + func (s *InMemoryStore) List(prefix string) ([]string, error) + func (s *InMemoryStore) Recall(ctx context.Context, query string, opts RecallOpts) ([]MemoryResult, error) + func (s *InMemoryStore) RecallByCategory(ctx context.Context, query, category string, limit int) ([]string, error) + func (s *InMemoryStore) RecallFIL(ctx context.Context, query string, limitPerCategory int) (*FILResult, error) + func (s *InMemoryStore) RememberFIL(ctx context.Context, findings, insights, lessons []string, source string) ([]string, error) + func (s *InMemoryStore) RememberObservation(ctx context.Context, content, category, source string) (string, error) + func (s *InMemoryStore) RetrieveByID(ctx context.Context, id string) (*ObservationItem, error) + func (s *InMemoryStore) Search(query string) ([]SearchResult, error) + func (s *InMemoryStore) Set(key, value string) error + type Memory struct + Category string + Content string + CreatedAt time.Time + ID string + Source string + type MemoryResult struct + Score float32 + type Message struct + Content string + Role string + type Observation struct + Findings []string + Insights []string + Lessons []string + StepName string + StepType string + type ObservationDocument struct + Category string + Content string + CreatedAt time.Time + ID string + Source string + type ObservationExtractor struct + func NewObservationExtractor(provider llm.Provider) *ObservationExtractor + func (e *ObservationExtractor) Extract(ctx context.Context, stepName, stepType, output string) (interface{}, error) + type ObservationItem struct + Category string + Content string + ID string + type RecallOpts struct + Limit int + MinScore float32 + TimeRange *TimeRange + type SearchResult struct + Key string + Value string + type Store interface + Close func() error + ConsolidateSession func(ctx context.Context, sessionID string, transcript []Message) error + Get func(key string) (string, error) + List func(prefix string) ([]string, error) + Recall func(ctx context.Context, query string, opts RecallOpts) ([]MemoryResult, error) + RecallByCategory func(ctx context.Context, query, category string, limit int) ([]string, error) + RecallFIL func(ctx context.Context, query string, limitPerCategory int) (*FILResult, error) + RememberFIL func(ctx context.Context, findings, insights, lessons []string, source string) ([]string, error) + RememberObservation func(ctx context.Context, content, category, source string) (string, error) + RetrieveByID func(ctx context.Context, id string) (*ObservationItem, error) + Search func(query string) ([]SearchResult, error) + Set func(key, value string) error + type TimeRange struct + End time.Time + Start time.Time + type ToolsAdapter struct + func NewToolsAdapter(store Store) *ToolsAdapter + func (a *ToolsAdapter) Close() error + func (a *ToolsAdapter) ConsolidateSession(ctx context.Context, sessionID string, transcript []Message) error + func (a *ToolsAdapter) Recall(ctx context.Context, query string, limit int) ([]ToolsMemoryResult, error) + func (a *ToolsAdapter) RecallFIL(ctx context.Context, query string, limitPerCategory int) (*FILResult, error) + func (a *ToolsAdapter) RememberFIL(ctx context.Context, findings, insights, lessons []string, source string) ([]string, error) + func (a *ToolsAdapter) RetrieveByID(ctx context.Context, id string) (*ToolsObservationItem, error) + type ToolsMemoryResult struct + Category string + Content string + ID string + Score float32 + type ToolsObservationItem struct + Category string + Content string + ID string
Go to main page