coordinator

Documentation

Index

• type Config
  • func DefaultConfig() *Config
  • func NewConfig(path string) (*Config, error)
• type Coordinator
  • func NewCoordinator(config *Config, log logrus.FieldLogger, metricsPort int) *Coordinator
  • func (c *Coordinator) ClientPool() *clients.ClientPool
  • func (c *Coordinator) GetTestByRunID(runID uint64) types.Test
  • func (c *Coordinator) GetTestDescriptors() []types.TestDescriptor
  • func (c *Coordinator) GetTestHistory() []types.Test
  • func (c *Coordinator) GetTestQueue() []types.Test
  • func (c *Coordinator) LoadTests(ctx context.Context)
  • func (c *Coordinator) LogScope() *logger.LogScope
  • 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.Test, error)
  • func (c *Coordinator) ValidatorNames() *names.ValidatorNames
  • func (c *Coordinator) WalletManager() *wallet.Manager

Types

type Config

type Config struct {
	// List of execution & consensus clients to use.
	Endpoints []clients.ClientConfig `yaml:"endpoints" json:"endpoints"`

	// WebServer config
	Web *web_types.WebConfig `yaml:"web" json:"web"`

	// Validator names config
	ValidatorNames *names.Config `yaml:"validatorNames" json:"validatorNames"`

	// Global variables
	GlobalVars map[string]interface{} `yaml:"globalVars" json:"globalVars"`

	// List of Test configurations.
	Tests []*types.TestConfig `yaml:"tests" json:"tests"`

	// List of yaml files with test configurations
	ExternalTests []*types.ExternalTestConfig `yaml:"externalTests" json:"externalTests"`
}

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig represents a sane-default configuration.

func NewConfig

func NewConfig(path string) (*Config, error)

type Coordinator

type Coordinator struct {
	// Config is the coordinator configuration.
	Config *Config
	// contains filtered or unexported fields
}

func NewCoordinator

func NewCoordinator(config *Config, log logrus.FieldLogger, metricsPort int) *Coordinator

func (*Coordinator) ClientPool

func (c *Coordinator) ClientPool() *clients.ClientPool

func (*Coordinator) GetTestByRunID

func (c *Coordinator) GetTestByRunID(runID uint64) types.Test

func (*Coordinator) GetTestDescriptors

func (c *Coordinator) GetTestDescriptors() []types.TestDescriptor

func (*Coordinator) GetTestHistory

func (c *Coordinator) GetTestHistory() []types.Test

func (*Coordinator) GetTestQueue

func (c *Coordinator) GetTestQueue() []types.Test

func (*Coordinator) LoadTests

func (c *Coordinator) LoadTests(ctx context.Context)

func (*Coordinator) LogScope

func (c *Coordinator) LogScope() *logger.LogScope

func (*Coordinator) Logger

func (c *Coordinator) Logger() logrus.FieldLogger

func (*Coordinator) Run

func (c *Coordinator) Run(ctx context.Context) error

Run executes the coordinator until completion.

func (*Coordinator) ScheduleTest

func (c *Coordinator) ScheduleTest(descriptor types.TestDescriptor, configOverrides map[string]any, allowDuplicate bool) (types.Test, error)

func (*Coordinator) ValidatorNames

func (c *Coordinator) ValidatorNames() *names.ValidatorNames

func (*Coordinator) WalletManager

func (c *Coordinator) WalletManager() *wallet.Manager