Versions in this module Expand all Collapse all v1 v1.3.0 Jun 1, 2026 Changes in this version + type GraphMemoryOption func(*GraphMemoryStore) + func WithSalienceConfig(cfg memory.SalienceConfig) GraphMemoryOption + type GraphMemoryStore struct + func NewGraphMemoryStore(db *sql.DB, tc memory.TokenCounter, tracer observability.Tracer, ...) *GraphMemoryStore + func (s *GraphMemoryStore) Close() error + func (s *GraphMemoryStore) Consolidate(ctx context.Context, memoryIDs []string, consolidated *memory.Memory) (*memory.Memory, error) + func (s *GraphMemoryStore) ContextFor(ctx context.Context, opts memory.ContextForOpts) (*memory.EntityRecall, error) + func (s *GraphMemoryStore) CreateEntity(ctx context.Context, entity *memory.Entity) (*memory.Entity, error) + func (s *GraphMemoryStore) DecayAll(ctx context.Context, agentID string, decayFactor float64) error + func (s *GraphMemoryStore) DeleteEntity(ctx context.Context, agentID, name string) error + func (s *GraphMemoryStore) Forget(ctx context.Context, memoryID string) error + func (s *GraphMemoryStore) GetEntity(ctx context.Context, agentID, name string) (*memory.Entity, error) + func (s *GraphMemoryStore) GetLineage(ctx context.Context, memoryID string) ([]*memory.MemoryLineage, error) + func (s *GraphMemoryStore) GetMemory(ctx context.Context, agentID, memoryID string) (*memory.Memory, error) + func (s *GraphMemoryStore) GetStats(ctx context.Context, agentID string) (*memory.GraphStats, error) + func (s *GraphMemoryStore) ListEdgesFrom(ctx context.Context, entityID string) ([]*memory.Edge, error) + func (s *GraphMemoryStore) ListEdgesTo(ctx context.Context, entityID string) ([]*memory.Edge, error) + func (s *GraphMemoryStore) ListEntities(ctx context.Context, agentID, entityType string, limit, offset int) ([]*memory.Entity, int, error) + func (s *GraphMemoryStore) Neighbors(ctx context.Context, entityID string, relation string, direction string, ...) ([]*memory.Edge, error) + func (s *GraphMemoryStore) Recall(ctx context.Context, opts memory.RecallOpts) ([]*memory.Memory, error) + func (s *GraphMemoryStore) Relate(ctx context.Context, edge *memory.Edge) (*memory.Edge, error) + func (s *GraphMemoryStore) Remember(ctx context.Context, mem *memory.Memory) (*memory.Memory, error) + func (s *GraphMemoryStore) SearchEntities(ctx context.Context, agentID, query string, limit int) ([]*memory.Entity, error) + func (s *GraphMemoryStore) Supersede(ctx context.Context, oldMemoryID string, newMem *memory.Memory) (*memory.Memory, error) + func (s *GraphMemoryStore) TouchMemories(ctx context.Context, memoryIDs []string) error + func (s *GraphMemoryStore) Unrelate(ctx context.Context, sourceID, targetID, relation string) error + func (s *GraphMemoryStore) UpdateEntity(ctx context.Context, entity *memory.Entity) (*memory.Entity, error) + func (s *GraphMemoryStore) VectorRecall(ctx context.Context, opts memory.VectorRecallOpts) ([]*memory.Memory, error) + type TaskStore struct + func NewTaskStore(db *sql.DB, tracer observability.Tracer) *TaskStore + func (s *TaskStore) AddDependency(ctx context.Context, dep *task.TaskDependency) error + func (s *TaskStore) ClaimTask(ctx context.Context, taskID, agentID, sessionID string) (*task.Task, error) + func (s *TaskStore) Close() error + func (s *TaskStore) CloseTask(ctx context.Context, taskID, reason string) (*task.Task, error) + func (s *TaskStore) CreateBoard(ctx context.Context, board *task.TaskBoard) (*task.TaskBoard, error) + func (s *TaskStore) CreateTask(ctx context.Context, t *task.Task) (*task.Task, error) + func (s *TaskStore) DeleteTask(ctx context.Context, id string) error + func (s *TaskStore) GetBlockedTasks(ctx context.Context, boardID string) ([]*task.Task, error) + func (s *TaskStore) GetBoard(ctx context.Context, id string) (*task.TaskBoard, error) + func (s *TaskStore) GetDependencies(ctx context.Context, taskID string) ([]*task.TaskDependency, error) + func (s *TaskStore) GetDependents(ctx context.Context, taskID string) ([]*task.TaskDependency, error) + func (s *TaskStore) GetHistory(ctx context.Context, taskID string) ([]*task.TaskHistoryEntry, error) + func (s *TaskStore) GetReadyFront(ctx context.Context, boardID string, opts task.ReadyFrontOpts) ([]*task.Task, error) + func (s *TaskStore) GetTask(ctx context.Context, id string) (*task.Task, error) + func (s *TaskStore) GetTaskByIdempotencyKey(ctx context.Context, key string) (*task.Task, error) + func (s *TaskStore) HasOpenSkillTasks(ctx context.Context, skillName, sessionID string) (bool, error) + func (s *TaskStore) ListBoards(ctx context.Context) ([]*task.TaskBoard, error) + func (s *TaskStore) ListBySkillRun(ctx context.Context, skillName, sessionID string) ([]*task.Task, error) + func (s *TaskStore) ListTasks(ctx context.Context, opts task.ListTasksOpts) ([]*task.Task, int, error) + func (s *TaskStore) RecordHistory(ctx context.Context, entry *task.TaskHistoryEntry) error + func (s *TaskStore) ReleaseTask(ctx context.Context, taskID, sessionID string) (*task.Task, error) + func (s *TaskStore) RemoveDependency(ctx context.Context, fromTaskID, toTaskID string) error + func (s *TaskStore) TransitionTask(ctx context.Context, taskID string, newStatus loomv1.TaskStatus) (*task.Task, error) + func (s *TaskStore) UpdateTask(ctx context.Context, t *task.Task, _ []string) (*task.Task, error) v1.2.0 Mar 19, 2026 Changes in this version + func Backup(dbPath string) (backupPath string, err error) + func VerifyBackup(backupPath string) error + type Migration struct + Description string + DownSQL string + UpSQL string + Version int + type Migrator struct + func NewMigrator(db *sql.DB, tracer observability.Tracer) (*Migrator, error) + func (m *Migrator) CurrentVersion(ctx context.Context) (int, error) + func (m *Migrator) MigrateDown(ctx context.Context, steps int) error + func (m *Migrator) MigrateUp(ctx context.Context) error + func (m *Migrator) PendingMigrations(ctx context.Context) ([]Migration, error)
Go to main page