wallet

Documentation

Index

• type Manager
  • func NewManager(clientPool *execution.Pool, logger logrus.FieldLogger) *Manager
  • func (manager *Manager) GetWalletByAddress(address common.Address) *Wallet
  • func (manager *Manager) GetWalletByPrivkey(privkey *ecdsa.PrivateKey) (*Wallet, error)
  • func (manager *Manager) GetWalletPoolByPrivkey(privkey *ecdsa.PrivateKey, walletCount uint64, childSeed string) (*WalletPool, error)
• type SendTransactionOptions
• type Summary
• type TxConfirmFn
• type TxLogFn
• type Wallet
  • func (wallet *Wallet) AwaitReady(ctx context.Context) error
  • func (wallet *Wallet) AwaitTransaction(ctx context.Context, tx *types.Transaction) (*types.Receipt, error)
  • func (wallet *Wallet) BuildTransaction(ctx context.Context, ...) (*types.Transaction, error)
  • func (wallet *Wallet) GetAddress() common.Address
  • func (wallet *Wallet) GetBalance() *big.Int
  • func (wallet *Wallet) GetNonce() uint64
  • func (wallet *Wallet) GetPendingBalance() *big.Int
  • func (wallet *Wallet) GetPrivateKey() *ecdsa.PrivateKey
  • func (wallet *Wallet) GetReadableBalance(unitDigits, maxPreCommaDigitsBeforeTrim, digits int, ...) string
  • func (wallet *Wallet) GetSummary() *Summary
  • func (wallet *Wallet) ResyncState()
  • func (wallet *Wallet) SendTransaction(ctx context.Context, tx *types.Transaction, options *SendTransactionOptions) error
  • func (wallet *Wallet) UseNextNonce(increase bool) uint64
• type WalletPool
  • func (pool *WalletPool) EnsureFunding(ctx context.Context, minBalance, refillAmount, gasFeeCap, gasTipCap *big.Int, ...) error
  • func (pool *WalletPool) GetChildWallet(index uint64) *Wallet
  • func (pool *WalletPool) GetChildWallets() []*Wallet
  • func (pool *WalletPool) GetNextChildWallet() *Wallet
  • func (pool *WalletPool) GetRootWallet() *Wallet

Types

type Manager

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

func NewManager

func NewManager(clientPool *execution.Pool, logger logrus.FieldLogger) *Manager

func (*Manager) GetWalletByAddress

func (manager *Manager) GetWalletByAddress(address common.Address) *Wallet

func (*Manager) GetWalletByPrivkey

func (manager *Manager) GetWalletByPrivkey(privkey *ecdsa.PrivateKey) (*Wallet, error)

func (*Manager) GetWalletPoolByPrivkey

func (manager *Manager) GetWalletPoolByPrivkey(privkey *ecdsa.PrivateKey, walletCount uint64, childSeed string) (*WalletPool, error)

type SendTransactionOptions

type SendTransactionOptions struct {
	Clients            []*execution.Client
	ClientsStartOffset int

	OnConfirm TxConfirmFn
	LogFn     TxLogFn

	MaxRebroadcasts     int
	RebroadcastInterval time.Duration
}

type Summary

type Summary struct {
	Address          string   `json:"address" yaml:"address"`
	PrivKey          string   `json:"privkey" yaml:"privkey"`
	PendingBalance   *big.Int `json:"pendingBalance" yaml:"pendingBalance"`
	PendingNonce     uint64   `json:"pendingNonce" yaml:"pendingNonce"`
	ConfirmedBalance *big.Int `json:"confirmedBalance" yaml:"confirmedBalance"`
	ConfirmedNonce   uint64   `json:"confirmedNonce" yaml:"confirmedNonce"`
}

type TxConfirmFn

type TxConfirmFn func(tx *types.Transaction, receipt *types.Receipt, err error)

type TxLogFn

type TxLogFn func(client *execution.Client, retry int, rebroadcast int, err error)

type Wallet

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

func (*Wallet) AwaitReady

func (wallet *Wallet) AwaitReady(ctx context.Context) error

func (*Wallet) AwaitTransaction

func (wallet *Wallet) AwaitTransaction(ctx context.Context, tx *types.Transaction) (*types.Receipt, error)

func (*Wallet) BuildTransaction

func (wallet *Wallet) BuildTransaction(ctx context.Context, buildFn func(ctx context.Context, nonce uint64, signer bind.SignerFn) (*types.Transaction, error)) (*types.Transaction, error)

func (*Wallet) GetAddress

func (wallet *Wallet) GetAddress() common.Address

func (*Wallet) GetBalance

func (wallet *Wallet) GetBalance() *big.Int

func (*Wallet) GetNonce

func (wallet *Wallet) GetNonce() uint64

func (*Wallet) GetPendingBalance

func (wallet *Wallet) GetPendingBalance() *big.Int

func (*Wallet) GetPrivateKey

func (wallet *Wallet) GetPrivateKey() *ecdsa.PrivateKey

func (*Wallet) GetReadableBalance

func (wallet *Wallet) GetReadableBalance(unitDigits, maxPreCommaDigitsBeforeTrim, digits int, addPositiveSign, trimAmount bool) string

func (*Wallet) GetSummary

func (wallet *Wallet) GetSummary() *Summary

func (*Wallet) ResyncState

func (wallet *Wallet) ResyncState()

func (*Wallet) SendTransaction

func (wallet *Wallet) SendTransaction(ctx context.Context, tx *types.Transaction, options *SendTransactionOptions) error

func (*Wallet) UseNextNonce

func (wallet *Wallet) UseNextNonce(increase bool) uint64

type WalletPool

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

func (*WalletPool) EnsureFunding

func (pool *WalletPool) EnsureFunding(ctx context.Context, minBalance, refillAmount, gasFeeCap, gasTipCap *big.Int, pendingLimit uint64) error

func (*WalletPool) GetChildWallet

func (pool *WalletPool) GetChildWallet(index uint64) *Wallet

func (*WalletPool) GetChildWallets

func (pool *WalletPool) GetChildWallets() []*Wallet

func (*WalletPool) GetNextChildWallet

func (pool *WalletPool) GetNextChildWallet() *Wallet

func (*WalletPool) GetRootWallet

func (pool *WalletPool) GetRootWallet() *Wallet