e2e

Documentation

Index

• Constants
• Variables
• func CopyFile(sourcePath string, targetPath string) error
• func GetNodesDataDirs(virtualChainId primitives.VirtualChainId) ([]string, error)
• func NewInProcessE2EAppNetwork(virtualChainId primitives.VirtualChainId, randomer *loggerRandomer, ...) *inProcessE2ENetwork
• func NewLoggerRandomer() *loggerRandomer
• func PrintTestTime(t *testing.T, msg string, last *time.Time)
• type E2EConfig
  • func GetConfig() E2EConfig
• type Harness
  • func NewAppHarness() *Harness
  • func (h *Harness) DeployContract(from *keys.Ed25519KeyPair, contractName string, ...) (*codec.TransactionResponse, error)
  • func (h *Harness) DeployContractAndRequireSuccess(t *testing.T, keyPair *keys.Ed25519KeyPair, contractName string, ...) uint64
  • func (h *Harness) DeployNativeContract(from *keys.Ed25519KeyPair, contractName string, code ...[]byte) (*codec.TransactionResponse, error)
  • func (h *Harness) GetMetrics() metrics
  • func (h *Harness) GetTransactionReceiptProof(txId string) (response *codec.GetTransactionReceiptProofResponse, err error)
  • func (h *Harness) GetTransactionStatus(txId string) (*codec.TransactionResponse, error)
  • func (h *Harness) RunQuery(senderPublicKey []byte, contractName string, methodName string, ...) (response *codec.RunQueryResponse, err error)
  • func (h *Harness) SendDeployTransaction(senderPublicKey []byte, senderPrivateKey []byte, contractName string, ...) (*codec.TransactionResponse, string, error)
  • func (h *Harness) SendTransaction(senderPublicKey []byte, senderPrivateKey []byte, contractName string, ...) (*codec.TransactionResponse, string, error)
  • func (h *Harness) WaitUntilReachBlockHeight(t *testing.T, targetBlockHeight primitives.BlockHeight, ...)
  • func (h *Harness) WaitUntilTransactionPoolIsReady(t *testing.T)
• type StressTestConfig

Constants

const CannedBlocksFileMinHeight = 500

const LOCAL_NETWORK_SIZE = 4

LOCAL_NETWORK_SIZE must remain identical to number of configured nodes in docker/test/benchmark-config Also Lean Helix consensus algo requires it to be >= 4 or it will panic

const METRICS_NODE_INDEX = 2

const START_GOSSIP_PORT = 8190

const START_HTTP_PORT = 8090

Variables

var OwnerOfAllSupply = keys.Ed25519KeyPairForTests(5) // needs to be a constant across all e2e tests since we deploy the contract only once

Functions

func CopyFile

func CopyFile(sourcePath string, targetPath string) error

func GetNodesDataDirs

func GetNodesDataDirs(virtualChainId primitives.VirtualChainId) ([]string, error)

func NewInProcessE2EAppNetwork

func NewInProcessE2EAppNetwork(virtualChainId primitives.VirtualChainId, randomer *loggerRandomer, experimentalExternalProcessorPluginPath string) *inProcessE2ENetwork

func NewLoggerRandomer

func NewLoggerRandomer() *loggerRandomer

func PrintTestTime

func PrintTestTime(t *testing.T, msg string, last *time.Time)

Types

type E2EConfig

type E2EConfig struct {
	AppVcid           primitives.VirtualChainId
	RemoteEnvironment bool
	Bootstrap         bool
	AppChainUrl       string
	StressTest        StressTestConfig
	EthereumEndpoint  string
}

func GetConfig

func GetConfig() E2EConfig

type Harness

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

func NewAppHarness

func NewAppHarness() *Harness

func (*Harness) DeployContract

func (h *Harness) DeployContract(from *keys.Ed25519KeyPair, contractName string, processorType orbsClient.ProcessorType, code ...[]byte) (*codec.TransactionResponse, error)

func (*Harness) DeployContractAndRequireSuccess

func (h *Harness) DeployContractAndRequireSuccess(t *testing.T, keyPair *keys.Ed25519KeyPair, contractName string, contractBytes ...[]byte) uint64

func (*Harness) DeployNativeContract

func (h *Harness) DeployNativeContract(from *keys.Ed25519KeyPair, contractName string, code ...[]byte) (*codec.TransactionResponse, error)

func (*Harness) GetMetrics

func (h *Harness) GetMetrics() metrics

func (*Harness) GetTransactionReceiptProof

func (h *Harness) GetTransactionReceiptProof(txId string) (response *codec.GetTransactionReceiptProofResponse, err error)

func (*Harness) GetTransactionStatus

func (h *Harness) GetTransactionStatus(txId string) (*codec.TransactionResponse, error)

func (*Harness) RunQuery

func (h *Harness) RunQuery(senderPublicKey []byte, contractName string, methodName string, args ...interface{}) (response *codec.RunQueryResponse, err error)

func (*Harness) SendDeployTransaction

func (h *Harness) SendDeployTransaction(senderPublicKey []byte, senderPrivateKey []byte, contractName string, processorType orbsClient.ProcessorType, code ...[]byte) (*codec.TransactionResponse, string, error)

func (*Harness) SendTransaction

func (h *Harness) SendTransaction(senderPublicKey []byte, senderPrivateKey []byte, contractName string, methodName string, args ...interface{}) (*codec.TransactionResponse, string, error)

func (*Harness) WaitUntilReachBlockHeight

func (h *Harness) WaitUntilReachBlockHeight(t *testing.T, targetBlockHeight primitives.BlockHeight, waitingTime time.Duration)

func (*Harness) WaitUntilTransactionPoolIsReady

func (h *Harness) WaitUntilTransactionPoolIsReady(t *testing.T)

type StressTestConfig

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