test_env

Aug 6, 2024

Changes in this version

type PostgresDb

+ func (pg *PostgresDb) ExecPgDumpFromContainer(writer io.Writer) error

+ func (pg *PostgresDb) ExecPgDumpFromLocal(stdout io.Writer) error

Aug 5, 2024

Changes in this version

+ type EthGenesisGenerator struct

+ func (g *EthGenesisGenerator) GetGeneratedDataContainerDir() string

+ func (g *EthGenesisGenerator) StartContainer() error

+ func (g *EthGenesisGenerator) WithTestInstance(t *testing.T) *EthGenesisGenerator

Jul 10, 2024

Changes in this version

type EnvComponent

+ StartupTimeout time.Duration

type EnvComponentOption

+ func WithStartupTimeout(timeout time.Duration) EnvComponentOption

+ type Reth struct

+ ExternalExecutionURL string

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalExecutionURL string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewRethEth2(networks []string, chainConfig *config.EthereumChainConfig, ...) (*Reth, error)

+ func (g *Reth) GetContainer() *tc.Container

+ func (g *Reth) GetContainerName() string

+ func (g *Reth) GetEthereumVersion() config.EthereumVersion

+ func (g *Reth) GetExternalExecutionURL() string

+ func (g *Reth) GetExternalHttpUrl() string

+ func (g *Reth) GetExternalWsUrl() string

+ func (g *Reth) GetInternalExecutionURL() string

+ func (g *Reth) GetInternalHttpUrl() string

+ func (g *Reth) GetInternalWsUrl() string

+ func (g *Reth) GethConsensusMechanism() ConsensusMechanism

+ func (g *Reth) StartContainer() (blockchain.EVMNetwork, error)

+ func (g *Reth) WaitUntilChainIsReady(ctx context.Context, waitTime time.Duration) error

+ func (g *Reth) WithTestInstance(t *testing.T) ExecutionClient

Jun 20, 2024

Changes in this version

type Killgrave

+ func (k *Killgrave) GetReceivedRequests() ([]RequestData, error)

+ type RequestData struct

+ Body string

+ Header map[string][]string

+ Host string

+ Method string

+ URL string

Jun 7, 2024

Changes in this version

type PostgresDbOption

+ func WithPostgresDbLogStream(ls *logstream.LogStream) PostgresDbOption

May 8, 2024

Changes in this version

type EnvComponent

+ LogLevel string

type EnvComponentOption

+ func WithLogLevel(logLevel string) EnvComponentOption

type EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithNodeLogLevel(nodeLogLevel string) *EthereumNetworkBuilder

May 6, 2024

Changes in this version

type EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithExistingConfigFromEnvVar() *EthereumNetworkBuilder

Apr 3, 2024

Changes in this version

type EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithLogStream(ls *logstream.LogStream) *EthereumNetworkBuilder

Mar 26, 2024

Changes in this version

type RpcProvider

+ func NewRPCProvider(privateHttpUrls, privateWsUrls, publiclHttpUrls, publicWsUrls []string) RpcProvider

Mar 15, 2024

Changes in this version

+ const AUTOMATIC_LATEST_TAG

+ const AUTOMATIC_STABLE_LATEST_TAG

+ const DEFAULT_EVM_NODE_HTTP_PORT

+ const DEFAULT_EVM_NODE_WS_PORT

+ const MsgInvalidDockerImageFormat

+ const MsgUnsupportedDockerImage

+ const MsgUnsupportedExecutionLayer

+ var ErrMissingEthereumVersion = errors.New("ethereum version is required")

+ var MsgMismatchedExecutionClient = "you provided a custom docker image for %s execution client, but explicitly set a execution client to %s. Make them match or remove one or the other"

+ var UNSUPPORTED_VERSIONS = []UnsupportedVersion

+ func FetchLatestEthereumClientDockerImageVersionIfNeed(dockerImageWithVersion string) (string, error)

+ func GetComparableVersionFromDockerImage(imageWithVersion string) (int, error)

+ func GetGithubRepositoryFromEthereumClientDockerImage(imageWithVersion string) (string, error)

+ func IsDockerImageVersionSupported(imageWithVersion string) (bool, string, error)

+ func UniqueStringSlice(slice []string) []string

type Besu

+ func NewBesuEth1(networks []string, chainConfig *EthereumChainConfig, ...) (*Besu, error)

+ func NewBesuEth2(networks []string, chainConfig *EthereumChainConfig, ...) (*Besu, error)

+ func (g *Besu) GetEthereumVersion() EthereumVersion

+ func (g *Besu) GethConsensusMechanism() ConsensusMechanism

+ type ConsensusMechanism string

+ const ConsensusMechanism_PoA

+ const ConsensusMechanism_PoS

+ const ConsensusMechanism_PoW

type ContainerType

+ const ContainerType_ConsensusLayer

+ const ContainerType_ConsensusValidator

+ const ContainerType_ExecutionLayer

type EnvComponent

+ WasRecreated bool

type Erigon

+ func NewErigonEth1(networks []string, chainConfig *EthereumChainConfig, ...) (*Erigon, error)

+ func NewErigonEth2(networks []string, chainConfig *EthereumChainConfig, ...) (*Erigon, error)

+ func (g *Erigon) GetEthereumVersion() EthereumVersion

+ func (g *Erigon) GethConsensusMechanism() ConsensusMechanism

type EthereumNetwork

+ EthereumVersion *EthereumVersion

type EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithEthereumVersion(ethereumVersion EthereumVersion) *EthereumNetworkBuilder

+ type EthereumVersion string

+ const EthereumVersion_Eth1

+ const EthereumVersion_Eth1_Legacy

+ const EthereumVersion_Eth2

+ const EthereumVersion_Eth2_Legacy

+ func GetEthereumVersionFromImage(executionLayer ExecutionLayer, imageWithVersion string) (EthereumVersion, error)

type ExecutionClient

+ GetEthereumVersion func() EthereumVersion

+ GethConsensusMechanism func() ConsensusMechanism

type ExecutionLayer

+ func GetExecutionLayerFromDockerImage(imageWithVersion string) (ExecutionLayer, error)

type Geth

+ ExternalExecutionURL string

+ InternalExecutionURL string

+ func NewGethEth1(networks []string, chainConfig *EthereumChainConfig, ...) *Geth

+ func NewGethEth2(networks []string, chainConfig *EthereumChainConfig, ...) (*Geth, error)

+ func (g *Geth) GetContainer() *tc.Container

+ func (g *Geth) GetContainerName() string

+ func (g *Geth) GetEthereumVersion() EthereumVersion

+ func (g *Geth) GetExternalExecutionURL() string

+ func (g *Geth) GetExternalHttpUrl() string

+ func (g *Geth) GetExternalWsUrl() string

+ func (g *Geth) GetInternalExecutionURL() string

+ func (g *Geth) GetInternalHttpUrl() string

+ func (g *Geth) GetInternalWsUrl() string

+ func (g *Geth) GethConsensusMechanism() ConsensusMechanism

+ func (g *Geth) WaitUntilChainIsReady(ctx context.Context, waitTime time.Duration) error

type Nethermind

+ func NewNethermindEth1(networks []string, chainConfig *EthereumChainConfig, ...) (*Nethermind, error)

+ func NewNethermindEth2(networks []string, generatedDataHostDir string, consensusLayer ConsensusLayer, ...) (*Nethermind, error)

+ func (g *Nethermind) GetEthereumVersion() EthereumVersion

+ func (g *Nethermind) GethConsensusMechanism() ConsensusMechanism

type PostgresDb

+ func (pg *PostgresDb) RestartContainer() error

+ type UnsupportedVersion struct

+ DockerImage string

+ Reason string

+ type ValKeysGenerator struct

+ func (g *ValKeysGenerator) StartContainer() error

+ func (g *ValKeysGenerator) WithTestInstance(t *testing.T) *ValKeysGenerator

Feb 28, 2024

Changes in this version

+ const UnsopportedForkErr

type EthereumChainConfig

+ HardForkEpochs map[string]int

+ func (c *EthereumChainConfig) ValidateHardForks() error

Jan 19, 2024

Changes in this version

type ContainerType

+ const ContainerType_GenesisGenerator

+ const ContainerType_ValKeysGenerator

type EnvComponent

+ func (ec *EnvComponent) GetImageWithVersion() string

type EnvComponentOption

+ func WithContainerImageWithVersion(imageWithVersion string) EnvComponentOption

type EthereumChainConfig

+ func (c *EthereumChainConfig) ApplyOverrides(from *EthereumChainConfig) error

+ func (c *EthereumChainConfig) Default() error

type EthereumNetwork

+ CustomDockerImages map[ContainerType]string

+ func (en *EthereumNetwork) ApplyOverrides(from *EthereumNetwork) error

+ func (en *EthereumNetwork) Validate() error

type EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithCustomDockerImages(newImages map[ContainerType]string) *EthereumNetworkBuilder

Jan 18, 2024

Changes in this version

type Killgrave

+ func (k *Killgrave) SetAnyValueResponse(path string, methods []string, v interface{}) error

Jan 17, 2024

Changes in this version

type EnvComponent

+ LogStream *logstream.LogStream

+ PostStartsHooks []tc.ContainerHook

+ PostStopsHooks []tc.ContainerHook

+ PreTerminatesHooks []tc.ContainerHook

+ func (ec *EnvComponent) SetDefaultHooks()

type EnvComponentOption

+ func WithLogStream(ls *logstream.LogStream) EnvComponentOption

+ func WithPostStartsHooks(hooks ...tc.ContainerHook) EnvComponentOption

+ func WithPostStopsHooks(hooks ...tc.ContainerHook) EnvComponentOption

+ func WithPreTerminatesHooks(hooks ...tc.ContainerHook) EnvComponentOption

Dec 7, 2023

Changes in this version

+ const CONFIG_ENV_VAR_NAME

+ const EXEC_CLIENT_ENV_VAR_NAME

+ var ACCOUNT_KEYSTORE_FILE_INSIDE_CONTAINER = fmt.Sprintf("%s/account_key", KEYSTORE_DIR_LOCATION_INSIDE_CONTAINER)

+ var ACCOUNT_PASSWORD_FILE_INSIDE_CONTAINER = fmt.Sprintf("%s/account_password.txt", GENERATED_DATA_DIR_INSIDE_CONTAINER)

+ var ETH2_EXECUTION_PORT = "8551"

+ var ErrConsensusLayerNotAllowed = errors.New("consensus layer is not allowed for PoW")

+ var ErrMissingConsensusLayer = errors.New("consensus layer is required for PoS")

+ var ErrMissingConsensusType = errors.New("consensus type is required")

+ var ErrMissingExecClientEnvVar = fmt.Errorf(...)

+ var ErrMissingExecutionLayer = errors.New("execution layer is required")

+ var ErrTestConfigNotSaved = errors.New("could not save test env config")

+ var GENERATED_DATA_DIR_INSIDE_CONTAINER = "/data/custom_config_data"

+ var GENERATED_VALIDATOR_KEYS_DIR_INSIDE_CONTAINER = "/keys"

+ var JWT_SECRET_FILE_LOCATION_INSIDE_CONTAINER = fmt.Sprintf("%s/jwtsecret", GENERATED_DATA_DIR_INSIDE_CONTAINER)

+ var KEYSTORE_DIR_LOCATION_INSIDE_CONTAINER = fmt.Sprintf("%s/keystore", GENERATED_DATA_DIR_INSIDE_CONTAINER)

+ var NODE_0_DIR_INSIDE_CONTAINER = fmt.Sprintf("%s/node-0", GENERATED_VALIDATOR_KEYS_DIR_INSIDE_CONTAINER)

+ var VALIDATOR_BIP39_MNEMONIC = "giant issue aisle success illegal bike spike question tent bar rely arctic volcano long crawl hungry vocal artwork sniff fantasy very lucky have athlete"

+ var VALIDATOR_WALLET_PASSWORD_FILE_INSIDE_CONTAINER = fmt.Sprintf("%s/wallet_password.txt", GENERATED_DATA_DIR_INSIDE_CONTAINER)

+ var WALLET_PASSWORD = "password"

+ type AfterGenesisHelper struct

+ func NewInitHelper(chainConfig EthereumChainConfig, customConfigDataDir string, ...) *AfterGenesisHelper

+ func (g *AfterGenesisHelper) StartContainer() error

+ func (g *AfterGenesisHelper) WithTestInstance(t *testing.T) *AfterGenesisHelper

+ type Besu struct

+ ExternalExecutionURL string

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalExecutionURL string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewBesu(networks []string, chainConfg *EthereumChainConfig, ...) (*Besu, error)

+ func (g *Besu) GetContainer() *tc.Container

+ func (g *Besu) GetContainerName() string

+ func (g *Besu) GetContainerType() ContainerType

+ func (g *Besu) GetExternalExecutionURL() string

+ func (g *Besu) GetExternalHttpUrl() string

+ func (g *Besu) GetExternalWsUrl() string

+ func (g *Besu) GetImage() string

+ func (g *Besu) GetInternalExecutionURL() string

+ func (g *Besu) GetInternalHttpUrl() string

+ func (g *Besu) GetInternalWsUrl() string

+ func (g *Besu) StartContainer() (blockchain.EVMNetwork, error)

+ func (g *Besu) WaitUntilChainIsReady(ctx context.Context, waitTime time.Duration) error

+ func (g *Besu) WithImage(imageWithTag string) *Besu

+ func (g *Besu) WithTestInstance(t *testing.T) ExecutionClient

type ContainerType

+ const ContainerType_Besu

+ const ContainerType_Erigon

+ const ContainerType_Nethermind

+ type Erigon struct

+ ExternalExecutionURL string

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalExecutionURL string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewErigon(networks []string, chainConfg *EthereumChainConfig, ...) (*Erigon, error)

+ func (g *Erigon) GetContainer() *tc.Container

+ func (g *Erigon) GetContainerName() string

+ func (g *Erigon) GetContainerType() ContainerType

+ func (g *Erigon) GetExternalExecutionURL() string

+ func (g *Erigon) GetExternalHttpUrl() string

+ func (g *Erigon) GetExternalWsUrl() string

+ func (g *Erigon) GetImage() string

+ func (g *Erigon) GetInternalExecutionURL() string

+ func (g *Erigon) GetInternalHttpUrl() string

+ func (g *Erigon) GetInternalWsUrl() string

+ func (g *Erigon) StartContainer() (blockchain.EVMNetwork, error)

+ func (g *Erigon) WaitUntilChainIsReady(ctx context.Context, waitTime time.Duration) error

+ func (g *Erigon) WithImage(imageWithTag string) *Erigon

+ func (g *Erigon) WithTestInstance(t *testing.T) ExecutionClient

+ type EthGenesisGeneretor struct

+ func NewEthGenesisGenerator(chainConfig EthereumChainConfig, generatedDataHostDir string, ...) (*EthGenesisGeneretor, error)

+ func (g *EthGenesisGeneretor) StartContainer() error

+ func (g *EthGenesisGeneretor) WithImage(imageWithTag string) *EthGenesisGeneretor

+ func (g *EthGenesisGeneretor) WithTestInstance(t *testing.T) *EthGenesisGeneretor

+ type EthereumChainConfig struct

+ AddressesToFund []string

+ ChainID int

+ GenesisDelay int

+ SecondsPerSlot int

+ SlotsPerEpoch int

+ ValidatorCount int

+ func GetDefaultChainConfig() EthereumChainConfig

+ func (c *EthereumChainConfig) GenerateGenesisTimestamp()

+ func (c *EthereumChainConfig) GetDefaultFinalizationWaitDuration() time.Duration

+ func (c *EthereumChainConfig) GetDefaultWaitDuration() time.Duration

+ func (c *EthereumChainConfig) GetValidatorBasedGenesisDelay() int

+ func (c *EthereumChainConfig) Validate(logger zerolog.Logger) error

type EthereumNetwork

+ EthereumChainConfig *EthereumChainConfig

+ GeneratedDataHostDir string

+ ValKeysDir string

+ WaitForFinalization bool

+ func NewPrivateChainEnvConfigFromFile(path string) (EthereumNetwork, error)

+ func (en *EthereumNetwork) Save() error

type EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WihtExistingConfigFromEnvVar() *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithEthereumChainConfig(config EthereumChainConfig) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithExecClientFromEnvVar() *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithWaitingForFinalization() *EthereumNetworkBuilder

+ type EthereumNetworkParticipant struct

+ ConsensusLayer ConsensusLayer

+ Count int

+ ExecutionLayer ExecutionLayer

+ type ExecutionClient interface

+ GetContainer func() *tc.Container

+ GetContainerName func() string

+ GetContainerType func() ContainerType

+ GetExternalExecutionURL func() string

+ GetExternalHttpUrl func() string

+ GetExternalWsUrl func() string

+ GetInternalExecutionURL func() string

+ GetInternalHttpUrl func() string

+ GetInternalWsUrl func() string

+ StartContainer func() (blockchain.EVMNetwork, error)

+ WaitUntilChainIsReady func(ctx context.Context, waitTime time.Duration) error

+ WithTestInstance func(t *testing.T) ExecutionClient

type ExecutionLayer

+ const ExecutionLayer_Besu

+ const ExecutionLayer_Erigon

+ const ExecutionLayer_Nethermind

+ type ExitCodeStrategy struct

+ func NewExitCodeStrategy() *ExitCodeStrategy

+ func (w *ExitCodeStrategy) WaitUntilReady(ctx context.Context, target tcwait.StrategyTarget) (err error)

+ func (w *ExitCodeStrategy) WithExitCode(exitCode int) *ExitCodeStrategy

+ func (w *ExitCodeStrategy) WithPollInterval(pollInterval time.Duration) *ExitCodeStrategy

+ func (w *ExitCodeStrategy) WithTimeout(timeout time.Duration) *ExitCodeStrategy

type Geth

+ func (g *Geth) WithTestInstance(t *testing.T) *Geth

type Geth2

+ func (g *Geth2) GetContainer() *tc.Container

+ func (g *Geth2) GetContainerName() string

+ func (g *Geth2) GetContainerType() ContainerType

+ func (g *Geth2) GetExternalExecutionURL() string

+ func (g *Geth2) GetExternalHttpUrl() string

+ func (g *Geth2) GetExternalWsUrl() string

+ func (g *Geth2) GetImage() string

+ func (g *Geth2) GetInternalExecutionURL() string

+ func (g *Geth2) GetInternalHttpUrl() string

+ func (g *Geth2) GetInternalWsUrl() string

+ func (g *Geth2) WaitUntilChainIsReady(ctx context.Context, waitTime time.Duration) error

+ func (g *Geth2) WithImage(imageWithTag string) *Geth2

+ func (g *Geth2) WithTestInstance(t *testing.T) ExecutionClient

+ type HasDockerImage interface

+ GetImage func() string

+ WithImage func(imageWithTag string) T

type Kafka

+ func (k *Kafka) WithTestInstance(t *testing.T) *Kafka

type Killgrave

+ func (k *Killgrave) WithTestInstance(t *testing.T) *Killgrave

+ type LogRegexStrategy struct

+ Occurrence int

+ Pattern *regexp.Regexp

+ PollInterval time.Duration

+ func NewLogRegexStrategy(pattern *regexp.Regexp) *LogRegexStrategy

+ func (ws *LogRegexStrategy) WaitUntilReady(ctx context.Context, target tcwait.StrategyTarget) (err error)

+ func (ws *LogRegexStrategy) WithOccurrence(o int) *LogRegexStrategy

+ func (ws *LogRegexStrategy) WithPollInterval(pollInterval time.Duration) *LogRegexStrategy

+ func (ws *LogRegexStrategy) WithStartupTimeout(timeout time.Duration) *LogRegexStrategy

type MockServer

+ func (ms *MockServer) WithTestInstance(t *testing.T) *MockServer

+ type Nethermind struct

+ ExternalExecutionURL string

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalExecutionURL string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewNethermind(networks []string, generatedDataHostDir string, consensusLayer ConsensusLayer, ...) (*Nethermind, error)

+ func (g *Nethermind) GetContainer() *tc.Container

+ func (g *Nethermind) GetContainerName() string

+ func (g *Nethermind) GetContainerType() ContainerType

+ func (g *Nethermind) GetExternalExecutionURL() string

+ func (g *Nethermind) GetExternalHttpUrl() string

+ func (g *Nethermind) GetExternalWsUrl() string

+ func (g *Nethermind) GetImage() string

+ func (g *Nethermind) GetInternalExecutionURL() string

+ func (g *Nethermind) GetInternalHttpUrl() string

+ func (g *Nethermind) GetInternalWsUrl() string

+ func (g *Nethermind) StartContainer() (blockchain.EVMNetwork, error)

+ func (g *Nethermind) WaitUntilChainIsReady(ctx context.Context, waitTime time.Duration) error

+ func (g *Nethermind) WithImage(imageWithTag string) *Nethermind

+ func (g *Nethermind) WithTestInstance(t *testing.T) ExecutionClient

type NonDevBesuNode

+ func (g *NonDevBesuNode) WithTestInstance(t *testing.T) NonDevNode

type NonDevGethNode

+ func (g *NonDevGethNode) WithTestInstance(t *testing.T) NonDevNode

type NonDevNode

+ WithTestInstance func(t *testing.T) NonDevNode

type PostgresDb

+ func (pg *PostgresDb) WithTestInstance(t *testing.T) *PostgresDb

type PrivateGethChain

+ func (p *PrivateGethChain) WithTestInstance(t *testing.T) *PrivateGethChain

type PrysmBeaconChain

+ func (g *PrysmBeaconChain) GetImage() string

+ func (g *PrysmBeaconChain) WithImage(imageWithTag string) *PrysmBeaconChain

+ func (g *PrysmBeaconChain) WithTestInstance(t *testing.T) *PrysmBeaconChain

type PrysmValidator

+ func (g *PrysmValidator) GetImage() string

+ func (g *PrysmValidator) WithImage(imageWithTag string) *PrysmValidator

+ func (g *PrysmValidator) WithTestInstance(t *testing.T) *PrysmValidator

type SchemaRegistry

+ func (r *SchemaRegistry) WithTestInstance(t *testing.T) *SchemaRegistry

+ type ValKeysGeneretor struct

+ func NewValKeysGeneretor(chainConfig *EthereumChainConfig, valKeysHostDataDir string, ...) (*ValKeysGeneretor, error)

+ func (g *ValKeysGeneretor) StartContainer() error

+ func (g *ValKeysGeneretor) WithTestInstance(t *testing.T) *ValKeysGeneretor

type Zookeeper

+ func (z *Zookeeper) WithTestInstance(t *testing.T) *Zookeeper

Nov 16, 2023

Changes in this version

type Geth2

+ func (g *Geth2) WithTestLogger(t *testing.T) *Geth2

type GethGenesis

+ func (g *GethGenesis) WithTestLogger(t *testing.T) *GethGenesis

type PrysmBeaconChain

+ func (g *PrysmBeaconChain) WithTestLogger(t *testing.T) *PrysmBeaconChain

type PrysmGenesis

+ func (g *PrysmGenesis) WithTestLogger(t *testing.T) *PrysmGenesis

type PrysmValidator

+ func (g *PrysmValidator) WithTestLogger(t *testing.T) *PrysmValidator

type RpcProvider

+ func (s *RpcProvider) PublicWsUrls() []string

Nov 13, 2023

Changes in this version

+ const CONTAINER_ETH2_CONSENSUS_DIRECTORY

+ const CONTAINER_ETH2_EXECUTION_DIRECTORY

+ const GETH_ETH2_EXECUTION_PORT

+ const GO_CLIENT_IMAGE_TAG

+ const PRYSM_IMAGE_TAG

+ const PRYSM_NODE_RPC_PORT

+ const PRYSM_QUERY_RPC_PORT

+ var BeaconChainConfigYAML = ...

+ var DefaultBeaconChainConfig = BeaconChainConfig

+ var Eth1GenesisJSON = ...

+ func FormatHttpUrl(host string, port string) string

+ func FormatWsUrl(host string, port string) string

+ func GenerateBeaconChainConfig(c *BeaconChainConfig) (string, error)

+ type BeaconChainConfig struct

+ SecondsPerSlot int

+ SlotsPerEpoch int

+ type ConsensusLayer string

+ const ConsensusLayer_Prysm

+ type ConsensusType string

+ const ConsensusType_PoS

+ const ConsensusType_PoW

+ type ContainerType string

+ const ContainerType_Geth

+ const ContainerType_Geth2

+ const ContainerType_PrysmBeacon

+ const ContainerType_PrysmVal

type EnvComponent

+ ContainerEnvs map[string]string

+ type Eth2Components struct

+ BeaconChain *PrysmBeaconChain

+ Geth *Geth2

+ Validator *PrysmValidator

+ type EthereumNetwork struct

+ ConsensusDir string

+ ConsensusLayer ConsensusLayer

+ ConsensusNodes int

+ ConsensusType ConsensusType

+ Containers EthereumNetworkContainers

+ DockerNetworkNames []string

+ ExecutionDir string

+ ExecutionLayer ExecutionLayer

+ ExecutionNodes int

+ func (b *EthereumNetwork) Describe() string

+ func (b *EthereumNetwork) Start() (blockchain.EVMNetwork, RpcProvider, error)

+ type EthereumNetworkBuilder struct

+ func NewEthereumNetworkBuilder() EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) Build() (EthereumNetwork, error)

+ func (b *EthereumNetworkBuilder) WithAddressesToFund(addresses []string) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithBeaconChainConfig(config BeaconChainConfig) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithConsensusLayer(consensusLayer ConsensusLayer) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithConsensusNodes(consensusNodes int) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithConsensusType(consensusType ConsensusType) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithDockerNetworks(networks []string) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithExecutionLayer(executionLayer ExecutionLayer) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithExecutionNodes(executionNodes int) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithExistingConfig(config EthereumNetwork) *EthereumNetworkBuilder

+ func (b *EthereumNetworkBuilder) WithTest(t *testing.T) *EthereumNetworkBuilder

+ type EthereumNetworkContainer struct

+ Container *tc.Container

+ ContainerName string

+ ContainerType ContainerType

+ type EthereumNetworkContainers []EthereumNetworkContainer

+ type ExecutionLayer string

+ const ExecutionLayer_Geth

type Geth

+ func (g *Geth) WithLogger(l zerolog.Logger) *Geth

+ type Geth2 struct

+ ExecutionDir string

+ ExternalExecutionURL string

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalExecutionURL string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewGeth2(networks []string, executionDir string, consensusLayer ConsensusLayer, ...) *Geth2

+ func (g *Geth2) StartContainer() (blockchain.EVMNetwork, error)

+ func (g *Geth2) WithLogger(l zerolog.Logger) *Geth2

+ type GethGenesis struct

+ ExecutionDir string

+ func NewEth1Genesis(networks []string, executionDir string, opts ...EnvComponentOption) *GethGenesis

+ func (g *GethGenesis) StartContainer() error

+ func (g *GethGenesis) WithLogger(l zerolog.Logger) *GethGenesis

type PostgresDbOption

+ func WithContainerEnv(key, value string) PostgresDbOption

+ func WithPostgresImageName(imageName string) PostgresDbOption

+ type PrysmBeaconChain struct

+ ExternalBeaconRpcProvider string

+ ExternalQueryRpcUrl string

+ InternalBeaconRpcProvider string

+ InternalQueryRpcUrl string

+ func NewPrysmBeaconChain(networks []string, executionDir, consensusDir, gethExecutionURL string, ...) *PrysmBeaconChain

+ func (g *PrysmBeaconChain) StartContainer() error

+ func (g *PrysmBeaconChain) WithLogger(l zerolog.Logger) *PrysmBeaconChain

+ type PrysmGenesis struct

+ func NewEth2Genesis(networks []string, beaconChainConfig BeaconChainConfig, ...) *PrysmGenesis

+ func (g *PrysmGenesis) StartContainer() error

+ func (g *PrysmGenesis) WithFundedAccounts(addresses []string) *PrysmGenesis

+ func (g *PrysmGenesis) WithLogger(l zerolog.Logger) *PrysmGenesis

+ type PrysmValidator struct

+ func NewPrysmValidator(networks []string, consensusDir, internalBeaconRpcProvider string, ...) *PrysmValidator

+ func (g *PrysmValidator) StartContainer() error

+ func (g *PrysmValidator) WithLogger(l zerolog.Logger) *PrysmValidator

+ type RpcProvider struct

+ func (s *RpcProvider) PrivateHttpUrls() []string

+ func (s *RpcProvider) PrivateWsUrsl() []string

+ func (s *RpcProvider) PublicHttpUrls() []string

+ func (s *RpcProvider) PublicWsUrsl() []string

Nov 7, 2023

Changes in this version

+ const BaseCMD

type EnvComponent

+ func (ec EnvComponent) ChaosNetworkDelay(l zerolog.Logger, duration time.Duration, delay time.Duration, ...) error

+ func (ec EnvComponent) ChaosNetworkLoss(l zerolog.Logger, duration time.Duration, lossPercentage int, ...) error

+ func (ec EnvComponent) ChaosPause(l zerolog.Logger, duration time.Duration) error

Nov 22, 2023

Changes in this version

type EnvComponent

+ ContainerImage string

+ ContainerVersion string

Oct 13, 2023

Changes in this version

+ func GetEndpoint(ctx context.Context, container tc.Container, endpointType string) (string, error)

+ func GetHost(ctx context.Context, container tc.Container) (string, error)

+ type HTTPStrategy struct

+ ExpectedStatusCode int

+ Path string

+ Port nat.Port

+ RetryDelay time.Duration

+ func NewHTTPStrategy(path string, port nat.Port) *HTTPStrategy

+ func (w *HTTPStrategy) WaitUntilReady(ctx context.Context, target tcwait.StrategyTarget) (err error)

+ func (w *HTTPStrategy) WithStatusCode(statusCode int) *HTTPStrategy

+ func (w *HTTPStrategy) WithTimeout(timeout time.Duration) *HTTPStrategy

+ type Kafka struct

+ BootstrapServerUrl string

+ EnvVars map[string]string

+ ExternalUrl string

+ InternalUrl string

+ TopicConfigs []KafkaTopicConfig

+ func NewKafka(networks []string) *Kafka

+ func (k *Kafka) CreateLocalTopics() error

+ func (k *Kafka) StartContainer() error

+ func (k *Kafka) WithContainerName(name string) *Kafka

+ func (k *Kafka) WithEnvVars(envVars map[string]string) *Kafka

+ func (k *Kafka) WithTestLogger(t *testing.T) *Kafka

+ func (k *Kafka) WithTopics(topics []KafkaTopicConfig) *Kafka

+ func (k *Kafka) WithZookeeper(zookeeperUrl string) *Kafka

+ type KafkaTopicConfig struct

+ CleanupPolicy string

+ Partitions int

+ Replication int

+ TopicName string

+ type SchemaRegistry struct

+ EnvVars map[string]string

+ ExternalUrl string

+ InternalUrl string

+ func NewSchemaRegistry(networks []string) *SchemaRegistry

+ func (r *SchemaRegistry) StartContainer() error

+ func (r *SchemaRegistry) WithContainerName(name string) *SchemaRegistry

+ func (r *SchemaRegistry) WithEnvVars(envVars map[string]string) *SchemaRegistry

+ func (r *SchemaRegistry) WithKafka(kafkaUrl string) *SchemaRegistry

+ func (r *SchemaRegistry) WithTestLogger(t *testing.T) *SchemaRegistry

+ type Zookeeper struct

+ InternalUrl string

+ func NewZookeeper(networks []string) *Zookeeper

+ func (z *Zookeeper) StartContainer() error

+ func (z *Zookeeper) WithContainerName(name string) *Zookeeper

+ func (z *Zookeeper) WithTestLogger(t *testing.T) *Zookeeper

Oct 12, 2023

Changes in this version

type PostgresDb

+ ExternalPort string

+ ExternalURL *url.URL

+ InternalPort string

+ InternalURL *url.URL

+ func (pg *PostgresDb) ExecPgDump(stdout io.Writer) error

type PostgresDbOption

+ func WithPostgresDbName(name string) PostgresDbOption

Oct 10, 2023

Changes in this version

type PostgresDb

+ ImageVersion string

type PostgresDbOption

+ func WithPostgresImageVersion(version string) PostgresDbOption

Oct 4, 2023

Changes in this version

+ type Killgrave struct

+ ExternalEndpoint string

+ InternalEndpoint string

+ InternalImposters []*url.URL

+ InternalPort string

+ func NewKillgrave(networks []string, impostersDirectoryPath string, opts ...EnvComponentOption) *Killgrave

+ func (k *Killgrave) AddImposter(imposter KillgraveImposter) error

+ func (k *Killgrave) SetAdapterBasedAnyValuePath(path string, method string, v interface{}) error

+ func (k *Killgrave) SetAdapterBasedIntValuePath(path string, method string, v int) error

+ func (k *Killgrave) SetStringValuePath(path string, method string, headers map[string]string, v string) error

+ func (k *Killgrave) StartContainer() error

+ func (k *Killgrave) WithTestLogger(t *testing.T) *Killgrave

+ type KillgraveAdapterResponse struct

+ Data KillgraveAdapterResult

+ Error interface{}

+ Id string

+ type KillgraveAdapterResult struct

+ Result interface{}

+ type KillgraveImposter struct

+ Request KillgraveRequest

+ Response KillgraveResponse

+ type KillgraveRequest struct

+ Endpoint string

+ Headers *map[string]string

+ Method string

+ Params *map[string]string

+ SchemaFile *string

+ type KillgraveResponse struct

+ Body string

+ BodyFile *string

+ Delay *KillgraveResponseDelay

+ Headers *map[string]string

+ Status int

+ type KillgraveResponseDelay struct

+ Delay int64

+ Offset int64

Sep 28, 2023

Changes in this version

+ func NatPort(port string) nat.Port

+ func NatPortFormat(port string) string

Sep 14, 2023

Changes in this version

+ const BESU_IMAGE

type Geth

+ func (g *Geth) WithTestLogger(t *testing.T) *Geth

type MockServer

+ func (ms *MockServer) WithTestLogger(t *testing.T) *MockServer

+ type NonDevBesuNode struct

+ Config gethTxNodeConfig

+ EVMClient blockchain.EVMClient

+ EthClient *ethclient.Client

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewNonDevBesuNode(networks []string, networkCfg *blockchain.EVMNetwork) *NonDevBesuNode

+ func (g *NonDevBesuNode) ConnectToClient() error

+ func (g *NonDevBesuNode) GetEVMClient() blockchain.EVMClient

+ func (g *NonDevBesuNode) GetInternalHttpUrl() string

+ func (g *NonDevBesuNode) GetInternalWsUrl() string

+ func (g *NonDevBesuNode) Start() error

+ func (g *NonDevBesuNode) WithTestLogger(t *testing.T) NonDevNode

type NonDevGethNode

+ func (g *NonDevGethNode) GetEVMClient() blockchain.EVMClient

+ func (g *NonDevGethNode) GetInternalHttpUrl() string

+ func (g *NonDevGethNode) GetInternalWsUrl() string

+ func (g *NonDevGethNode) WithTestLogger(t *testing.T) NonDevNode

+ type NonDevNode interface

+ ConnectToClient func() error

+ GetEVMClient func() blockchain.EVMClient

+ GetInternalHttpUrl func() string

+ GetInternalWsUrl func() string

+ Start func() error

+ WithTestLogger func(t *testing.T) NonDevNode

type PostgresDb

+ func (pg *PostgresDb) WithTestLogger(t *testing.T) *PostgresDb

+ type PrivateBesuChain struct

+ DockerNetworks []string

+ NetworkConfig *blockchain.EVMNetwork

+ Nodes []*NonDevBesuNode

+ PrimaryNode *NonDevBesuNode

+ func (p *PrivateBesuChain) GetDockerNetworks() []string

+ func (p *PrivateBesuChain) GetNetworkConfig() *blockchain.EVMNetwork

+ func (p *PrivateBesuChain) GetNodes() []NonDevNode

+ func (p *PrivateBesuChain) GetPrimaryNode() NonDevNode

+ type PrivateChain interface

+ GetDockerNetworks func() []string

+ GetNetworkConfig func() *blockchain.EVMNetwork

+ GetNodes func() []NonDevNode

+ GetPrimaryNode func() NonDevNode

+ func NewPrivateBesuChain(networkCfg *blockchain.EVMNetwork, dockerNetworks []string) PrivateChain

type PrivateGethChain

+ func (p *PrivateGethChain) GetDockerNetworks() []string

+ func (p *PrivateGethChain) GetNetworkConfig() *blockchain.EVMNetwork

+ func (p *PrivateGethChain) GetNodes() []NonDevNode

+ func (p *PrivateGethChain) GetPrimaryNode() NonDevNode

+ func (p *PrivateGethChain) WithTestLogger(t *testing.T) *PrivateGethChain

Sep 1, 2023

Changes in this version

type WebSocketStrategy

+ func (w *WebSocketStrategy) WithTimeout(timeout time.Duration) *WebSocketStrategy

Aug 31, 2023

Changes in this version

+ const RootFundingAddr

+ const RootFundingWallet

+ const TX_GETH_HTTP_PORT

+ const TX_GETH_WS_PORT

+ const TX_NON_DEV_GETH_WS_PORT

+ type Geth struct

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewGeth(networks []string, opts ...EnvComponentOption) *Geth

+ func (g *Geth) StartContainer() (blockchain.EVMNetwork, InternalDockerUrls, error)

+ type InternalDockerUrls struct

+ HttpUrl string

+ WsUrl string

+ type MockServer struct

+ Client *ctfClient.MockserverClient

+ EAMockUrls []*url.URL

+ Endpoint string

+ InternalEndpoint string

+ func NewMockServer(networks []string, opts ...EnvComponentOption) *MockServer

+ func (ms *MockServer) SetExternalAdapterMocks(count int) error

+ func (ms *MockServer) StartContainer() error

+ type PostgresDb struct

+ DbName string

+ Password string

+ Port string

+ User string

+ func NewPostgresDb(networks []string, opts ...PostgresDbOption) *PostgresDb

+ func (pg *PostgresDb) StartContainer() error

+ type PostgresDbOption = func(c *PostgresDb)

+ func WithPostgresDbContainerName(name string) PostgresDbOption

+ type WebSocketStrategy struct

+ Port nat.Port

+ Retries int

+ RetryDelay time.Duration

+ func NewWebSocketStrategy(port nat.Port) *WebSocketStrategy

+ func (w *WebSocketStrategy) WaitUntilReady(ctx context.Context, target tcwait.StrategyTarget) (err error)

Aug 14, 2023

Changes in this version

+ const BOOTNODE_PORT

+ const GETH_BOOTNODE_IMAGE

+ const GETH_IMAGE

+ const TX_HTTP_PORT

+ const TX_WS_PORT

+ var FundingAddresses = map[string]string

+ type EnvComponent struct

+ Container tc.Container

+ ContainerName string

+ Networks []string

+ type EnvComponentOption = func(c *EnvComponent)

+ func WithContainerName(name string) EnvComponentOption

+ type NonDevGethNode struct

+ Config gethTxNodeConfig

+ EVMClient blockchain.EVMClient

+ EthClient *ethclient.Client

+ ExternalHttpUrl string

+ ExternalWsUrl string

+ InternalHttpUrl string

+ InternalWsUrl string

+ func NewNonDevGethNode(networks []string, networkCfg *blockchain.EVMNetwork) *NonDevGethNode

+ func (g *NonDevGethNode) ConnectToClient() error

+ func (g *NonDevGethNode) Start() error

+ type PrivateGethChain struct

+ DockerNetworks []string

+ NetworkConfig *blockchain.EVMNetwork

+ Nodes []*NonDevGethNode

+ PrimaryNode *NonDevGethNode

+ func NewPrivateGethChain(networkCfg *blockchain.EVMNetwork, dockerNetworks []string) PrivateGethChain