coordinator

Documentation

Index

• type Config
  • func DefaultConfig() *Config
  • func NewConfig(path string) (*Config, error)
• type Coordinator
  • func NewCoordinator(config *Config, log logrus.FieldLogger, metricsPort, lameDuckSeconds int) *Coordinator
  • func (c *Coordinator) ClientPool() *clients.ClientPool
  • func (c *Coordinator) GetTests() []types.Test
  • func (c *Coordinator) LogScope() *logger.LogScope
  • func (c *Coordinator) Logger() logrus.FieldLogger
  • func (c *Coordinator) NewVariables(parentScope types.Variables) types.Variables
  • func (c *Coordinator) Run(ctx context.Context) 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 []*test.Config `yaml:"tests" json:"tests"`

	// List of yaml files with test configurations
	ExternalTests []*test.ExternalConfig `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, lameDuckSeconds int) *Coordinator

func (*Coordinator) ClientPool

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

func (*Coordinator) GetTests

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

func (*Coordinator) LogScope

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

func (*Coordinator) Logger

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

func (*Coordinator) NewVariables

func (c *Coordinator) NewVariables(parentScope types.Variables) types.Variables

func (*Coordinator) Run

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

Run executes the coordinator until completion.

func (*Coordinator) ValidatorNames

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

func (*Coordinator) WalletManager

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