test

Nov 3, 2025

Changes in this version

type Descriptor

+ func (d *Descriptor) BasePath() string

Aug 5, 2025

Changes in this version

+ func ValidateTestConfig(config *types.TestConfig) error

Dec 11, 2024

Changes in this version

+ func LoadTestFromDB(database *db.Database, runID int) (types.Test, error)

+ func WrapDBTestRun(database *db.Database, test *db.TestRun) types.Test

Mar 9, 2024

Changes in this version

type Descriptor

+ func (d *Descriptor) Vars() types.Variables

Feb 29, 2024

Changes in this version

+ func LoadExternalTestConfig(ctx context.Context, extTestCfg *types.ExternalTestConfig) (*types.TestConfig, error)

type Descriptor

+ func NewDescriptor(testID, testSrc string, config *types.TestConfig) *Descriptor

Feb 22, 2024

Changes in this version

+ func LoadTestDescriptors(ctx context.Context, localTests []*types.TestConfig, ...) []types.TestDescriptor

+ type Descriptor struct

+ func (d *Descriptor) Config() *types.TestConfig

+ func (d *Descriptor) Err() error

+ func (d *Descriptor) ID() string

+ func (d *Descriptor) Source() string

type Test

+ func (t *Test) AbortTest(skipCleanup bool)

+ func (t *Test) GetTestVariables() types.Variables

+ func (t *Test) RunID() uint64

+ func (t *Test) TestID() string

Jan 31, 2024

Changes in this version

+ func CreateTest(coordinator types.Coordinator, config *Config, variables types.Variables) (types.Test, error)

+ type Config struct

+ CleanupTasks []helper.RawMessage

+ Config map[string]interface{}

+ ConfigVars map[string]string

+ Disable bool

+ Name string

+ Tasks []helper.RawMessage

+ Timeout human.Duration

+ type ExternalConfig struct

+ Config map[string]interface{}

+ ConfigVars map[string]string

+ File string

+ Name string

+ Timeout *human.Duration

+ type Metrics struct

+ CurrentTask *prometheus.GaugeVec

+ TaskDuration *prometheus.GaugeVec

+ TaskInfo *prometheus.GaugeVec

+ TestDuration *prometheus.GaugeVec

+ TestInfo *prometheus.GaugeVec

+ TestResult *prometheus.GaugeVec

+ TotalTasks *prometheus.GaugeVec

+ func NewMetrics(namespace, testName string) Metrics

+ func (m *Metrics) Register()

+ func (m *Metrics) SetTestDuration(duration float64)

+ func (m *Metrics) SetTestInfo(description string)

+ func (m *Metrics) SetTotalTasks(total float64)

+ type TaskScheduler struct

+ func NewTaskScheduler(log logrus.FieldLogger, coordinator types.Coordinator, ...) *TaskScheduler

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

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

+ func (ts *TaskScheduler) ExecuteTask(ctx context.Context, task types.Task, ...) error

+ func (ts *TaskScheduler) GetAllCleanupTasks() []types.Task

+ func (ts *TaskScheduler) GetAllTasks() []types.Task

+ func (ts *TaskScheduler) GetCoordinator() types.Coordinator

+ func (ts *TaskScheduler) GetRootCleanupTasks() []types.Task

+ func (ts *TaskScheduler) GetRootTasks() []types.Task

+ func (ts *TaskScheduler) GetTaskCount() int

+ func (ts *TaskScheduler) GetTaskResultUpdateChan(task types.Task, oldResult types.TaskResult) <-chan bool

+ func (ts *TaskScheduler) GetTaskStatus(task types.Task) *types.TaskStatus

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

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

+ func (ts *TaskScheduler) WatchTaskPass(ctx context.Context, cancelFn context.CancelFunc, task types.Task)

+ type Test struct

+ func (t *Test) GetTaskScheduler() types.TaskScheduler

+ func (t *Test) Logger() logrus.FieldLogger

+ func (t *Test) Name() string

+ func (t *Test) Percent() float64

+ func (t *Test) Run(ctx context.Context) error

+ func (t *Test) StartTime() time.Time

+ func (t *Test) Status() types.TestStatus

+ func (t *Test) StopTime() time.Time

+ func (t *Test) Timeout() time.Duration

+ func (t *Test) Validate() error