Versions in this module Expand all Collapse all v1 v1.999.10 Nov 28, 2022 Changes in this version + const GasSchedulePath + const GlobalTopic + const MaxGasLimitPerBlock + const OpGasValueForMockVm + const ScheduledMiniBlocksEnableEpoch + const ShardTopic + const StakingV2Epoch + var AdditionalGasLimit = uint64(999000) + var ChainID = []byte("integration tests chain ID") + var DelegationManagerConfigChangeAddress = "erd1vxy22x0fj4zv6hktmydg8vpfh6euv02cz4yg0aaws6rrad5a5awqgqky80" + var InitialRating = uint32(50) + var MinTransactionVersion = uint32(1) + var MinTxGasLimit = uint64(1000) + var MinTxGasPrice = uint64(100) + var P2pBootstrapDelay = 5 * time.Second + var SoftwareVersion = []byte("intT") + var StepDelay = time.Millisecond * 180 + var SyncDelay = time.Second / 5 + var TestAddressPubkeyConverter = pubkeyConverter.NewBech32PubkeyConverter(32, log) + var TestAppStatusHandler = &statusHandlerMock.AppStatusHandlerStub + var TestBalanceComputationHandler = preprocess.NewBalanceComputation() + var TestBlockSizeComputationHandler = preprocess.NewBlockSizeComputation(TestMarshalizer, TestBlockSizeThrottler, uint32(core.MegabyteSize * 90 / 100)) + var TestBlockSizeThrottler = &mock.BlockSizeThrottlerStub + var TestBuiltinFunctions = make(map[string]vmcommon.BuiltinFunction) + var TestHasher = sha256.NewSha256() + var TestKeyGenForAccounts = signing.NewKeyGenerator(ed25519.NewEd25519()) + var TestMarshalizer = &marshal.GogoProtoMarshalizer + var TestMarshaller = &marshal.GogoProtoMarshalizer + var TestMultiSig = cryptoMocks.NewMultiSigner(1) + var TestThrottler = &processMock.InterceptorThrottlerStub + var TestTxSignHasher = keccak.NewKeccak() + var TestTxSignMarshalizer = &marshal.JsonMarshalizer + var TestUint64Converter = uint64ByteSlice.NewBigEndianConverter() + var TestValidatorPubkeyConverter = pubkeyConverter.NewHexPubkeyConverter(96) + var TestVmMarshalizer = &marshal.JsonMarshalizer + var TimeSpanForBadHeaders = time.Second * 30 + func AdbEmulateBalanceTxExecution(accounts state.AccountsAdapter, acntSrc, acntDest state.UserAccountHandler, ...) error + func AdbEmulateBalanceTxSafeExecution(acntSrc, acntDest state.UserAccountHandler, accounts state.AccountsAdapter, ...) + func AddSelfNotarizedHeaderByMetachain(nodes []*TestProcessorNode) + func AllShardsProposeBlock(round uint64, nonce uint64, nodesMap map[uint32][]*TestProcessorNode) (map[uint32]data.BodyHandler, map[uint32]data.HeaderHandler, ...) + func BootstrapDelay() + func CheckRootHashes(t *testing.T, nodes []*TestProcessorNode, idxProposers []int) + func CheckTxPresentAndRightNonce(t *testing.T, startingNonce uint64, noOfTxs int, txHashes [][]byte, ...) + func ClosePeers(peers []p2p.Messenger) + func CloseProcessorNodes(nodes []*TestProcessorNode) + func ComputeAndRequestMissingTransactions(nodes []*TestProcessorNode, generatedTxHashes [][]byte, shardResolver uint32, ...) + func ConnectNodes(nodes []Connectable) + func CreateAccount(accnts state.AccountsAdapter, nonce uint64, balance *big.Int) []byte + func CreateAccountForNode(node *TestProcessorNode) + func CreateAccountForNodes(nodes []*TestProcessorNode) + func CreateAccountsDB(accountType Type, trieStorageManager common.StorageManager) (*state.AccountsDB, common.Trie) + func CreateAndSendTransaction(node *TestProcessorNode, nodes []*TestProcessorNode, txValue *big.Int, ...) + func CreateAndSendTransactionWithGasLimit(node *TestProcessorNode, txValue *big.Int, gasLimit uint64, rcvAddress []byte, ...) + func CreateAndSendTransactions(nodes map[uint32][]*TestProcessorNode, ...) + func CreateFixedNetworkOf14Peers() ([]p2p.Messenger, error) + func CreateFixedNetworkOf8Peers() ([]p2p.Messenger, error) + func CreateFullGenesisBlocks(accounts state.AccountsAdapter, validatorAccounts state.AccountsAdapter, ...) map[uint32]data.HeaderHandler + func CreateGenesisBlocks(accounts state.AccountsAdapter, validatorAccounts state.AccountsAdapter, ...) map[uint32]data.HeaderHandler + func CreateGenesisMetaBlock(accounts state.AccountsAdapter, validatorAccounts state.AccountsAdapter, ...) data.MetaHeaderHandler + func CreateHeaderIntegrityVerifier() process.HeaderIntegrityVerifier + func CreateMemUnit() storage.Storer + func CreateMessengerFromConfig(p2pConfig config.P2PConfig) p2p.Messenger + func CreateMessengerFromConfigWithPeersRatingHandler(p2pConfig config.P2PConfig, peersRatingHandler p2p.PeersRatingHandler) p2p.Messenger + func CreateMessengerWithKadDht(initialAddr string) p2p.Messenger + func CreateMessengerWithKadDhtAndProtocolID(initialAddr string, protocolID string) p2p.Messenger + func CreateMessengerWithNoDiscovery() p2p.Messenger + func CreateMessengerWithNoDiscoveryAndPeersRatingHandler(peersRatingHanlder p2p.PeersRatingHandler) p2p.Messenger + func CreateMetaChain() data.ChainHandler + func CreateMintingForSenders(nodes []*TestProcessorNode, senderShard uint32, ...) + func CreateMintingFromAddresses(nodes []*TestProcessorNode, addresses [][]byte, value *big.Int) + func CreateNewDefaultTrie() common.Trie + func CreateNodesWithFullGenesis(numOfShards int, nodesPerShard int, numMetaChainNodes int, genesisFile string) ([]*TestProcessorNode, *TestProcessorNode) + func CreateNodesWithNodesCoordinator(nodesPerShard int, nbMetaNodes int, nbShards int, shardConsensusGroupSize int, ...) map[uint32][]*TestProcessorNode + func CreateNodesWithNodesCoordinatorAndHeaderSigVerifier(nodesPerShard int, nbMetaNodes int, nbShards int, shardConsensusGroupSize int, ...) map[uint32][]*TestProcessorNode + func CreateNodesWithNodesCoordinatorAndTxKeys(nodesPerShard int, nbMetaNodes int, nbShards int, shardConsensusGroupSize int, ...) map[uint32][]*TestProcessorNode + func CreateNodesWithNodesCoordinatorFactory(nodesPerShard int, nbMetaNodes int, nbShards int, shardConsensusGroupSize int, ...) map[uint32][]*TestProcessorNode + func CreateNodesWithNodesCoordinatorKeygenAndSingleSigner(nodesPerShard int, nbMetaNodes int, nbShards int, shardConsensusGroupSize int, ...) map[uint32][]*TestProcessorNode + func CreateNodesWithNodesCoordinatorWithCacher(nodesPerShard int, nbMetaNodes int, nbShards int, shardConsensusGroupSize int, ...) map[uint32][]*TestProcessorNode + func CreateNodesWithTestHeartbeatNode(nodesPerShard int, numMetaNodes int, numShards int, ...) map[uint32][]*TestHeartbeatNode + func CreateNodesWithTestP2PNodes(nodesPerShard int, numMetaNodes int, numShards int, ...) map[uint32][]*TestP2PNode + func CreateP2PConfigWithNoDiscovery() config.P2PConfig + func CreatePkBytes(numShards uint32) map[uint32][]byte + func CreateProcessorNodesWithNodesCoordinator(rewardsAddrsAssignments map[uint32][]uint32, shardConsensusGroupSize int, ...) (map[uint32][]*TestProcessorNode, uint32) + func CreateRandomAddress() []byte + func CreateRandomBytes(chars int) []byte + func CreateRatingsData() *rating.RatingsData + func CreateRequesterDataPool(recvTxs map[int]map[string]struct{}, mutRecvTxs *sync.Mutex, nodeIndex int, ...) dataRetriever.PoolsHolder + func CreateResolversDataPool(t *testing.T, maxTxs int, senderShardID uint32, recvShardId uint32, ...) (dataRetriever.PoolsHolder, [][]byte, [][]byte) + func CreateSendersAndReceiversInShard(nodeInShard *TestProcessorNode, nbSenderReceiverPairs uint32) ([]crypto.PrivateKey, []crypto.PublicKey) + func CreateSendersWithInitialBalances(nodesMap map[uint32][]*TestProcessorNode, mintValue *big.Int) map[uint32][]crypto.PrivateKey + func CreateShardChain() data.ChainHandler + func CreateSimpleGenesisBlock(shardId uint32) *dataBlock.Header + func CreateSimpleGenesisBlocks(shardCoordinator sharding.Coordinator) map[uint32]data.HeaderHandler + func CreateSimpleGenesisMetaBlock() *dataBlock.MetaBlock + func CreateSimpleTxProcessor(accnts state.AccountsAdapter) process.TransactionProcessor + func CreateStore(numOfShards uint32) dataRetriever.StorageService + func CreateTrieStorageManager(store storage.Storer) (common.StorageManager, storage.Storer) + func CreateTrieStorageManagerWithPruningStorer(coordinator sharding.Coordinator, notifier pruning.EpochStartNotifier) common.StorageManager + func DeployScTx(nodes []*TestProcessorNode, senderIdx int, scCode string, vmType []byte, ...) + func DisplayAndStartNodes(nodes []*TestProcessorNode) + func DoConsensusSigningOnBlock(blockHeader data.HeaderHandler, consensusNodes []*TestProcessorNode, ...) data.HeaderHandler + func EmptyDataPools(nodes []*TestProcessorNode, shardId uint32) + func ForkChoiceOneBlock(nodes []*TestProcessorNode, shardId uint32) + func GenValidatorsFromPubKeys(pubKeysMap map[uint32][]string, _ uint32) map[uint32][]nodesCoordinator.GenesisNodeInfoHandler + func GenValidatorsFromPubKeysAndTxPubKeys(blsPubKeysMap map[uint32][]string, txPubKeysMap map[uint32][]string) map[uint32][]nodesCoordinator.GenesisNodeInfoHandler + func GenerateAddressJournalAccountAccountsDB() ([]byte, state.UserAccountHandler, *state.AccountsDB) + func GenerateAndDisseminateTxs(n *TestProcessorNode, senders []crypto.PrivateKey, ...) + func GenerateIntraShardTransactions(nodesMap map[uint32][]*TestProcessorNode, nbTxsPerShard uint32, ...) + func GenerateOneAddressPerShard(shardCoordinator sharding.Coordinator) [][]byte + func GenerateRandomSlice(size int) []byte + func GenerateSkAndPkInShard(coordinator sharding.Coordinator, shardId uint32) (crypto.PrivateKey, crypto.PublicKey, crypto.KeyGenerator) + func GenerateTransferTx(nonce uint64, senderPrivateKey crypto.PrivateKey, ...) *transaction.Transaction + func GetConnectableAddress(mes p2p.Messenger) string + func GetDefaultCoreComponents() *mock.CoreComponentsStub + func GetDefaultCryptoComponents() *mock.CryptoComponentsStub + func GetDefaultDataComponents() *mock.DataComponentsStub + func GetDefaultNetworkComponents() *mock.NetworkComponentsStub + func GetDefaultProcessComponents() *mock.ProcessComponentsStub + func GetDefaultStateComponents() *testscommon.StateComponentsMock + func GetDefaultStatusComponents() *mock.StatusComponentsStub + func GetMiniBlocksHashesFromShardIds(body *dataBlock.Body, shardIds ...uint32) [][]byte + func GetTokenIdentifier(nodes []*TestProcessorNode, ticker []byte) []byte + func IncrementAndPrintRound(round uint64) uint64 + func IncrementNonces(nonces []*uint64) + func IsIntInSlice(idx int, slice []int) bool + func MakeDisplayTable(nodes []*TestProcessorNode) string + func MakeDisplayTableForHeartbeatNodes(nodes map[uint32][]*TestHeartbeatNode) string + func MakeDisplayTableForP2PNodes(nodes map[uint32][]*TestP2PNode) string + func MintAddress(accnts state.AccountsAdapter, addressBytes []byte, value *big.Int) + func MintAllNodes(nodes []*TestProcessorNode, value *big.Int) + func MintAllPlayers(nodes []*TestProcessorNode, players []*TestWalletAccount, value *big.Int) + func NewOneNodeNetwork() *oneNodeNetwork + func PlayerSendsTransaction(nodes []*TestProcessorNode, player *TestWalletAccount, scAddress []byte, ...) + func PrintShardAccount(accnt state.UserAccountHandler, tag string) + func ProposeAndSyncOneBlock(t *testing.T, nodes []*TestProcessorNode, idxProposers []int, round uint64, ...) (uint64, uint64) + func ProposeBlock(nodes []*TestProcessorNode, idxProposers []int, round uint64, nonce uint64) + func ProposeBlockSignalsEmptyBlock(node *TestProcessorNode, round uint64, nonce uint64) (data.HeaderHandler, data.BodyHandler, bool) + func ProposeBlocks(nodes []*TestProcessorNode, round *uint64, idxProposers []int, ...) + func PubKeysMapFromKeysMap(keyPairMap map[uint32][]*TestKeyPair) map[uint32][]string + func ResetHighestProbableNonce(nodes []*TestProcessorNode, shardId uint32, targetNonce uint64) + func SaveDelegationContractsList(nodes []*TestProcessorNode) + func SaveDelegationManagerConfig(nodes []*TestProcessorNode) + func ScCallTxWithParams(senderNode *TestProcessorNode, sk crypto.PrivateKey, nonce uint64, data string, ...) + func SetEconomicsParameters(nodes []*TestProcessorNode, maxGasLimitPerBlock uint64, minGasPrice uint64, ...) + func StartSyncingBlocks(nodes []*TestProcessorNode) + func SyncAllShardsWithRoundBlock(t *testing.T, nodesMap map[uint32][]*TestProcessorNode, ...) + func SyncBlock(t *testing.T, nodes []*TestProcessorNode, idxProposers []int, round uint64) + func TestPrivateKeyHasBalance(t *testing.T, n *TestProcessorNode, sk crypto.PrivateKey, ...) + func TestPublicKeyHasBalance(t *testing.T, n *TestProcessorNode, pk crypto.PublicKey, ...) + func Uint32InSlice(searched uint32, list []uint32) bool + func UpdateRound(nodes []*TestProcessorNode, round uint64) + func WaitForBootstrapAndShowConnected(peers []p2p.Messenger, durationBootstrapingTime time.Duration) + func WaitOperationToBeDone(t *testing.T, nodes []*TestProcessorNode, nrOfRounds int, nonce uint64, ...) (uint64, uint64) + func WhiteListTxs(nodes []*TestProcessorNode, txs []*transaction.Transaction) + type Address = []byte + type ArgIndexHashedNodesCoordinatorFactory struct + type Connectable interface + ConnectTo func(connectable Connectable) error + GetConnectableAddress func() string + IsInterfaceNil func() bool + type CountInterceptor struct + func NewCountInterceptor() *CountInterceptor + func (ci *CountInterceptor) IsInterfaceNil() bool + func (ci *CountInterceptor) MessageCount(topic string) int + func (ci *CountInterceptor) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error + func (ci *CountInterceptor) Reset() + type CryptoParams struct + KeyGen crypto.KeyGenerator + Keys map[uint32][]*TestKeyPair + SingleSigner crypto.SingleSigner + TxKeyGen crypto.KeyGenerator + TxKeys map[uint32][]*TestKeyPair + func CreateCryptoParams(nodesPerShard int, nbMetaNodes int, nbShards uint32) *CryptoParams + type Facade interface + ComputeTransactionGasLimit func(tx *transaction.Transaction) (*transaction.CostResponse, error) + CreateTransaction func(nonce uint64, value string, receiver string, receiverUsername []byte, ...) (*transaction.Transaction, []byte, error) + DecodeAddressPubkey func(pk string) ([]byte, error) + EncodeAddressPubkey func(pk []byte) (string, error) + ExecuteSCQuery func(*process.SCQuery) (*vm.VMOutputApi, error) + GetAccount func(address string, options api.AccountQueryOptions) (dataApi.AccountResponse, api.BlockInfo, error) + GetAllESDTTokens func(address string, options api.AccountQueryOptions) (map[string]*esdt.ESDigitalToken, api.BlockInfo, error) + GetAllIssuedESDTs func(tokenType string) ([]string, error) + GetBalance func(address string, options api.AccountQueryOptions) (*big.Int, api.BlockInfo, error) + GetBlockByHash func(hash string, options api.BlockQueryOptions) (*dataApi.Block, error) + GetBlockByNonce func(nonce uint64, options api.BlockQueryOptions) (*dataApi.Block, error) + GetBlockByRound func(round uint64, options api.BlockQueryOptions) (*dataApi.Block, error) + GetDelegatorsList func() ([]*dataApi.Delegator, error) + GetDirectStakedList func() ([]*dataApi.DirectStakedValue, error) + GetESDTData func(address string, key string, nonce uint64, options api.AccountQueryOptions) (*esdt.ESDigitalToken, api.BlockInfo, error) + GetESDTsRoles func(address string, options api.AccountQueryOptions) (map[string][]string, api.BlockInfo, error) + GetESDTsWithRole func(address string, role string, options api.AccountQueryOptions) ([]string, api.BlockInfo, error) + GetEpochStartDataAPI func(epoch uint32) (*common.EpochStartDataAPI, error) + GetGasConfigs func() (map[string]map[string]uint64, error) + GetGenesisBalances func() ([]*common.InitialAccountAPI, error) + GetGenesisNodesPubKeys func() (map[uint32][]string, map[uint32][]string, error) + GetHeartbeats func() ([]data.PubKeyHeartbeat, error) + GetKeyValuePairs func(address string, options api.AccountQueryOptions) (map[string]string, api.BlockInfo, error) + GetLastPoolNonceForSender func(sender string) (uint64, error) + GetNFTTokenIDsRegisteredByAddress func(address string, options api.AccountQueryOptions) ([]string, api.BlockInfo, error) + GetPeerInfo func(pid string) ([]core.QueryP2PPeerInfo, error) + GetProof func(rootHash string, address string) (*common.GetProofResponse, error) + GetProofCurrentRootHash func(address string) (*common.GetProofResponse, error) + GetProofDataTrie func(rootHash string, address string, key string) (*common.GetProofResponse, *common.GetProofResponse, error) + GetQueryHandler func(name string) (debug.QueryHandler, error) + GetThrottlerForEndpoint func(endpoint string) (core.Throttler, bool) + GetTokenSupply func(token string) (*dataApi.ESDTSupply, error) + GetTotalStakedValue func() (*dataApi.StakeValues, error) + GetTransaction func(hash string, withResults bool) (*transaction.ApiTransactionResult, error) + GetTransactionsPool func(fields string) (*common.TransactionsPoolAPIResponse, error) + GetTransactionsPoolForSender func(sender, fields string) (*common.TransactionsPoolForSenderApiResponse, error) + GetTransactionsPoolNonceGapsForSender func(sender string) (*common.TransactionsPoolNonceGapsForSenderApiResponse, error) + GetUsername func(address string, options api.AccountQueryOptions) (string, api.BlockInfo, error) + GetValueForKey func(address string, key string, options api.AccountQueryOptions) (string, api.BlockInfo, error) + IsInterfaceNil func() bool + IsSelfTrigger func() bool + SendBulkTransactions func([]*transaction.Transaction) (uint64, error) + SimulateTransactionExecution func(tx *transaction.Transaction) (*txSimData.SimulationResults, error) + StatusMetrics func() external.StatusMetricsHandler + Trigger func(epoch uint32, withEarlyEndOfEpoch bool) error + ValidateTransaction func(tx *transaction.Transaction) error + ValidateTransactionForSimulation func(tx *transaction.Transaction, bypassSignature bool) error + ValidatorStatisticsApi func() (map[string]*state.ValidatorApiResponse, error) + VerifyProof func(rootHash string, address string, proof [][]byte) (bool, error) + type GasScheduleMap = map[string]map[string]uint64 + type IndexHashedNodesCoordinatorFactory struct + func (tpn *IndexHashedNodesCoordinatorFactory) CreateNodesCoordinator(arg ArgIndexHashedNodesCoordinatorFactory) nodesCoordinator.NodesCoordinator + type IndexHashedNodesCoordinatorWithRaterFactory struct + func (ihncrf *IndexHashedNodesCoordinatorWithRaterFactory) CreateNodesCoordinator(arg ArgIndexHashedNodesCoordinatorFactory) nodesCoordinator.NodesCoordinator + type NetworkShardingUpdater interface + GetPeerInfo func(pid core.PeerID) core.P2PPeerInfo + IsInterfaceNil func() bool + PutPeerIdShardId func(pid core.PeerID, shardID uint32) + PutPeerIdSubType func(pid core.PeerID, peerSubType core.P2PPeerSubType) + UpdatePeerIDInfo func(pid core.PeerID, pk []byte, shardID uint32) + UpdatePeerIDPublicKeyPair func(pid core.PeerID, pk []byte) + type NodeSlice = []*TestProcessorNode + type NodesByShardMap = map[ShardIdentifier]NodeSlice + type NodesCoordinatorFactory interface + CreateNodesCoordinator func(arg ArgIndexHashedNodesCoordinatorFactory) nodesCoordinator.NodesCoordinator + type NodesWithRater struct + func (nwr *NodesWithRater) IsInterfaceNil() bool + type ShardIdentifier = uint32 + type TestBootstrapper interface + RollBack func(revertUsingForkNonce bool) error + SetProbableHighestNonce func(nonce uint64) + type TestBuiltinFunction struct + Function func(acntSnd, acntDst vmcommon.UserAccountHandler, ...) (*vmcommon.VMOutput, error) + func (bf *TestBuiltinFunction) IsActive() bool + func (bf *TestBuiltinFunction) IsInterfaceNil() bool + func (bf *TestBuiltinFunction) ProcessBuiltinFunction(acntSnd, acntDst vmcommon.UserAccountHandler, ...) (*vmcommon.VMOutput, error) + func (bf *TestBuiltinFunction) SetNewGasConfig(_ *vmcommon.GasCost) + type TestEpochStartTrigger interface + GetRoundsPerEpoch func() uint64 + SetEpoch func(epoch uint32) + SetMinRoundsBetweenEpochs func(minRoundsPerEpoch uint64) + SetRoundsPerEpoch func(roundsPerEpoch uint64) + SetTrigger func(triggerHandler epochStart.TriggerHandler) + type TestHeartbeatNode struct + DataPool dataRetriever.PoolsHolder + DirectConnectionProcessor update.Closer + HeartbeatInterceptor *interceptors.SingleDataInterceptor + Interceptor *CountInterceptor + Messenger p2p.Messenger + NodeKeys TestKeyPair + NodesCoordinator nodesCoordinator.NodesCoordinator + PeerAuthInterceptor *interceptors.MultiDataInterceptor + PeerShardInterceptor *interceptors.SingleDataInterceptor + PeerShardMapper process.NetworkShardingCollector + PeerSigHandler crypto.PeerSignatureHandler + RequestHandler process.RequestHandler + RequestedItemsHandler dataRetriever.RequestedItemsHandler + RequestsProcessor update.Closer + ResolverFinder dataRetriever.ResolversFinder + ResolversContainer dataRetriever.ResolversContainer + Sender update.Closer + ShardCoordinator sharding.Coordinator + ShardSender update.Closer + Storage dataRetriever.StorageService + WhiteListHandler process.WhiteListHandler + func NewTestHeartbeatNode(tb testing.TB, maxShards uint32, nodeShardId uint32, minPeersWaiting int, ...) *TestHeartbeatNode + func NewTestHeartbeatNodeWithCoordinator(maxShards uint32, nodeShardId uint32, p2pConfig config.P2PConfig, ...) *TestHeartbeatNode + func (thn *TestHeartbeatNode) Close() + func (thn *TestHeartbeatNode) ConnectTo(connectable Connectable) error + func (thn *TestHeartbeatNode) CountCrossShardMessages() int + func (thn *TestHeartbeatNode) CountGlobalMessages() int + func (thn *TestHeartbeatNode) CountIntraShardMessages() int + func (thn *TestHeartbeatNode) CreateTestInterceptors() + func (thn *TestHeartbeatNode) GetConnectableAddress() string + func (thn *TestHeartbeatNode) InitTestHeartbeatNode(tb testing.TB, minPeersWaiting int) + func (thn *TestHeartbeatNode) IsInterfaceNil() bool + type TestKeyPair struct + Pk crypto.PublicKey + Sk crypto.PrivateKey + type TestNetwork struct + BypassErrorsOnce bool + DefaultGasPrice uint64 + DefaultGasSchedule GasScheduleMap + DefaultNode *TestProcessorNode + DefaultVM []byte + DeploymentAddress Address + MaxGasLimit uint64 + MinGasLimit uint64 + Nodes NodeSlice + NodesInMetashard int + NodesPerShard int + NodesSharded NodesByShardMap + Nonce uint64 + NumShards int + Proposers []int + Round uint64 + T *testing.T + Wallets []*TestWalletAccount + func NewTestNetwork(t *testing.T) *TestNetwork + func NewTestNetworkSized(t *testing.T, numShards int, nodesPerShard int, nodesInMetashard int) *TestNetwork + func (net *TestNetwork) Close() + func (net *TestNetwork) ComputeGasLimit(tx *transaction.Transaction) uint64 + func (net *TestNetwork) ComputeTxFee(tx *transaction.Transaction) *big.Int + func (net *TestNetwork) ComputeTxFeeUint64(tx *transaction.Transaction) uint64 + func (net *TestNetwork) CreateSignedTx(sender *TestWalletAccount, recvAddress Address, value *big.Int, txData []byte) *transaction.Transaction + func (net *TestNetwork) CreateSignedTxUint64(sender *TestWalletAccount, recvAddress Address, value uint64, txData []byte) *transaction.Transaction + func (net *TestNetwork) CreateTx(sender *TestWalletAccount, recvAddress Address, value *big.Int, txData []byte) *transaction.Transaction + func (net *TestNetwork) CreateTxUint64(sender *TestWalletAccount, recvAddress Address, value uint64, txData []byte) *transaction.Transaction + func (net *TestNetwork) CreateWallets(count int) + func (net *TestNetwork) DeployNonpayableSC(owner *TestWalletAccount, fileName string) []byte + func (net *TestNetwork) DeployPayableSC(owner *TestWalletAccount, fileName string) []byte + func (net *TestNetwork) DeploySC(owner *TestWalletAccount, fileName string, payable bool) []byte + func (net *TestNetwork) DeploySCWithInitArgs(owner *TestWalletAccount, fileName string, payable bool, args ...[]byte) []byte + func (net *TestNetwork) GetAccountHandler(address Address) state.UserAccountHandler + func (net *TestNetwork) Increment() + func (net *TestNetwork) MintNodeAccounts(value *big.Int) + func (net *TestNetwork) MintNodeAccountsUint64(value uint64) + func (net *TestNetwork) MintWallets(value *big.Int) + func (net *TestNetwork) MintWalletsUint64(value uint64) + func (net *TestNetwork) NewAddress(creator *TestWalletAccount) Address + func (net *TestNetwork) RequireWalletNoncesInSyncWithState() + func (net *TestNetwork) SendTx(tx *transaction.Transaction) string + func (net *TestNetwork) SendTxFromNode(tx *transaction.Transaction, node *TestProcessorNode) string + func (net *TestNetwork) ShardOfAddress(address Address) ShardIdentifier + func (net *TestNetwork) SignAndSendTx(signer *TestWalletAccount, tx *transaction.Transaction) string + func (net *TestNetwork) SignTx(signer *TestWalletAccount, tx *transaction.Transaction) + func (net *TestNetwork) Start() + func (net *TestNetwork) Step() + func (net *TestNetwork) Steps(steps int) + type TestP2PNode struct + Interceptor *CountInterceptor + KeyGen crypto.KeyGenerator + Messenger p2p.Messenger + NetworkShardingUpdater NetworkShardingUpdater + Node *node.Node + NodeKeys TestKeyPair + NodesCoordinator nodesCoordinator.NodesCoordinator + ShardCoordinator sharding.Coordinator + SingleSigner crypto.SingleSigner + Storage dataRetriever.StorageService + func NewTestP2PNode(maxShards uint32, nodeShardId uint32, p2pConfig config.P2PConfig, ...) *TestP2PNode + func (tP2pNode *TestP2PNode) CountCrossShardMessages() int + func (tP2pNode *TestP2PNode) CountGlobalMessages() int + func (tP2pNode *TestP2PNode) CountIntraShardMessages() int + func (tP2pNode *TestP2PNode) CreateTestInterceptors() + func (tP2pNode *TestP2PNode) RegisterTopicValidator(topic string, processor p2p.MessageProcessor) + type TestProcessorNode struct + AccntState state.AccountsAdapter + ArgsParser process.ArgumentsParser + ArwenChangeLocker common.Locker + BlockBlackListHandler process.TimeCacher + BlockChain data.ChainHandler + BlockProcessor process.BlockProcessor + BlockTracker process.BlockTracker + BlockchainHook *hooks.BlockChainHookImpl + BootstrapStorer *mock.BoostrapStorerMock + Bootstrapper TestBootstrapper + BroadcastMessenger consensus.BroadcastMessenger + ChainID []byte + CounterHdrRecv int32 + CounterMbRecv int32 + CounterMetaRcv int32 + CounterTxRecv int32 + DataPool dataRetriever.PoolsHolder + EconomicsData *economics.TestEconomicsData + EnableEpochs config.EnableEpochs + EpochNotifier process.EpochNotifier + EpochStartNotifier notifier.EpochStartNotifier + EpochStartSystemSCProcessor process.EpochStartSystemSCProcessor + EpochStartTrigger TestEpochStartTrigger + ExportFolder string + ExportHandler update.ExportHandler + FeeAccumulator process.TransactionFeeHandler + ForkDetector process.ForkDetector + GasHandler process.GasHandler + GenesisBlocks map[uint32]data.HeaderHandler + HardforkTrigger node.HardforkTrigger + HeaderIntegrityVerifier process.HeaderIntegrityVerifier + HeaderSigVerifier process.InterceptedHeaderSigVerifier + HeaderValidator process.HeaderConstructionValidator + HistoryRepository dblookupext.HistoryRepository + InitialNodes []*sharding.InitialNode + InterceptorsContainer process.InterceptorsContainer + InterimProcContainer process.IntermediateProcessorContainer + Messenger p2p.Messenger + MinTransactionVersion uint32 + MiniblocksProvider process.MiniBlockProvider + MultiSigner crypto.MultiSigner + NetworkShardingCollector consensus.NetworkShardingCollector + Node *node.Node + NodeKeys *TestKeyPair + NodesCoordinator nodesCoordinator.NodesCoordinator + NodesSetup sharding.GenesisNodesSetupHandler + OwnAccount *TestWalletAccount + PeerShardMapper process.PeerShardMapper + PeerState state.AccountsAdapter + PeersRatingHandler p2p.PeersRatingHandler + PreProcessorsContainer process.PreProcessorsContainer + Rater sharding.PeerAccountListAndRatingHandler + RatingsData *rating.RatingsData + ReceivedTransactions sync.Map + RequestHandler process.RequestHandler + RequestedItemsHandler dataRetriever.RequestedItemsHandler + ResolverFinder dataRetriever.ResolversFinder + ResolversContainer dataRetriever.ResolversContainer + RewardsProcessor process.RewardTransactionProcessor + RoundHandler *mock.RoundHandlerMock + SCQueryService external.SCQueryService + ScProcessor *smartContract.TestScProcessor + ScrForwarder process.IntermediateTransactionHandler + ShardCoordinator sharding.Coordinator + SmartContractParser genesis.InitialSmartContractParser + Storage dataRetriever.StorageService + StorageBootstrapper *mock.StorageBootstrapperMock + SystemSCFactory vm.SystemSCContainerFactory + TransactionLogProcessor process.TransactionLogProcessor + TrieContainer common.TriesHolder + TrieStorageManagers map[string]common.StorageManager + TxCoordinator process.TransactionCoordinator + TxProcessor process.TransactionProcessor + UseValidVmBlsSigVerifier bool + VMContainer process.VirtualMachinesContainer + ValidatorStatisticsProcessor process.ValidatorStatisticsProcessor + WaitTime time.Duration + WhiteListHandler process.WhiteListHandler + WhiteListerVerifiedTxs process.WhiteListHandler + func CreateNode(nodesPerShard int, nbMetaNodes int, shardConsensusGroupSize int, ...) *TestProcessorNode + func CreateNodeWithBLSAndTxKeys(nodesPerShard int, nbMetaNodes int, shardConsensusGroupSize int, ...) *TestProcessorNode + func CreateNodes(numOfShards int, nodesPerShard int, numMetaChainNodes int) []*TestProcessorNode + func CreateNodesWithBLSSigVerifier(numOfShards int, nodesPerShard int, numMetaChainNodes int) []*TestProcessorNode + func CreateNodesWithCustomStateCheckpointModulus(numOfShards int, nodesPerShard int, numMetaChainNodes int, ...) []*TestProcessorNode + func CreateNodesWithEnableEpochs(numOfShards int, nodesPerShard int, numMetaChainNodes int, ...) []*TestProcessorNode + func NewTestProcessorNode(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32) *TestProcessorNode + func NewTestProcessorNodeWithBLSSigVerifier(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32) *TestProcessorNode + func NewTestProcessorNodeWithCustomDataPool(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32, ...) *TestProcessorNode + func NewTestProcessorNodeWithCustomNodesCoordinator(maxShards uint32, nodeShardId uint32, ...) *TestProcessorNode + func NewTestProcessorNodeWithEnableEpochs(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32, ...) *TestProcessorNode + func NewTestProcessorNodeWithFullGenesis(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32, ...) *TestProcessorNode + func NewTestProcessorNodeWithStateCheckpointModulus(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32, ...) *TestProcessorNode + func NewTestProcessorNodeWithStorageTrieAndGasModel(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32, ...) *TestProcessorNode + func NewTestSyncNode(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32) *TestProcessorNode + func ProposeBlockWithConsensusSignature(shardId uint32, nodesMap map[uint32][]*TestProcessorNode, round uint64, ...) (data.BodyHandler, data.HeaderHandler, [][]byte, []*TestProcessorNode) + func SetupSyncNodesOneShardAndMeta(numNodesPerShard int, numNodesMeta int) ([]*TestProcessorNode, []int) + func (tpn *TestProcessorNode) BroadcastBlock(body data.BodyHandler, header data.HeaderHandler) + func (tpn *TestProcessorNode) Close() + func (tpn *TestProcessorNode) CommitBlock(body data.BodyHandler, header data.HeaderHandler) + func (tpn *TestProcessorNode) ConnectTo(connectable Connectable) error + func (tpn *TestProcessorNode) GetBlockBody(header data.HeaderHandler) (*dataBlock.Body, error) + func (tpn *TestProcessorNode) GetConnectableAddress() string + func (tpn *TestProcessorNode) GetMetaBlockBody(header *dataBlock.MetaBlock) (*dataBlock.Body, error) + func (tpn *TestProcessorNode) GetMetaHeader(nonce uint64) (*dataBlock.MetaBlock, error) + func (tpn *TestProcessorNode) GetShardHeader(nonce uint64) (data.HeaderHandler, error) + func (tpn *TestProcessorNode) InitDelegationManager() + func (tpn *TestProcessorNode) InitializeProcessors(gasMap map[string]map[string]uint64) + func (tpn *TestProcessorNode) IsInterfaceNil() bool + func (tpn *TestProcessorNode) LoadTxSignSkBytes(skBytes []byte) + func (tpn *TestProcessorNode) MiniBlocksPresent(hashes [][]byte) bool + func (tpn *TestProcessorNode) ProposeBlock(round uint64, nonce uint64) (data.BodyHandler, data.HeaderHandler, [][]byte) + func (tpn *TestProcessorNode) SendTransaction(tx *dataTransaction.Transaction) (string, error) + func (tpn *TestProcessorNode) SetAccountNonce(nonce uint64) error + func (tpn *TestProcessorNode) StartSync() error + func (tpn *TestProcessorNode) SyncNode(nonce uint64) error + func (tpn *TestProcessorNode) WhiteListBody(nodes []*TestProcessorNode, bodyHandler data.BodyHandler) + type TestProcessorNodeWithTestWebServer struct + func NewTestProcessorNodeWithTestWebServer(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32) *TestProcessorNodeWithTestWebServer + func (node *TestProcessorNodeWithTestWebServer) DoRequest(request *http.Request) *httptest.ResponseRecorder + type TestStorage struct + func NewTestStorage() *TestStorage + func (ts *TestStorage) CreateStorageLevelDB() storage.Storer + func (ts *TestStorage) CreateStorageLevelDBSerial() storage.Storer + func (ts *TestStorage) CreateStoredData(nonce uint64) ([]byte, []byte) + func (ts *TestStorage) InitAdditionalFieldsForStorageOperations(nbTxsWrite int, mapRemovedKeys *sync.Map, maxWritten *uint64) + func (ts *TestStorage) ReadMultiple(store storage.Storer, wg *sync.WaitGroup, chStartTrigger chan struct{}, ...) + func (ts *TestStorage) RemoveMultiple(store storage.Storer, wg *sync.WaitGroup, chEndRemove chan struct{}, ...) + func (ts *TestStorage) WriteMultipleWithNotif(store storage.Storer, wg *sync.WaitGroup, chWriteDone chan struct{}, ...) + type TestWalletAccount struct + Address []byte + Balance *big.Int + BlockSingleSigner crypto.SingleSigner + KeygenBlockSign crypto.KeyGenerator + KeygenTxSign crypto.KeyGenerator + Nonce uint64 + PeerSigHandler crypto.PeerSignatureHandler + PkTxSign crypto.PublicKey + PkTxSignBytes []byte + SingleSigner crypto.SingleSigner + SkTxSign crypto.PrivateKey + func CreateTestWalletAccount(coordinator sharding.Coordinator, shardId uint32) *TestWalletAccount + func CreateTestWalletAccountWithKeygenAndSingleSigner(coordinator sharding.Coordinator, shardId uint32, ...) *TestWalletAccount + func (twa *TestWalletAccount) LoadTxSignSkBytes(skBytes []byte) + type Type uint8 + const UserAccount + const ValidatorAccount