load

package

v0.0.0-...-9e22ca1 Latest Latest Go to latest Published: Dec 10, 2023 License: GPL-3.0, LGPL-3.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bilgin-kocak/subnet-evm

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DistributeFunds(ctx context.Context, client ethclient.Client, keys []*key.Key, numKeys int, ...) ([]*key.Key, error)
func ExecuteLoader(ctx context.Context, config config.Config) error
func NewSingleAddressTxWorker(ctx context.Context, client ethclient.Client, address common.Address) *ethereumTxWorker
func NewTxReceiptWorker(ctx context.Context, client ethclient.Client) *ethereumTxWorker
type Loader
- func New[T txs.THash](clients []txs.Worker[T], txSequences []txs.TxSequence[T], batchSize uint64, ...) *Loader[T]
- func (l *Loader[T]) ConfirmReachedTip(ctx context.Context) error
- func (l *Loader[T]) Execute(ctx context.Context) error

Constants ¶

View Source

const (
	MetricsEndpoint = "/metrics" // Endpoint for the Prometheus Metrics Server
)

Variables ¶

This section is empty.

Functions ¶

func DistributeFunds ¶

func DistributeFunds(ctx context.Context, client ethclient.Client, keys []*key.Key, numKeys int, minFundsPerAddr *big.Int, m *metrics.Metrics) ([]*key.Key, error)

DistributeFunds ensures that each address in keys has at least [minFundsPerAddr] by sending funds from the key with the highest starting balance. This function returns a set of at least [numKeys] keys, each having a minimum balance [minFundsPerAddr].

func ExecuteLoader ¶

func ExecuteLoader(ctx context.Context, config config.Config) error

ExecuteLoader creates txSequences from config and has txAgents execute the specified simulation.

func NewSingleAddressTxWorker ¶

func NewSingleAddressTxWorker(ctx context.Context, client ethclient.Client, address common.Address) *ethereumTxWorker

NewSingleAddressTxWorker creates and returns a new ethereumTxWorker that confirms transactions by checking the latest nonce of [address] and assuming any transaction with a lower nonce was already accepted.

func NewTxReceiptWorker ¶

func NewTxReceiptWorker(ctx context.Context, client ethclient.Client) *ethereumTxWorker

NewTxReceiptWorker creates and returns a new ethereumTxWorker that confirms transactions by checking for the corresponding transaction receipt.

Types ¶

type Loader ¶

type Loader[T txs.THash] struct {
	// contains filtered or unexported fields
}

Loader executes a series of worker/tx sequence pairs. Each worker/txSequence pair issues [batchSize] transactions, confirms all of them as accepted, and then moves to the next batch until the txSequence is exhausted.

func New ¶

func New[T txs.THash](
	clients []txs.Worker[T],
	txSequences []txs.TxSequence[T],
	batchSize uint64,
	metrics *metrics.Metrics,
) *Loader[T]

func (*Loader[T]) ConfirmReachedTip ¶

func (l *Loader[T]) ConfirmReachedTip(ctx context.Context) error

ConfirmReachedTip finds the max height any client has reached and then ensures every client reaches at least that height.

This allows the network to continue to roll forward and creates a synchronization point to ensure that every client in the loader has reached at least the max height observed of any client at the time this function was called.

func (*Loader[T]) Execute ¶

func (l *Loader[T]) Execute(ctx context.Context) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL