task

Aug 2, 2026

Changes in this version

+ var ErrAbandoned = errors.New("worker exited without recording a result")

+ var ErrCanceled = errors.New("canceled")

+ func WorkerProcessName(id string) string

+ type CreateOptions struct

+ Command string

+ WorkspaceID string

+ type State struct

+ Command string

+ Error string

+ ID string

+ PID int

+ Phase string

+ Result *config.Result

+ StartedAt time.Time

+ Status Status

+ Step string

+ UpdatedAt time.Time

+ WorkspaceID string

+ type Status string

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ const StatusSucceeded

+ func (s Status) Terminal() bool

+ type Store struct

+ func NewStore() (*Store, error)

+ func NewStoreAt(dir string) (*Store, error)

+ func (s *Store) Abandoned(state *State) bool

+ func (s *Store) Create(opts CreateOptions) (*Task, error)

+ func (s *Store) Delete(id string, force bool) error

+ func (s *Store) Get(id string) (*State, error)

+ func (s *Store) List() ([]*State, error)

+ func (s *Store) Open(id string) *Task

+ func (s *Store) Reconcile(state *State) *State

+ type Task struct

+ func (t *Task) Cancel() error

+ func (t *Task) Fail(err error) error

+ func (t *Task) HoldWorkerLock() error

+ func (t *Task) ID() string

+ func (t *Task) ReleaseWorkerLockForTest() error

+ func (t *Task) Reporter() status.Reporter

+ func (t *Task) SetPID(pid int) error

+ func (t *Task) SetWorkspaceID(id string) error

+ func (t *Task) Succeed(result *config.Result) error