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 + type Coordinator interface + ClientPool func() *clients.ClientPool + Database func() *db.Database + DeleteTestRun func(runID uint64) error + EventBus func() *events.EventBus + GetTestByRunID func(runID uint64) Test + GetTestHistory func(testID string, firstRunID uint64, offset uint64, limit uint64) ([]Test, uint64) + GetTestQueue func() []Test + GlobalVariables func() Variables + LogReader func() logger.LogReader + Logger func() logrus.FieldLogger + ScheduleTest func(descriptor TestDescriptor, configOverrides map[string]any, allowDuplicate bool, ...) (TestRunner, error) + TestRegistry func() TestRegistry + ValidatorNames func() *names.ValidatorNames + WalletManager func() *txmgr.Spamoor + type ExternalTestConfig struct + Config map[string]interface{} + ConfigVars map[string]string + File string + ID string + Name string + Schedule *TestSchedule + Timeout *helper.Duration + YamlSource string + type Task interface + Config func() any + Execute func(ctx context.Context) error + LoadConfig func() error + Timeout func() time.Duration + type TaskContext struct + EmitEvent func(eventType string, data any) + Index TaskIndex + Logger *logger.LogScope + NewTask func(options *TaskOptions, variables Variables) (TaskIndex, error) + Outputs Variables + ReportProgress func(percent float64, message string) + Scheduler TaskSchedulerRunner + SetResult func(result TaskResult) + Vars Variables + type TaskDescriptor struct + Aliases []string + Category string + Config any + Description string + Name string + NewTask func(ctx *TaskContext, options *TaskOptions) (Task, error) + Outputs []TaskOutputDefinition + type TaskIndex uint64 + type TaskOptions struct + Config *helper.RawMessage + ConfigVars map[string]string + ID string + If string + Name string + Timeout helper.Duration + Title string + type TaskOutputDefinition struct + Description string + Name string + Type string + type TaskResult uint8 + const TaskResultFailure + const TaskResultNone + const TaskResultSuccess + type TaskScheduler interface + GetAllCleanupTasks func() []TaskIndex + GetAllTasks func() []TaskIndex + GetRootCleanupTasks func() []TaskIndex + GetRootTasks func() []TaskIndex + GetTaskCount func() uint64 + GetTaskState func(taskIndex TaskIndex) TaskState + type TaskSchedulerRunner interface + ExecuteTask func(ctx context.Context, taskIndex TaskIndex, ...) error + GetServices func() TaskServices + GetTestRunCtx func() context.Context + GetTestRunID func() uint64 + ParseTaskOptions func(rawtask helper.IRawMessage) (*TaskOptions, error) + type TaskServices interface + ClientPool func() *clients.ClientPool + Database func() *db.Database + EventBus func() *events.EventBus + ValidatorNames func() *names.ValidatorNames + WalletManager func() *txmgr.Spamoor + type TaskState interface + Config func() any + Description func() string + GetScopeOwner func() TaskIndex + GetTaskResultUpdateChan func(oldResult TaskResult) <-chan bool + GetTaskStatus func() *TaskStatus + GetTaskStatusVars func() Variables + ID func() string + Index func() TaskIndex + Name func() string + ParentIndex func() TaskIndex + Timeout func() time.Duration + Title func() string + type TaskStatus struct + Error error + Index TaskIndex + IsRunning bool + IsSkipped bool + IsStarted bool + Logger logger.LogReader + ParentIndex TaskIndex + Progress float64 + ProgressMessage string + Result TaskResult + StartTime time.Time + StopTime time.Time + type Test interface + AbortTest func(skipCleanup bool) + GetTaskScheduler func() TaskScheduler + Name func() string + RunID func() uint64 + StartTime func() time.Time + Status func() TestStatus + StopTime func() time.Time + TestID func() string + Timeout func() time.Duration + type TestConfig struct + CleanupTasks []helper.RawMessage + Config map[string]interface{} + ConfigVars map[string]string + ID string + Name string + Schedule *TestSchedule + Tasks []helper.RawMessage + Timeout helper.Duration + type TestDescriptor interface + BasePath func() string + Config func() *TestConfig + Err func() error + ID func() string + Source func() string + Vars func() Variables + type TestRegistry interface + AddExternalTest func(ctx context.Context, extTestConfig *ExternalTestConfig) (TestDescriptor, error) + AddLocalTest func(testConfig *TestConfig) (TestDescriptor, error) + AddLocalTestWithYaml func(testConfig *TestConfig, yamlSource string) (TestDescriptor, error) + DeleteTest func(testID string) error + GetTestDescriptors func() []TestDescriptor + type TestRunner interface + GetTestVariables func() Variables + Logger func() logrus.FieldLogger + Run func(ctx context.Context) error + Validate func() error + type TestSchedule struct + Cron []string + SkipQueue bool + Startup bool + type TestStatus string + const TestStatusAborted + const TestStatusFailure + const TestStatusPending + const TestStatusRunning + const TestStatusSkipped + const TestStatusSuccess + type Variables interface + ConsumeVars func(config interface{}, consumeMap map[string]string) error + CopyVars func(source Variables, copyMap map[string]string) error + GetSubScope func(name string) Variables + GetVar func(name string) interface{} + GetVarsMap func(varsMap map[string]any, skipParent bool) map[string]any + LookupVar func(name string) (interface{}, bool) + NewScope func() Variables + ResolvePlaceholders func(str string) string + ResolveQuery func(query string) (interface{}, bool, error) + SetDefaultVar func(name string, value interface{}) + SetSubScope func(name string, subScope Variables) + SetVar func(name string, value interface{})
Go to main page