utils

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 12, 2019 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// RPCTimeout defines rpc timeout
	RPCTimeout = 10 * time.Second
	// RPCInterval defines rpc query interval
	RPCInterval = 300 * time.Millisecond
)

Variables

View Source 
var (

	// NewNodes flag indicates to need to start nodes
	NewNodes = flag.Bool("nodes", true, "need to start nodes?")
	// EnableDocker flag indicates to need start docker
	EnableDocker = flag.Bool("docker", false, "test in docker containers?")

	// LocalConf defines local test devconfig
	LocalConf = struct {
		ConfDir, WorkDir, KeyDir string
	}{"./.devconfig/", "./.devconfig/", "./.devconfig/keyfile/"}

	// DockerConf defines docker test devconfig
	DockerConf = struct {
		ConfDir, WorkDir, KeyDir string
	}{"../docker/.devconfig/", "../docker/.devconfig/", "../docker/.devconfig/keyfile/"}
)
View Source 
var (
	// ErrItems record functional errors during integration tests
	ErrItems = make([]error, 0, maxErrItems)
)

Functions

func BalanceFor 

func BalanceFor(accAddr string, conn *grpc.ClientConn) uint64

BalanceFor get balance of accAddr

func BalanceNoPanicFor added in v0.5.0 

func BalanceNoPanicFor(accAddr string, conn *grpc.ClientConn) (uint64, error)

BalanceNoPanicFor returns accAddr's balance without panic

func CallContract added in v0.5.0 

func CallContract(addr, contractAddr string, code []byte, conn *grpc.ClientConn) []byte

CallContract calls contract with code

func CircuAccounts 

func CircuAccounts() int

CircuAccounts return circuAccounts

func CircuRepeatRandom 

func CircuRepeatRandom() bool

CircuRepeatRandom return circuRepeatRandom

func CircuRepeatTxTimes 

func CircuRepeatTxTimes() int

CircuRepeatTxTimes return circuRepeatTxTimes

func CircuUnitAccounts 

func CircuUnitAccounts() int

CircuUnitAccounts return circuUnitAccounts

func Closing 

func Closing(quitCh <-chan os.Signal) bool

Closing check if receive quit signal

func CollAccounts 

func CollAccounts() int

CollAccounts return collAccounts

func CollUnitAccounts 

func CollUnitAccounts() int

CollUnitAccounts return collUnitAccounts

func ContractAccounts added in v0.5.0 

func ContractAccounts() int

ContractAccounts return contractAccounts

func ContractRepeatRandom added in v0.5.0 

func ContractRepeatRandom() bool

ContractRepeatRandom return circuRepeatRandom

func ContractRepeatTxTimes added in v0.5.0 

func ContractRepeatTxTimes() int

ContractRepeatTxTimes return contractRepeatTxTimes

func ContractTestEnable added in v0.5.0 

func ContractTestEnable() bool

ContractTestEnable return contractTestEnable

func ContractUnitAccounts added in v0.5.0 

func ContractUnitAccounts() int

ContractUnitAccounts return contractUnitAccounts

func GenTestAddr 

func GenTestAddr(count int) []string

GenTestAddr defines generate test address

func GetBoolCfgVal 

func GetBoolCfgVal(def interface{}, keys ...string) (bool, error)

GetBoolCfgVal get bool value

func GetBoolSpecCfgVal 

func GetBoolSpecCfgVal(cfgData CfgData, def interface{}, keys ...string) (bool, error)

GetBoolSpecCfgVal get bool value

func GetCfgVal 

func GetCfgVal(def interface{}, keys ...string) (interface{}, error)

GetCfgVal get value from default cfgData

func GetFloatArrayCfgVal 

func GetFloatArrayCfgVal(def interface{}, keys ...string) ([]float64, error)

GetFloatArrayCfgVal get float array value

func GetFloatArraySpecCfgVal 

func GetFloatArraySpecCfgVal(cfgData CfgData, def interface{}, keys ...string) ([]float64, error)

GetFloatArraySpecCfgVal get float array value

func GetFloatCfgVal 

func GetFloatCfgVal(def interface{}, keys ...string) (float64, error)

GetFloatCfgVal get float value

func GetFloatSpecCfgVal 

func GetFloatSpecCfgVal(cfgData CfgData, def interface{}, keys ...string) (float64, error)

GetFloatSpecCfgVal get float value

func GetIniKV 

func GetIniKV(iniBuf, key string) string

GetIniKV parses ini buff and get value of key

func GetIntArrayCfgVal 

func GetIntArrayCfgVal(def interface{}, keys ...string) ([]int, error)

GetIntArrayCfgVal get int array value

func GetIntArraySpecCfgVal 

func GetIntArraySpecCfgVal(cfgData CfgData, def interface{}, keys ...string) ([]int, error)

GetIntArraySpecCfgVal get int array value

func GetIntCfgVal 

func GetIntCfgVal(def interface{}, keys ...string) (int, error)

GetIntCfgVal get int config value

func GetIntSpecCfgVal 

func GetIntSpecCfgVal(cfgData CfgData, def interface{}, keys ...string) (int, error)

GetIntSpecCfgVal get int config vlaue

func GetSpecCfgVal 

func GetSpecCfgVal(cfgData CfgData, def interface{}, keys ...string) (
	v interface{}, err error)

GetSpecCfgVal get special cfg value from param cfgdata

func GetStrArrayCfgVal 

func GetStrArrayCfgVal(def interface{}, keys ...string) ([]string, error)

GetStrArrayCfgVal get string array value

func GetStrArraySpecCfgVal 

func GetStrArraySpecCfgVal(cfgData CfgData, def interface{}, keys ...string) ([]string, error)

GetStrArraySpecCfgVal get string array value

func GetStringCfgVal 

func GetStringCfgVal(def interface{}, keys ...string) (string, error)

GetStringCfgVal get string cfg value

func GetStringSpecCfgVal 

func GetStringSpecCfgVal(cfgData CfgData, def interface{}, keys ...string) (
	string, error)

GetStringSpecCfgVal get string cfg value

func InitConf 

func InitConf(cfgFile string) error

InitConf init config and store them int default variable cfgData

func LoadConf 

func LoadConf() error

LoadConf load config file

func LoadJSONFromFile 

func LoadJSONFromFile(fileName string, result interface{}) error

LoadJSONFromFile load json from file to result

func MinerAccounts 

func MinerAccounts(keyFiles ...string) ([]string, []*acc.Account)

MinerAccounts get miners' accounts

func MinerAddrs 

func MinerAddrs() []string

MinerAddrs gets miners addresses from config file

func NonceFor added in v0.5.0 

func NonceFor(addr string, conn *grpc.ClientConn) uint64

NonceFor returns address' nonce in blockchain state

func ParseIPlist 

func ParseIPlist(fileName string) ([]string, error)

ParseIPlist parse ip list from json file

func PeerAddrs 

func PeerAddrs() []string

PeerAddrs gets execute transactions peers addresses from config file

func PrepareEnv 

func PrepareEnv(count int) error

PrepareEnv prepare env

func RemoveKeystoreFiles 

func RemoveKeystoreFiles(addrs ...string)

RemoveKeystoreFiles removes key store files

func SplitAddrAccounts 

func SplitAddrAccounts() int

SplitAddrAccounts return splitAddrAccounts

func SplitAddrRepeatRandom 

func SplitAddrRepeatRandom() bool

SplitAddrRepeatRandom return splitAddrRepeatRandom

func SplitAddrRepeatTxTimes 

func SplitAddrRepeatTxTimes() int

SplitAddrRepeatTxTimes return splitAddrRepeatTxTimes

func SplitAddrTestEnable 

func SplitAddrTestEnable() bool

SplitAddrTestEnable return splitAddrTestEnable

func SplitAddrUnitAccounts 

func SplitAddrUnitAccounts() int

SplitAddrUnitAccounts return splitAddrUnitAccounts

func StartDockerNodes 

func StartDockerNodes() error

StartDockerNodes start nodes

func StartLocalNodes 

func StartLocalNodes(peerCount int) ([]*os.Process, error)

StartLocalNodes start local nodes

func StartProcess 

func StartProcess(args ...string) (*os.Process, error)

StartProcess starts a process with args and default process attributions

func StopLocalNodes 

func StopLocalNodes(processes ...*os.Process) error

StopLocalNodes stop local nodes

func StopNodes 

func StopNodes() error

StopNodes stop nodes

func TearDown 

func TearDown(count int) error

TearDown clean resource and files

func TickerDurationTxs 

func TickerDurationTxs() time.Duration

TickerDurationTxs get ticker duration for calc tx count

func TimesToUpdateAddrs 

func TimesToUpdateAddrs() int

TimesToUpdateAddrs return timesToUpdateAddrs

func TokenAccounts 

func TokenAccounts() int

TokenAccounts return tokenAccounts

func TokenBalanceFor 

func TokenBalanceFor(
	addr string, tokenHash string, tokenIndex uint32, conn *grpc.ClientConn,
) uint64

TokenBalanceFor get token balance of addr

func TokenRepeatRandom 

func TokenRepeatRandom() bool

TokenRepeatRandom return circuRepeatRandom

func TokenRepeatTxTimes 

func TokenRepeatTxTimes() int

TokenRepeatTxTimes return tokenRepeatTxTimes

func TokenTestEnable 

func TokenTestEnable() bool

TokenTestEnable return tokenTestEnable

func TokenUnitAccounts 

func TokenUnitAccounts() int

TokenUnitAccounts return tokenUnitAccounts

func TryRecordError 

func TryRecordError(err error) bool

TryRecordError try to record error during integration test

func TxTestEnable 

func TxTestEnable() bool

TxTestEnable return txTestEnable

func UnlockAccount 

func UnlockAccount(addr string) *acc.Account

UnlockAccount defines unlock account

func WaitBalanceEnough 

func WaitBalanceEnough(addr string, amount uint64, conn *grpc.ClientConn,
	timeout time.Duration) (uint64, error)

WaitBalanceEnough wait balance of addr is more than amount

func WaitBalanceEqual 

func WaitBalanceEqual(addr string, amount uint64, conn *grpc.ClientConn,
	timeout time.Duration) (uint64, error)

WaitBalanceEqual wait balance of addr is more than amount

func WaitERC20AllowanceEqualTo added in v0.5.0 

func WaitERC20AllowanceEqualTo(
	addr, contractAddr string, amount uint64, code []byte, conn *grpc.ClientConn,
	timeout time.Duration,
) error

WaitERC20AllowanceEqualTo waits ERC20 allowance of addr equal to amount

func WaitERC20BalanceEqualTo added in v0.5.0 

func WaitERC20BalanceEqualTo(
	addr, contractAddr string, amount uint64, code []byte, conn *grpc.ClientConn,
	timeout time.Duration,
) error

WaitERC20BalanceEqualTo waits ERC20 balance of addr equal to amount

func WaitTokenBalanceEnough 

func WaitTokenBalanceEnough(
	addr string, amount uint64, thash string, idx uint32, conn *grpc.ClientConn,
	timeout time.Duration,
) (uint64, error)

WaitTokenBalanceEnough wait tokken balance of addr is more than amount

func WaitTokenBalanceEqualTo 

func WaitTokenBalanceEqualTo(
	addr string, amount uint64, thash string, idx uint32, conn *grpc.ClientConn,
	timeout time.Duration,
) error

WaitTokenBalanceEqualTo wait token balance of addr equal to amount

Types

type CfgData 

type CfgData map[string]*json.RawMessage

CfgData define config data responding conf.json

func InitSpecConf 

func InitSpecConf(cfgFile string) (CfgData, error)

InitSpecConf inits config and return CfgData variable

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.