Method Read

flow/agent/react/memory_example/memory/inmem.go:51–56

Read returns decoded messages for the given session; returns nil if absent.

(ctx context.Context, sessionID string)

// Read returns decoded messages for the given session; returns nil if absent.
func (s *InMemoryStore) Read(ctx context.Context, sessionID string) ([]*schema.Message, error) {
	s.mu.RLock()
	b := s.data[sessionID]
	s.mu.RUnlock()
	return DecodeMessages(b)
}

// Query performs a simple substring search on message contents for the session.
func (s *InMemoryStore) Query(ctx context.Context, sessionID, text string, limit int) ([]*schema.Message, error) {