Documentation ¶
Index ¶
- func CheckPendingActionList(cs *chainservice.ChainService, pendingActionMap *sync.Map, ...) (bool, error)
- func DeployContract(client iotexapi.APIServiceClient, counter map[string]uint64, ...) (hash.Hash256, error)
- func GetAllBalanceMap(client iotexapi.APIServiceClient, chainaddrs []*AddressKey) map[string]*big.Int
- func GetTotalTsfCreated() uint64
- func GetTotalTsfFailed() uint64
- func GetTotalTsfSentToAPI() uint64
- func GetTotalTsfSucceeded() uint64
- func InitCounter(client iotexapi.APIServiceClient, addrKeys []*AddressKey) (map[string]uint64, error)
- func InjectByAps(wg *sync.WaitGroup, aps float64, counter map[string]uint64, ...)
- func InjectByInterval(transferNum int, transferGasLimit int, transferGasPrice int, ...)
- type AddressKey
- type KeyPair
- type KeyPairs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckPendingActionList ¶
func CheckPendingActionList( cs *chainservice.ChainService, pendingActionMap *sync.Map, balancemap *map[string]*big.Int, ) (bool, error)
CheckPendingActionList will go through the pending action list, for an executed action: 1) update the expectation balance map if the action has been run successfully 2) remove the action from pending list
func DeployContract ¶
func DeployContract( client iotexapi.APIServiceClient, counter map[string]uint64, delegates []*AddressKey, executionGasLimit int, executionGasPrice int64, executionData string, retryNum int, retryInterval int, ) (hash.Hash256, error)
DeployContract deploys a smart contract before starting action injections
func GetAllBalanceMap ¶
func GetAllBalanceMap( client iotexapi.APIServiceClient, chainaddrs []*AddressKey, ) map[string]*big.Int
GetAllBalanceMap returns a account balance map of all admins and delegates
func GetTotalTsfCreated ¶
func GetTotalTsfCreated() uint64
GetTotalTsfCreated returns number of total transfer action created
func GetTotalTsfFailed ¶
func GetTotalTsfFailed() uint64
GetTotalTsfFailed returns number of total transfer action failed
func GetTotalTsfSentToAPI ¶
func GetTotalTsfSentToAPI() uint64
GetTotalTsfSentToAPI returns number of total transfer action successfully send through GRPC
func GetTotalTsfSucceeded ¶
func GetTotalTsfSucceeded() uint64
GetTotalTsfSucceeded returns number of total transfer action created
func InitCounter ¶
func InitCounter(client iotexapi.APIServiceClient, addrKeys []*AddressKey) (map[string]uint64, error)
InitCounter initializes the map of nonce counter of each address
func InjectByAps ¶
func InjectByAps( wg *sync.WaitGroup, aps float64, counter map[string]uint64, transferGasLimit int, transferGasPrice int64, transferPayload string, voteGasLimit int, voteGasPrice int64, contract string, executionAmount int, executionGasLimit int, executionGasPrice int64, executionData string, fpToken blockchain.FpToken, fpContract string, debtor *AddressKey, creditor *AddressKey, client iotexapi.APIServiceClient, admins []*AddressKey, delegates []*AddressKey, duration time.Duration, retryNum int, retryInterval int, resetInterval int, expectedBalances *map[string]*big.Int, cs *chainservice.ChainService, pendingActionMap *sync.Map, )
InjectByAps injects Actions in APS Mode
func InjectByInterval ¶
func InjectByInterval( transferNum int, transferGasLimit int, transferGasPrice int, transferPayload string, voteNum int, voteGasLimit int, voteGasPrice int, executionNum int, contract string, executionAmount int, executionGasLimit int, executionGasPrice int, executionData string, interval int, counter map[string]uint64, client iotexapi.APIServiceClient, admins []*AddressKey, delegates []*AddressKey, retryNum int, retryInterval int, )
InjectByInterval injects Actions in Interval Mode
Types ¶
type AddressKey ¶
type AddressKey struct { EncodedAddr string PriKey keypair.PrivateKey }
AddressKey contains the encoded address and private key of an account
func LoadAddresses ¶
func LoadAddresses(keypairsPath string, chainID uint32) ([]*AddressKey, error)
LoadAddresses loads key pairs from key pair path and construct addresses