-
Notifications
You must be signed in to change notification settings - Fork 222
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* Refactor load simulator * Cleanup * simulator: support http as well as websocket endpoints * simulator: move help err handling * simulator: Fix distribute funds bug * simulator: add metrics at the end of simulator run * Support no timeout * Address review comments * Remove unused struct * Update cmd/simulator/config/flags.go * Update cmd/simulator/load/funder.go * Remove . from simulator flags * Add comment to scripts/run_simulator.sh * Address PR comments
- Loading branch information
1 parent
e6bf2a0
commit 9895149
Showing
19 changed files
with
704 additions
and
958 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -46,6 +46,7 @@ bin/ | |
| build/ | ||
|
|
||
| cmd/simulator/.simulator/* | ||
| cmd/simulator/simulator | ||
|
|
||
| # goreleaser | ||
| dist/ | ||
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,117 @@ | ||
| // (c) 2023, Ava Labs, Inc. All rights reserved. | ||
| // See the file LICENSE for licensing terms. | ||
|
|
||
| package config | ||
|
|
||
| import ( | ||
| "errors" | ||
| "fmt" | ||
| "strings" | ||
| "time" | ||
|
|
||
| "github.com/spf13/pflag" | ||
| "github.com/spf13/viper" | ||
| ) | ||
|
|
||
| const Version = "v0.1.0" | ||
|
|
||
| const ( | ||
| ConfigFilePathKey = "config-file" | ||
| LogLevelKey = "log-level" | ||
| EndpointsKey = "endpoints" | ||
| MaxFeeCapKey = "max-fee-cap" | ||
| MaxTipCapKey = "max-tip-cap" | ||
| WorkersKey = "workers" | ||
| TxsPerWorkerKey = "txs-per-worker" | ||
| KeyDirKey = "key-dir" | ||
| VersionKey = "version" | ||
| TimeoutKey = "timeout" | ||
| ) | ||
|
|
||
| var ( | ||
| ErrNoEndpoints = errors.New("must specify at least one endpoint") | ||
| ErrNoWorkers = errors.New("must specify non-zero number of workers") | ||
| ErrNoTxs = errors.New("must specify non-zero number of txs-per-worker") | ||
| ) | ||
|
|
||
| type Config struct { | ||
| Endpoints []string `json:"endpoints"` | ||
| MaxFeeCap int64 `json:"max-fee-cap"` | ||
| MaxTipCap int64 `json:"max-tip-cap"` | ||
| Workers int `json:"workers"` | ||
| TxsPerWorker uint64 `json:"txs-per-worker"` | ||
| KeyDir string `json:"key-dir"` | ||
| Timeout time.Duration `json:"timeout"` | ||
| } | ||
|
|
||
| func BuildConfig(v *viper.Viper) (Config, error) { | ||
| c := Config{ | ||
| Endpoints: v.GetStringSlice(EndpointsKey), | ||
| MaxFeeCap: v.GetInt64(MaxFeeCapKey), | ||
| MaxTipCap: v.GetInt64(MaxTipCapKey), | ||
| Workers: v.GetInt(WorkersKey), | ||
| TxsPerWorker: v.GetUint64(TxsPerWorkerKey), | ||
| KeyDir: v.GetString(KeyDirKey), | ||
| Timeout: v.GetDuration(TimeoutKey), | ||
| } | ||
| if len(c.Endpoints) == 0 { | ||
| return c, ErrNoEndpoints | ||
| } | ||
| if c.Workers == 0 { | ||
| return c, ErrNoWorkers | ||
| } | ||
| if c.TxsPerWorker == 0 { | ||
| return c, ErrNoTxs | ||
| } | ||
| // Note: it's technically valid for the fee/tip cap to be 0, but cannot | ||
| // be less than 0. | ||
| if c.MaxFeeCap < 0 { | ||
| return c, fmt.Errorf("invalid max fee cap %d < 0", c.MaxFeeCap) | ||
| } | ||
| if c.MaxTipCap < 0 { | ||
| return c, fmt.Errorf("invalid max tip cap %d <= 0", c.MaxTipCap) | ||
| } | ||
| return c, nil | ||
| } | ||
|
|
||
| func BuildViper(fs *pflag.FlagSet, args []string) (*viper.Viper, error) { | ||
| if err := fs.Parse(args); err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| v := viper.New() | ||
| v.AutomaticEnv() | ||
| v.SetEnvKeyReplacer(strings.NewReplacer("-", "_")) | ||
| v.SetEnvPrefix("evm_simulator") | ||
| if err := v.BindPFlags(fs); err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| if v.IsSet(ConfigFilePathKey) { | ||
| v.SetConfigFile(v.GetString(ConfigFilePathKey)) | ||
| if err := v.ReadInConfig(); err != nil { | ||
| return nil, err | ||
| } | ||
| } | ||
| return v, nil | ||
| } | ||
|
|
||
| // BuildFlagSet returns a complete set of flags for simulator | ||
| func BuildFlagSet() *pflag.FlagSet { | ||
| fs := pflag.NewFlagSet("simulator", pflag.ContinueOnError) | ||
| addSimulatorFlags(fs) | ||
| return fs | ||
| } | ||
|
|
||
| func addSimulatorFlags(fs *pflag.FlagSet) { | ||
| fs.Bool(VersionKey, false, "Print the version and exit") | ||
| fs.String(ConfigFilePathKey, "", "Specify the config path to use to load a YAML config for the simulator") | ||
| fs.StringSlice(EndpointsKey, []string{"ws://127.0.0.1:9650/ext/bc/C/ws"}, "Specify a comma separated list of RPC Websocket Endpoints (minimum of 1 endpoint)") | ||
| fs.Int64(MaxFeeCapKey, 50, "Specify the maximum fee cap to use for transactions denominated in GWei (must be > 0)") | ||
| fs.Int64(MaxTipCapKey, 1, "Specify the max tip cap for transactions denominated in GWei (must be >= 0)") | ||
| fs.Uint64(TxsPerWorkerKey, 100, "Specify the number of transactions to create per worker (must be > 0)") | ||
| fs.Int(WorkersKey, 1, "Specify the number of workers to create for the simulator (must be > 0)") | ||
| fs.String(KeyDirKey, ".simulator/keys", "Specify the directory to save private keys in (INSECURE: only use for testing)") | ||
| fs.Duration(TimeoutKey, 5*time.Minute, "Specify the timeout for the simulator to complete (0 indicates no timeout)") | ||
| fs.String(LogLevelKey, "info", "Specify the log level to use in the simulator") | ||
| } |
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.