Versions in this module Expand all Collapse all v0 v0.1.1 Apr 22, 2026 v0.1.0 Apr 14, 2026 Changes in this version + func GetRawConfig(config interface{}) *helper.RawMessage + func NewServicesProvider(database *db.Database, clientPool *clients.ClientPool, ...) types.TaskServices + type TaskScheduler struct + func NewTaskScheduler(log logrus.FieldLogger, services types.TaskServices, variables types.Variables, ...) *TaskScheduler + func (ts *TaskScheduler) AddCleanupTask(options *types.TaskOptions) (types.TaskIndex, error) + func (ts *TaskScheduler) AddRootTask(options *types.TaskOptions) (types.TaskIndex, error) + func (ts *TaskScheduler) CancelTasks(cancelCleanup bool) + func (ts *TaskScheduler) ExecuteTask(ctx context.Context, taskIndex types.TaskIndex, ...) error + func (ts *TaskScheduler) GetAllCleanupTasks() []types.TaskIndex + func (ts *TaskScheduler) GetAllTasks() []types.TaskIndex + func (ts *TaskScheduler) GetRootCleanupTasks() []types.TaskIndex + func (ts *TaskScheduler) GetRootTasks() []types.TaskIndex + func (ts *TaskScheduler) GetServices() types.TaskServices + func (ts *TaskScheduler) GetTaskCount() uint64 + func (ts *TaskScheduler) GetTaskState(taskIndex types.TaskIndex) types.TaskState + func (ts *TaskScheduler) GetTestRunCtx() context.Context + func (ts *TaskScheduler) GetTestRunID() uint64 + func (ts *TaskScheduler) ParseTaskOptions(rawtask helper.IRawMessage) (*types.TaskOptions, error) + func (ts *TaskScheduler) RunTasks(testRunCtx context.Context, timeout time.Duration) error