framework

Documentation

Index

• type ClusterOption
  • func WithBootnodeCount(cnt int) ClusterOption
  • func WithBridge() ClusterOption
  • func WithEpochReward(epochReward int) ClusterOption
  • func WithEpochSize(epochSize int) ClusterOption
  • func WithNonValidators(num int) ClusterOption
  • func WithPremine(addresses ...types.Address) ClusterOption
  • func WithValidatorSnapshot(validatorsLen uint64) ClusterOption
• type TestBridge
  • func NewTestBridge(t *testing.T, clusterConfig *TestClusterConfig) (*TestBridge, error)
  • func (t *TestBridge) JSONRPCAddr() string
  • func (t *TestBridge) Start() error
  • func (t *TestBridge) Stop()
  • func (t *TestBridge) WaitUntil(pollFrequency, timeout time.Duration, handler func() (bool, error)) error
• type TestCluster
  • func NewTestCluster(t *testing.T, validatorsCount int, opts ...ClusterOption) *TestCluster
  • func (c *TestCluster) EmitTransfer(contractAddress, walletAddresses, amounts string) error
  • func (c *TestCluster) Fail(err error)
  • func (c *TestCluster) Stats(t *testing.T)
  • func (c *TestCluster) Stop()
  • func (c *TestCluster) WaitForBlock(n uint64, timeout time.Duration) error
  • func (c *TestCluster) WaitForGeneric(dur time.Duration, fn func(*TestServer) bool) error
  • func (c *TestCluster) WaitUntil(dur time.Duration, handler func() bool) error
• type TestClusterConfig
  • func (c *TestClusterConfig) Dir(name string) string
  • func (c *TestClusterConfig) GetStdout(name string) io.Writer
• type TestServer
  • func NewTestServer(t *testing.T, clusterConfig *TestClusterConfig, ...) *TestServer
  • func (t *TestServer) Conn() proto.SystemClient
  • func (t *TestServer) GrpcAddr() string
  • func (t *TestServer) JSONRPC() *jsonrpc.Client
  • func (t *TestServer) JSONRPCAddr() string
  • func (t *TestServer) Stake(amount uint64) error
  • func (t *TestServer) Start()
  • func (t *TestServer) Stop()
• type TestServerConfig
• type TestServerConfigCallback

Types

type ClusterOption

type ClusterOption func(*TestClusterConfig)

func WithBootnodeCount

func WithBootnodeCount(cnt int) ClusterOption

func WithBridge

func WithBridge() ClusterOption

func WithEpochReward

func WithEpochReward(epochReward int) ClusterOption

func WithEpochSize

func WithEpochSize(epochSize int) ClusterOption

func WithNonValidators

func WithNonValidators(num int) ClusterOption

func WithPremine

func WithPremine(addresses ...types.Address) ClusterOption

func WithValidatorSnapshot

func WithValidatorSnapshot(validatorsLen uint64) ClusterOption

type TestBridge

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

func NewTestBridge

func NewTestBridge(t *testing.T, clusterConfig *TestClusterConfig) (*TestBridge, error)

func (*TestBridge) JSONRPCAddr

func (t *TestBridge) JSONRPCAddr() string

func (*TestBridge) Start

func (t *TestBridge) Start() error

func (*TestBridge) Stop

func (t *TestBridge) Stop()

func (*TestBridge) WaitUntil

func (t *TestBridge) WaitUntil(pollFrequency, timeout time.Duration, handler func() (bool, error)) error

type TestCluster

type TestCluster struct {
	Config  *TestClusterConfig
	Servers []*TestServer
	Bridge  *TestBridge
	// contains filtered or unexported fields
}

func NewTestCluster

func NewTestCluster(t *testing.T, validatorsCount int, opts ...ClusterOption) *TestCluster

func (*TestCluster) EmitTransfer

func (c *TestCluster) EmitTransfer(contractAddress, walletAddresses, amounts string) error

EmitTransfer function is used to invoke e2e rootchain emit command with appropriately created wallets and amounts for test transactions

func (*TestCluster) Fail

func (c *TestCluster) Fail(err error)

func (*TestCluster) Stats

func (c *TestCluster) Stats(t *testing.T)

func (*TestCluster) Stop

func (c *TestCluster) Stop()

func (*TestCluster) WaitForBlock

func (c *TestCluster) WaitForBlock(n uint64, timeout time.Duration) error

func (*TestCluster) WaitForGeneric

func (c *TestCluster) WaitForGeneric(dur time.Duration, fn func(*TestServer) bool) error

WaitForGeneric waits until all running servers returns true from fn callback or timeout defined by dur occurs

func (*TestCluster) WaitUntil

func (c *TestCluster) WaitUntil(dur time.Duration, handler func() bool) error

type TestClusterConfig

type TestClusterConfig struct {
	Name              string
	Premine           []types.Address
	HasBridge         bool
	BootnodeCount     int
	NonValidatorCount int
	WithLogs          bool
	WithStdout        bool
	LogsDir           string
	TmpDir            string
	ContractsDir      string
	ValidatorPrefix   string
	Binary            string
	ValidatorSetSize  uint64
	EpochSize         int
	EpochReward       int
	// contains filtered or unexported fields
}

func (*TestClusterConfig) Dir

func (c *TestClusterConfig) Dir(name string) string

func (*TestClusterConfig) GetStdout

func (c *TestClusterConfig) GetStdout(name string) io.Writer

type TestServer

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

func NewTestServer

func NewTestServer(t *testing.T, clusterConfig *TestClusterConfig, callback TestServerConfigCallback) *TestServer

func (*TestServer) Conn

func (t *TestServer) Conn() proto.SystemClient

func (*TestServer) GrpcAddr

func (t *TestServer) GrpcAddr() string

func (*TestServer) JSONRPC

func (t *TestServer) JSONRPC() *jsonrpc.Client

func (*TestServer) JSONRPCAddr

func (t *TestServer) JSONRPCAddr() string

func (*TestServer) Stake

func (t *TestServer) Stake(amount uint64) error

Stake stakes given amount to validator account encapsulated by given server instance

func (*TestServer) Start

func (t *TestServer) Start()

func (*TestServer) Stop

func (t *TestServer) Stop()

type TestServerConfig

type TestServerConfig struct {
	Name        string
	JSONRPCPort int64
	GRPCPort    int64
	P2PPort     int64
	Seal        bool
	DataDir     string
	Chain       string
	LogLevel    string
}

type TestServerConfigCallback

type TestServerConfigCallback func(*TestServerConfig)