components

Documentation

Overview

Package components defines utilities to spin up actual beacon node and validator processes as needed by end to end tests.

Index

• func SendAndMineDeposits(keystorePath string, validatorNum, offset int, partial bool) error
• type BeaconNode
  • func NewBeaconNode(config *e2etypes.E2EConfig, index int, enr string) *BeaconNode
  • func (node *BeaconNode) Start(ctx context.Context) error
  • func (node *BeaconNode) Started() <-chan struct{}
• type BeaconNodeSet
  • func NewBeaconNodes(config *e2etypes.E2EConfig) *BeaconNodeSet
  • func (s *BeaconNodeSet) SetENR(enr string)
  • func (s *BeaconNodeSet) Start(ctx context.Context) error
  • func (s *BeaconNodeSet) Started() <-chan struct{}
• type BootNode
  • func NewBootNode() *BootNode
  • func (node *BootNode) ENR() string
  • func (node *BootNode) Start(ctx context.Context) error
  • func (node *BootNode) Started() <-chan struct{}
• type Eth1Node
  • func NewEth1Node() *Eth1Node
  • func (node *Eth1Node) KeystorePath() string
  • func (node *Eth1Node) Start(ctx context.Context) error
  • func (node *Eth1Node) Started() <-chan struct{}
• type SlasherNode
  • func NewSlasherNode(_ *e2etypes.E2EConfig, index int) *SlasherNode
  • func (node *SlasherNode) Start(ctx context.Context) error
  • func (node *SlasherNode) Started() <-chan struct{}
• type SlasherNodeSet
  • func NewSlasherNodeSet(config *e2etypes.E2EConfig) *SlasherNodeSet
  • func (s *SlasherNodeSet) Start(ctx context.Context) error
  • func (s *SlasherNodeSet) Started() <-chan struct{}
• type ValidatorNode
  • func NewValidatorNode(config *e2etypes.E2EConfig, validatorNum, index, offset int) *ValidatorNode
  • func (v *ValidatorNode) Start(ctx context.Context) error
  • func (v *ValidatorNode) Started() <-chan struct{}
• type ValidatorNodeSet
  • func NewValidatorNodeSet(config *e2etypes.E2EConfig) *ValidatorNodeSet
  • func (s *ValidatorNodeSet) Start(ctx context.Context) error
  • func (s *ValidatorNodeSet) Started() <-chan struct{}

Functions

func SendAndMineDeposits

func SendAndMineDeposits(keystorePath string, validatorNum, offset int, partial bool) error

SendAndMineDeposits sends the requested amount of deposits and mines the chain after to ensure the deposits are seen.

Types

type BeaconNode

type BeaconNode struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

BeaconNode represents beacon node.

func NewBeaconNode

func NewBeaconNode(config *e2etypes.E2EConfig, index int, enr string) *BeaconNode

NewBeaconNode creates and returns a beacon node.

func (*BeaconNode) Start

func (node *BeaconNode) Start(ctx context.Context) error

Start starts a fresh beacon node, connecting to all passed in beacon nodes.

func (*BeaconNode) Started

func (node *BeaconNode) Started() <-chan struct{}

Started checks whether beacon node is started and ready to be queried.

type BeaconNodeSet

type BeaconNodeSet struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

BeaconNodeSet represents set of beacon nodes.

func NewBeaconNodes

func NewBeaconNodes(config *e2etypes.E2EConfig) *BeaconNodeSet

NewBeaconNodes creates and returns a set of beacon nodes.

func (*BeaconNodeSet) SetENR

func (s *BeaconNodeSet) SetENR(enr string)

SetENR assigns ENR to the set of beacon nodes.

func (*BeaconNodeSet) Start

func (s *BeaconNodeSet) Start(ctx context.Context) error

Start starts all the beacon nodes in set.

func (*BeaconNodeSet) Started

func (s *BeaconNodeSet) Started() <-chan struct{}

Started checks whether beacon node set is started and all nodes are ready to be queried.

type BootNode

type BootNode struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

BootNode represents boot node.

func NewBootNode

func NewBootNode() *BootNode

NewBootNode creates and returns boot node.

func (*BootNode) ENR

func (node *BootNode) ENR() string

ENR exposes node's ENR.

func (*BootNode) Start

func (node *BootNode) Start(ctx context.Context) error

Start starts a bootnode blocks up until ctx is cancelled.

func (*BootNode) Started

func (node *BootNode) Started() <-chan struct{}

Started checks whether a boot node is started and ready to be queried.

type Eth1Node

type Eth1Node struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

Eth1Node represents ETH1 node.

func NewEth1Node

func NewEth1Node() *Eth1Node

NewEth1Node creates and returns ETH1 node.

func (*Eth1Node) KeystorePath

func (node *Eth1Node) KeystorePath() string

KeystorePath exposes node's keystore path.

func (*Eth1Node) Start

func (node *Eth1Node) Start(ctx context.Context) error

Start starts an ETH1 local dev chain and deploys a deposit contract.

func (*Eth1Node) Started

func (node *Eth1Node) Started() <-chan struct{}

Started checks whether ETH1 node is started and ready to be queried.

type SlasherNode

type SlasherNode struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

SlasherNode represents a slasher node.

func NewSlasherNode

func NewSlasherNode(_ *e2etypes.E2EConfig, index int) *SlasherNode

NewSlasherNode creates and returns slasher node.

func (*SlasherNode) Start

func (node *SlasherNode) Start(ctx context.Context) error

Start starts slasher clients for use within E2E, connected to all beacon nodes.

func (*SlasherNode) Started

func (node *SlasherNode) Started() <-chan struct{}

Started checks whether slasher node is started and ready to be queried.

type SlasherNodeSet

type SlasherNodeSet struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

SlasherNodeSet represents set of slasher nodes.

func NewSlasherNodeSet

func NewSlasherNodeSet(config *e2etypes.E2EConfig) *SlasherNodeSet

NewSlasherNodeSet creates and returns a set of slasher nodes.

func (*SlasherNodeSet) Start

func (s *SlasherNodeSet) Start(ctx context.Context) error

Start starts all the slasher nodes in set.

func (*SlasherNodeSet) Started

func (s *SlasherNodeSet) Started() <-chan struct{}

Started checks whether beacon node set is started and all nodes are ready to be queried.

type ValidatorNode

type ValidatorNode struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

ValidatorNode represents a validator node.

func NewValidatorNode

func NewValidatorNode(config *e2etypes.E2EConfig, validatorNum, index, offset int) *ValidatorNode

NewValidatorNode creates and returns a validator node.

func (*ValidatorNode) Start

func (v *ValidatorNode) Start(ctx context.Context) error

Start starts a validator client.

func (*ValidatorNode) Started

func (v *ValidatorNode) Started() <-chan struct{}

Started checks whether validator node is started and ready to be queried.

type ValidatorNodeSet

type ValidatorNodeSet struct {
	e2etypes.ComponentRunner
	// contains filtered or unexported fields
}

ValidatorNodeSet represents set of validator nodes.

func NewValidatorNodeSet

func NewValidatorNodeSet(config *e2etypes.E2EConfig) *ValidatorNodeSet

NewValidatorNodeSet creates and returns a set of validator nodes.

func (*ValidatorNodeSet) Start

func (s *ValidatorNodeSet) Start(ctx context.Context) error

Start starts the configured amount of validators, also sending and mining their deposits.

func (*ValidatorNodeSet) Started

func (s *ValidatorNodeSet) Started() <-chan struct{}

Started checks whether validator node set is started and all nodes are ready to be queried.