Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

memory

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 13, 2026

Changes in this version

+ func BuildObservationTools(ms *Store) []*agent.Tool

type Store

+ func (s *Store) SetEventBus(bus *eventbus.Bus)

v0.6.0

Mar 17, 2026

v0.5.0

Mar 9, 2026

v0.4.0

Mar 5, 2026

v0.3.0

Feb 28, 2026

Changes in this version

+ func CountMessageTokens(msg session.Message) int

+ func CountMessagesTokens(msgs []session.Message) int

+ func EstimateTokens(text string) int

+ type Buffer struct

+ func NewBuffer(observer *Observer, reflector *Reflector, store *Store, ...) *Buffer

+ func (b *Buffer) SetCompactor(c MessageCompactor)

+ func (b *Buffer) SetReflectionConsolidationThreshold(n int)

+ func (b *Buffer) Start(wg *sync.WaitGroup)

+ func (b *Buffer) Stop()

+ func (b *Buffer) Trigger(sessionKey string)

+ type GraphHooks struct

+ func NewGraphHooks(callback TripleCallback, logger *zap.SugaredLogger) *GraphHooks

+ func (h *GraphHooks) OnObservation(obs Observation, previousObsID string)

+ func (h *GraphHooks) OnReflection(ref Reflection, observationIDs []string)

+ type MessageCompactor func(sessionKey string, upToIndex int, summary string) error

+ type MessageProvider func(sessionKey string) ([]session.Message, error)

+ type Observation struct

+ Content string

+ CreatedAt time.Time

+ ID uuid.UUID

+ SessionKey string

+ SourceEndIndex int

+ SourceStartIndex int

+ TokenCount int

+ type Observer struct

+ func NewObserver(generator TextGenerator, store *Store, logger *zap.SugaredLogger) *Observer

+ func (o *Observer) Observe(ctx context.Context, sessionKey string, messages []session.Message, ...) (*Observation, error)

+ type Reflection struct

+ Content string

+ CreatedAt time.Time

+ Generation int

+ ID uuid.UUID

+ SessionKey string

+ TokenCount int

+ type Reflector struct

+ func NewReflector(generator TextGenerator, store *Store, logger *zap.SugaredLogger) *Reflector

+ func (r *Reflector) Reflect(ctx context.Context, sessionKey string) (*Reflection, error)

+ func (r *Reflector) ReflectOnReflections(ctx context.Context, sessionKey string) (*Reflection, error)

+ type Store struct

+ func NewStore(client *ent.Client, logger *zap.SugaredLogger) *Store

+ func (s *Store) DeleteObservations(ctx context.Context, ids []uuid.UUID) error

+ func (s *Store) DeleteObservationsBySession(ctx context.Context, sessionKey string) error

+ func (s *Store) DeleteReflections(ctx context.Context, ids []uuid.UUID) error

+ func (s *Store) DeleteReflectionsBySession(ctx context.Context, sessionKey string) error

+ func (s *Store) GetObservation(ctx context.Context, id uuid.UUID) (*Observation, error)

+ func (s *Store) GetReflection(ctx context.Context, id uuid.UUID) (*Reflection, error)

+ func (s *Store) ListObservations(ctx context.Context, sessionKey string) ([]Observation, error)

+ func (s *Store) ListRecentObservations(ctx context.Context, sessionKey string, limit int) ([]Observation, error)

+ func (s *Store) ListRecentReflections(ctx context.Context, sessionKey string, limit int) ([]Reflection, error)

+ func (s *Store) ListReflections(ctx context.Context, sessionKey string) ([]Reflection, error)

+ func (s *Store) SaveObservation(ctx context.Context, obs Observation) error

+ func (s *Store) SaveReflection(ctx context.Context, ref Reflection) error

+ func (s *Store) SetEmbedCallback(cb types.EmbedCallback)

+ func (s *Store) SetGraphCallback(cb types.ContentCallback)

+ func (s *Store) SetGraphHooks(hooks *GraphHooks)

+ type TextGenerator interface

+ GenerateText func(ctx context.Context, systemPrompt, userPrompt string) (string, error)

+ type TripleCallback func(triples []graph.Triple)