scheduler

Documentation

Index

• func GetRawConfig(config interface{}) *helper.RawMessage
• func NewServicesProvider(database *db.Database, clientPool *clients.ClientPool, ...) types.TaskServices
• type TaskScheduler
  • 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

Functions

func GetRawConfig

func GetRawConfig(config interface{}) *helper.RawMessage

func NewServicesProvider

func NewServicesProvider(database *db.Database, clientPool *clients.ClientPool, walletManager *txmgr.Spamoor, validatorNames *names.ValidatorNames, eventBus *events.EventBus) types.TaskServices

Types

type TaskScheduler

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

func NewTaskScheduler

func NewTaskScheduler(log logrus.FieldLogger, services types.TaskServices, variables types.Variables, testRunID uint64) *TaskScheduler

func (*TaskScheduler) AddCleanupTask

func (ts *TaskScheduler) AddCleanupTask(options *types.TaskOptions) (types.TaskIndex, error)

func (*TaskScheduler) AddRootTask

func (ts *TaskScheduler) AddRootTask(options *types.TaskOptions) (types.TaskIndex, error)

func (*TaskScheduler) CancelTasks

func (ts *TaskScheduler) CancelTasks(cancelCleanup bool)

func (*TaskScheduler) ExecuteTask

func (ts *TaskScheduler) ExecuteTask(ctx context.Context, taskIndex types.TaskIndex, taskWatchFn func(ctx context.Context, cancelFn context.CancelFunc, taskIndex types.TaskIndex)) error

ExecuteTask executes a task this function blocks until the task is executed or the context cancelled

func (*TaskScheduler) GetAllCleanupTasks

func (ts *TaskScheduler) GetAllCleanupTasks() []types.TaskIndex

func (*TaskScheduler) GetAllTasks

func (ts *TaskScheduler) GetAllTasks() []types.TaskIndex

func (*TaskScheduler) GetRootCleanupTasks

func (ts *TaskScheduler) GetRootCleanupTasks() []types.TaskIndex

func (*TaskScheduler) GetRootTasks

func (ts *TaskScheduler) GetRootTasks() []types.TaskIndex

func (*TaskScheduler) GetServices

func (ts *TaskScheduler) GetServices() types.TaskServices

func (*TaskScheduler) GetTaskCount

func (ts *TaskScheduler) GetTaskCount() uint64

func (*TaskScheduler) GetTaskState

func (ts *TaskScheduler) GetTaskState(taskIndex types.TaskIndex) types.TaskState

func (*TaskScheduler) GetTestRunCtx

func (ts *TaskScheduler) GetTestRunCtx() context.Context

func (*TaskScheduler) GetTestRunID

func (ts *TaskScheduler) GetTestRunID() uint64

func (*TaskScheduler) ParseTaskOptions

func (ts *TaskScheduler) ParseTaskOptions(rawtask helper.IRawMessage) (*types.TaskOptions, error)

func (*TaskScheduler) RunTasks

func (ts *TaskScheduler) RunTasks(testRunCtx context.Context, timeout time.Duration) error