store

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

type ListFilter struct {
	Status []models.TaskStatus
	Tags   []string
	Limit  int
	Offset int
	// ParentSessionID, when non-empty, restricts results to tasks whose
	// ParentSessionID matches exactly. Used for delegation correlation queries.
	ParentSessionID string
}

type Store interface {
	Save(task *models.Task) error
	Get(id string) (*models.Task, error)
	List(filter ListFilter) ([]*models.Task, error)
	// ListByParentSession returns tasks correlated to the given parent agent
	// session id (see Task.ParentSessionID). Used by delegation phases to find
	// the tasks spawned by a session; no consumer reads it yet.
	ListByParentSession(sessionID string) ([]*models.Task, error)
	Delete(id string) error
	UpdateStatus(id string, status models.TaskStatus) error
	// ClaimForDispatch atomically reserves a pending task for execution by owner
	// and returns whether the claim was won. It is the compare-and-set that makes
	// dispatch safe when several readiness evaluations race for the same task
	// (two dependencies completing at once used to start it twice).
	ClaimForDispatch(id, owner string, expires time.Time) (bool, error)
	// ReleaseClaim drops a task's dispatch claim. Safe to call on a task that
	// holds none.
	ReleaseClaim(id string) error
	Close() error
}