harmonytask

May 28, 2024

Changes in this version

+ const WorkSourceIAmBored

+ const WorkSourcePoller

+ const WorkSourceRecover

+ var POLL_NEXT_DURATION = 100 * time.Millisecond

+ func SingletonTaskAdder(minInterval time.Duration, task TaskInterface) func(AddTaskFunc) error

type TaskEngine

+ WorkOrigin string

type TaskTypeDetails

+ IAmBored func(AddTaskFunc) error

Jan 11, 2024

Changes in this version

+ var CLEANUP_FREQUENCY = 5 * time.Minute

+ var FOLLOW_FREQUENCY = 1 * time.Minute

+ var POLL_DURATION = time.Second * 3

+ type AddTaskFunc func(extraInfo func(TaskID, *harmonydb.Tx) (shouldCommit bool, seriousError error))

+ type TaskEngine struct

+ func New(db *harmonydb.DB, impls []TaskInterface, hostnameAndPort string) (*TaskEngine, error)

+ func (e *TaskEngine) GracefullyTerminate(deadline time.Duration)

+ func (e *TaskEngine) ResourcesAvailable() resources.Resources

+ type TaskID int

+ type TaskInterface interface

+ Adder func(AddTaskFunc)

+ CanAccept func([]TaskID, *TaskEngine) (*TaskID, error)

+ Do func(taskID TaskID, stillOwned func() bool) (done bool, err error)

+ TypeDetails func() TaskTypeDetails

+ type TaskTypeDetails struct

+ Cost resources.Resources

+ Follows map[string]func(TaskID, AddTaskFunc) (bool, error)

+ Max int

+ MaxFailures uint

+ Name string