Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 Changes in this version + const GlobalTopic + const MaxGasLimitPerBlock + const OpGasValueForMockVm + 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.Second / 10 + var SyncDelay = time.Second / 5 + var TestAddressPubkeyConverter = pubkeyConverter.NewBech32PubkeyConverter(32) + var TestBalanceComputationHandler = preprocess.NewBalanceComputation() + var TestBlockSizeComputationHandler = preprocess.NewBlockSizeComputation(TestMarshalizer, TestBlockSizeThrottler, uint32(core.MegabyteSize * 90 / 100)) + var TestBlockSizeThrottler = &mock.BlockSizeThrottlerStub + var TestBuiltinFunctions = make(map[string]process.BuiltinFunction) + var TestHasher = sha256.Sha256 + var TestKeyGenForAccounts = signing.NewKeyGenerator(ed25519.NewEd25519()) + var TestMarshalizer = &marshal.GogoProtoMarshalizer + var TestMultiSig = mock.NewMultiSigner(1) + var TestTxSignHasher = keccak.Keccak + 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 data.StorageManager) (*state.AccountsDB, data.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.HeaderHandler + func CreateHeaderIntegrityVerifier() process.HeaderIntegrityVerifier + func CreateMemUnit() storage.Storer + func CreateMessengerFromConfig(p2pConfig config.P2PConfig) p2p.Messenger + func CreateMessengerWithKadDht(initialAddr string) p2p.Messenger + func CreateMessengerWithKadDhtAndProtocolID(initialAddr string, protocolID string) p2p.Messenger + func CreateMessengerWithNoDiscovery() p2p.Messenger + func CreateMetaChain() data.ChainHandler + func CreateMintingForSenders(nodes []*TestProcessorNode, senderShard uint32, ...) + func CreateMintingFromAddresses(nodes []*TestProcessorNode, addresses [][]byte, value *big.Int) + func CreateNewDefaultTrie() data.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 CreateNodesWithTestP2PNodes(nodesPerShard int, numMetaNodes int, numShards int, ...) map[uint32][]*TestP2PNode + 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) (data.StorageManager, storage.Storer) + 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][]sharding.GenesisNodeInfoHandler + func GenValidatorsFromPubKeysAndTxPubKeys(blsPubKeysMap map[uint32][]string, txPubKeysMap map[uint32][]string) map[uint32][]sharding.GenesisNodeInfoHandler + func GenerateAddressJournalAccountAccountsDB() ([]byte, state.UserAccountHandler, *state.AccountsDB) + func GenerateAndDisseminateTxs(n *TestProcessorNode, senders []crypto.PrivateKey, ...) + func GenerateIntraShardTransactions(nodesMap map[uint32][]*TestProcessorNode, nbTxsPerShard uint32, ...) + 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 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 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 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) + CreateMiddlewareLimiters func() ([]api.MiddlewareProcessor, 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) (state.UserAccountHandler, error) + GetAllESDTTokens func(address string) (map[string]*esdt.ESDigitalToken, error) + GetBalance func(address string) (*big.Int, error) + GetBlockByHash func(hash string, withTxs bool) (*dataApi.Block, error) + GetBlockByNonce func(nonce uint64, withTxs bool) (*dataApi.Block, error) + GetCode func(account state.UserAccountHandler) []byte + GetESDTData func(address string, key string, nonce uint64) (*esdt.ESDigitalToken, error) + GetESDTsWithRole func(address string, role string) ([]string, error) + GetHeartbeats func() ([]data.PubKeyHeartbeat, error) + GetNFTTokenIDsRegisteredByAddress func(address string) ([]string, error) + GetNumCheckpointsFromAccountState func() uint32 + GetNumCheckpointsFromPeerState func() uint32 + GetPeerInfo func(pid string) ([]core.QueryP2PPeerInfo, error) + GetQueryHandler func(name string) (debug.QueryHandler, error) + GetThrottlerForEndpoint func(endpoint string) (core.Throttler, bool) + GetTotalStakedValue func() (*dataApi.StakeValues, error) + GetTransaction func(hash string, withResults bool) (*transaction.ApiTransactionResult, error) + GetUsername func(address string) (string, error) + GetValueForKey func(address string, key string) (string, error) + IsInterfaceNil func() bool + IsSelfTrigger func() bool + SendBulkTransactions func([]*transaction.Transaction) (uint64, error) + SimulateTransactionExecution func(tx *transaction.Transaction) (*transaction.SimulationResults, error) + StatusMetrics func() external.StatusMetricsHandler + TpsBenchmark func() *statistics.TpsBenchmark + 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) + type IndexHashedNodesCoordinatorFactory struct + func (tpn *IndexHashedNodesCoordinatorFactory) CreateNodesCoordinator(arg ArgIndexHashedNodesCoordinatorFactory) sharding.NodesCoordinator + type IndexHashedNodesCoordinatorWithRaterFactory struct + func (ihncrf *IndexHashedNodesCoordinatorWithRaterFactory) CreateNodesCoordinator(arg ArgIndexHashedNodesCoordinatorFactory) sharding.NodesCoordinator + type NetworkShardingUpdater interface + GetPeerInfo func(pid core.PeerID) core.P2PPeerInfo + IsInterfaceNil func() bool + UpdatePeerIdPublicKey func(pid core.PeerID, pk []byte) + UpdatePeerIdShardId func(pid core.PeerID, shardId uint32) + UpdatePublicKeyShardId func(pk []byte, shardId uint32) + type NodesCoordinatorFactory interface + CreateNodesCoordinator func(arg ArgIndexHashedNodesCoordinatorFactory) sharding.NodesCoordinator + type NodesWithRater struct + func (nwr *NodesWithRater) IsInterfaceNil() bool + type TestBootstrapper interface + RollBack func(revertUsingForkNonce bool) error + SetProbableHighestNonce func(nonce uint64) + type TestBuiltinFunction struct + Function func(acntSnd, acntDst state.UserAccountHandler, vmInput *vmcommon.ContractCallInput) (*vmcommon.VMOutput, error) + func (bf *TestBuiltinFunction) IsInterfaceNil() bool + func (bf *TestBuiltinFunction) ProcessBuiltinFunction(acntSnd, acntDst state.UserAccountHandler, vmInput *vmcommon.ContractCallInput) (*vmcommon.VMOutput, error) + func (bf *TestBuiltinFunction) SetNewGasConfig(_ *process.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 TestKeyPair struct + Pk crypto.PublicKey + Sk crypto.PrivateKey + type TestP2PNode struct + Interceptor *CountInterceptor + KeyGen crypto.KeyGenerator + Messenger p2p.Messenger + NetworkShardingUpdater NetworkShardingUpdater + Node *node.Node + NodeKeys TestKeyPair + NodesCoordinator sharding.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 process.Locker + BlockBlackListHandler process.TimeCacher + BlockChain data.ChainHandler + BlockGasAndFeesReCheckEnableEpoch uint32 + BlockProcessor process.BlockProcessor + BlockTracker process.BlockTracker + BlockchainHook *hooks.BlockChainHookImpl + BootstrapStorer *mock.BoostrapStorerMock + Bootstrapper TestBootstrapper + BroadcastMessenger consensus.BroadcastMessenger + BuiltinEnableEpoch uint32 + ChainID []byte + CounterHdrRecv int32 + CounterMbRecv int32 + CounterMetaRcv int32 + CounterTxRecv int32 + DataPool dataRetriever.PoolsHolder + DeployEnableEpoch uint32 + EconomicsData *economics.TestEconomicsData + 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 + 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 sharding.NodesCoordinator + NodesSetup sharding.GenesisNodesSetupHandler + OwnAccount *TestWalletAccount + PeerState state.AccountsAdapter + PenalizedTooMuchGasEnableEpoch uint32 + PreProcessorsContainer process.PreProcessorsContainer + Rater sharding.PeerAccountListAndRatingHandler + RatingsData *rating.RatingsData + ReceivedTransactions sync.Map + RelayedTxEnableEpoch uint32 + RequestHandler process.RequestHandler + RequestedItemsHandler dataRetriever.RequestedItemsHandler + ResolverFinder dataRetriever.ResolversFinder + ResolversContainer dataRetriever.ResolversContainer + RewardsProcessor process.RewardTransactionProcessor + Rounder *mock.RounderMock + SCQueryService external.SCQueryService + ScProcessor *smartContract.TestScProcessor + ScrForwarder process.IntermediateTransactionHandler + ShardCoordinator sharding.Coordinator + SmartContractParser genesis.InitialSmartContractParser + Storage dataRetriever.StorageService + StorageBootstrapper *mock.StorageBootstrapperMock + SystemSCFactory vm.SystemSCContainerFactory + TrieContainer state.TriesHolder + TrieStorageManagers map[string]data.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 CreateNodesWithGasSchedule(numOfShards int, nodesPerShard int, numMetaChainNodes int, ...) []*TestProcessorNode + func NewTestProcessorNode(maxShards uint32, nodeShardId uint32, txSignPrivKeyShardId uint32) *TestProcessorNode + func NewTestProcessorNodeSoftFork(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 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) CommitBlock(body data.BodyHandler, header data.HeaderHandler) + func (tpn *TestProcessorNode) ConnectTo(connectable Connectable) error + func (tpn *TestProcessorNode) GetBlockBody(header *dataBlock.Header) (*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) (*dataBlock.Header, 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