spam

Documentation

Index

• Variables
• func RunMarketSpam(args OrdersArgs) error
• type AssetPartyPair
  • func NewAssetPartyPair(assetId, partyId string) AssetPartyPair
  • func (pair AssetPartyPair) String() string
• type BalanceManager
  • func NewBalanceManager(dataNodeClient vegaapi.DataNodeClient, whaleWallet *wallet.VegaWallet, ...) (*BalanceManager, error)
  • func (bm *BalanceManager) AddAssetPartyPair(pair AssetPartyPair) error
  • func (bm *BalanceManager) Run() error
  • func (bm *BalanceManager) TopUpPair(lastBlockData *vegaapipb.LastBlockHeightResponse, pair AssetPartyPair, ...) error
• type OrderSpammer
  • func NewOrderSpammer(threads uint8, marketId string, rateLimit, minPrice, maxPrice uint64, ...) (*OrderSpammer, error)
  • func (spammer *OrderSpammer) LastBlockMonitor()
  • func (spammer *OrderSpammer) Report()
  • func (spammer *OrderSpammer) Run() error
  • func (spammer *OrderSpammer) Stop()
• type OrdersArgs

Variables

var SpamCmd = &cobra.Command{
	Use:   "spam",
	Short: "Set of tools for network stress-tests",
}

Root Command for Spam

Functions

func RunMarketSpam

func RunMarketSpam(args OrdersArgs) error

Types

type AssetPartyPair

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

func NewAssetPartyPair

func NewAssetPartyPair(assetId, partyId string) AssetPartyPair

func (AssetPartyPair) String

func (pair AssetPartyPair) String() string

type BalanceManager

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

func NewBalanceManager

func NewBalanceManager(dataNodeClient vegaapi.DataNodeClient, whaleWallet *wallet.VegaWallet, tickPeriod time.Duration) (*BalanceManager, error)

func (*BalanceManager) AddAssetPartyPair

func (bm *BalanceManager) AddAssetPartyPair(pair AssetPartyPair) error

func (*BalanceManager) Run

func (bm *BalanceManager) Run() error

func (*BalanceManager) TopUpPair

func (bm *BalanceManager) TopUpPair(lastBlockData *vegaapipb.LastBlockHeightResponse, pair AssetPartyPair, amount *big.Int) error

type OrderSpammer

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

func NewOrderSpammer

func NewOrderSpammer(threads uint8, marketId string, rateLimit, minPrice, maxPrice uint64, logger *zap.Logger, network *veganetwork.VegaNetwork) (*OrderSpammer, error)

func (*OrderSpammer) LastBlockMonitor

func (spammer *OrderSpammer) LastBlockMonitor()

func (*OrderSpammer) Report

func (spammer *OrderSpammer) Report()

func (*OrderSpammer) Run

func (spammer *OrderSpammer) Run() error

func (*OrderSpammer) Stop

func (spammer *OrderSpammer) Stop()

type OrdersArgs

type OrdersArgs struct {
	*rootCmd.RootArgs
	VegaNetworkName string
	MarketID        string
	Orders          uint64
	Threads         uint8
	MaxPrice        uint64
	MinPrice        uint64
	RateLimit       uint64
	Duration        time.Duration
}