helpers

Documentation

Overview

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

Index

• Variables
• func ComponentsStarted(ctx context.Context, comps []e2etypes.ComponentRunner) error
• func DeleteAndCreateFile(tmpPath, fileName string) (*os.File, error)
• func EpochTickerStartTime(genesis *eth.Genesis) time.Time
• func GraffitiYamlFile(testDir string) (string, error)
• func LogErrorOutput(t *testing.T, file io.Reader, title string, index int)
• func LogOutput(t *testing.T, config *e2etypes.E2EConfig)
• func NewLocalConnection(ctx context.Context, port int) (*grpc.ClientConn, error)
• func NewLocalConnections(ctx context.Context, numConns int) ([]*grpc.ClientConn, func(), error)
• func WaitForTextInFile(file *os.File, text string) error
• func WaitOnNodes(ctx context.Context, nodes []e2etypes.ComponentRunner, nodesStarted func()) error
• func WritePprofFiles(testDir string, index int) error
• type EpochTicker
  • func NewEpochTicker(genesisTime time.Time, secondsPerEpoch uint64) *EpochTicker
  • func (s *EpochTicker) C() <-chan uint64
  • func (s *EpochTicker) Done()

Variables

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, config *e2etypes.E2EConfig)

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.