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 Config struct + AI *web_types.AIConfig + Coordinator *CoordinatorConfig + Database *db.DatabaseConfig + Endpoints []clients.ClientConfig + ExternalTests []*types.ExternalTestConfig + GlobalVars map[string]any + Tests []*types.TestConfig + ValidatorNames *names.Config + Web *web_types.WebConfig + func DefaultConfig() *Config + func NewConfig(path string) (*Config, error) + func (c *Config) Validate() error + type Coordinator struct + Config *Config + func NewCoordinator(config *Config, log logrus.FieldLogger, metricsPort int) *Coordinator + func (c *Coordinator) ClientPool() *clients.ClientPool + func (c *Coordinator) Database() *db.Database + func (c *Coordinator) DeleteTestRun(runID uint64) error + func (c *Coordinator) EventBus() *events.EventBus + func (c *Coordinator) GetTestByRunID(runID uint64) types.Test + func (c *Coordinator) GetTestHistory(testID string, firstRunID, offset, limit uint64) (tests []types.Test, totalTests uint64) + func (c *Coordinator) GetTestQueue() []types.Test + func (c *Coordinator) GlobalVariables() types.Variables + func (c *Coordinator) LogReader() logger.LogReader + func (c *Coordinator) Logger() logrus.FieldLogger + func (c *Coordinator) Run(ctx context.Context) error + func (c *Coordinator) ScheduleTest(descriptor types.TestDescriptor, configOverrides map[string]any, ...) (types.TestRunner, error) + func (c *Coordinator) TestRegistry() types.TestRegistry + func (c *Coordinator) ValidatorNames() *names.ValidatorNames + func (c *Coordinator) WalletManager() *txmgr.Spamoor + type CoordinatorConfig struct + MaxConcurrentTests uint64 + TestRetentionTime helper.Duration + func (c *CoordinatorConfig) Validate() error + type TestRegistry struct + func NewTestRegistry(coordinator types.Coordinator) *TestRegistry + func (c *TestRegistry) AddExternalTest(ctx context.Context, extTestCfg *types.ExternalTestConfig) (types.TestDescriptor, error) + func (c *TestRegistry) AddLocalTest(testConfig *types.TestConfig) (types.TestDescriptor, error) + func (c *TestRegistry) AddLocalTestWithYaml(testConfig *types.TestConfig, yamlSource string) (types.TestDescriptor, error) + func (c *TestRegistry) DeleteTest(testID string) error + func (c *TestRegistry) GetTestDescriptors() []types.TestDescriptor + func (c *TestRegistry) LoadTests(ctx context.Context, local []*types.TestConfig, ...) + type TestRunner struct + func NewTestRunner(coordinator types.Coordinator, lastRunID uint64) *TestRunner + func (c *TestRunner) GetTestByRunID(runID uint64) types.Test + func (c *TestRunner) GetTestQueue() []types.Test + func (c *TestRunner) RemoveTestFromQueue(runID uint64) bool + func (c *TestRunner) RunOffQueueTestExecutionLoop(ctx context.Context) + func (c *TestRunner) RunTestCleanup(ctx context.Context, retentionTime time.Duration) + func (c *TestRunner) RunTestExecutionLoop(ctx context.Context, concurrencyLimit uint64) + func (c *TestRunner) RunTestScheduler(ctx context.Context) + func (c *TestRunner) ScheduleTest(descriptor types.TestDescriptor, configOverrides map[string]any, ...) (types.TestRunner, error)
Go to main page