helpers

package
v2.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 5, 2021 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Overview

Package helpers defines helper functions to peer into end to end processes and kill processes as needed.

Index

Constants

View Source
const (
	AltairE2EForkEpoch = 6
)

Variables

View Source
var Graffiti = []string{"Sushi", "Ramen", "Takoyaki"}

Graffiti is a list of sample graffiti strings.

Functions

func ComponentsStarted

func ComponentsStarted(ctx context.Context, comps []e2etypes.ComponentRunner) error

ComponentsStarted checks, sequentially, each provided component, blocks until all of the components are ready.

func DeleteAndCreateFile

func DeleteAndCreateFile(tmpPath, fileName string) (*os.File, error)

DeleteAndCreateFile checks if the file path given exists, if it does, it deletes it and creates a new file. If not, it just creates the requested file.

func EpochTickerStartTime

func EpochTickerStartTime(genesis *eth.Genesis) time.Time

EpochTickerStartTime calculates the best time to start epoch ticker for a given genesis.

func GraffitiYamlFile

func GraffitiYamlFile(testDir string) (string, error)

GraffitiYamlFile outputs graffiti YAML file into a testing directory.

func LogErrorOutput

func LogErrorOutput(t *testing.T, file io.Reader, title string, index int)

LogErrorOutput logs the output of a specific file.

func LogOutput

func LogOutput(t *testing.T)

LogOutput logs the output of all log files made.

func NewLocalConnection

func NewLocalConnection(ctx context.Context, port int) (*grpc.ClientConn, error)

NewLocalConnection creates and returns GRPC connection on a given localhost port.

func NewLocalConnections

func NewLocalConnections(ctx context.Context, numConns int) ([]*grpc.ClientConn, func(), error)

NewLocalConnections returns number of GRPC connections, along with function to close all of them.

func WaitForTextInFile

func WaitForTextInFile(file *os.File, text string) error

WaitForTextInFile checks a file every polling interval for the text requested.

func WaitOnNodes

func WaitOnNodes(ctx context.Context, nodes []e2etypes.ComponentRunner, nodesStarted func()) error

WaitOnNodes waits on nodes to complete execution, accepts function that will be called when all nodes are ready.

func WritePprofFiles

func WritePprofFiles(testDir string, index int) error

WritePprofFiles writes the memory heap and cpu profile files to the test path.

Types

type EpochTicker

type EpochTicker struct {
	// contains filtered or unexported fields
}

EpochTicker is a special ticker for timing epoch changes. The channel emits over the epoch interval, and ensures that the ticks are in line with the genesis time. This means that the duration between the ticks and the genesis time are always a multiple of the epoch duration. In addition, the channel returns the new epoch number.

func NewEpochTicker

func NewEpochTicker(genesisTime time.Time, secondsPerEpoch uint64) *EpochTicker

NewEpochTicker starts the EpochTicker.

func (*EpochTicker) C

func (s *EpochTicker) C() <-chan uint64

C returns the ticker channel. Call Cancel afterwards to ensure that the goroutine exits cleanly.

func (*EpochTicker) Done

func (s *EpochTicker) Done()

Done should be called to clean up the ticker.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL