Feat/Introduce the TxPool load tool

pkg/coordinator/tasks/tasks.go

@@ -38,10 +38,10 @@ import (
 	runtaskoptions "github.com/noku-team/assertoor/pkg/coordinator/tasks/run_task_options"
 	runtasks "github.com/noku-team/assertoor/pkg/coordinator/tasks/run_tasks"
 	runtasksconcurrent "github.com/noku-team/assertoor/pkg/coordinator/tasks/run_tasks_concurrent"
-	txpoollatencyanalysis "github.com/noku-team/assertoor/pkg/coordinator/tasks/tx_pool_latency_analysis"
-	txpoolthroughputanalysis "github.com/noku-team/assertoor/pkg/coordinator/tasks/tx_pool_throughput_analysis"
-	txpoolclean "github.com/noku-team/assertoor/pkg/coordinator/tasks/tx_pool_clean"
 	sleep "github.com/noku-team/assertoor/pkg/coordinator/tasks/sleep"
+	txpoolclean "github.com/noku-team/assertoor/pkg/coordinator/tasks/tx_pool_clean"
+	txpoolthroughputanalysis "github.com/noku-team/assertoor/pkg/coordinator/tasks/tx_pool_throughput_analysis"
+	txpoollatencyanalysis "github.com/noku-team/assertoor/pkg/coordinator/tasks/tx_pool_latency_analysis"
 )
 
 var AvailableTaskDescriptors = []*types.TaskDescriptor{

pkg/coordinator/tasks/tx_pool_latency_analysis/README.md

@@ -15,7 +15,7 @@ The `tx_pool_latency_analysis` task evaluates latency of transaction processing
 - **`duration_s`**:
   The test duration (the number of transactions to send is calculated as `tps * duration_s`).
 
-- **`measureInterval`**:
+- **`logInterval`**:
   The interval at which the script logs progress (e.g., every 100 transactions).
 
 ### Outputs
@@ -37,9 +37,9 @@ The `tx_pool_latency_analysis` task evaluates latency of transaction processing
 ```yaml
 - name: tx_pool_latency_analysis
   config:
-    tps: 100
+    tps: 1000
     duration_s: 10  
-    measureInterval: 1000
+    logInterval: 1000
   configVars:
     privateKey: "walletPrivkey"
 ```

pkg/coordinator/tasks/tx_pool_latency_analysis/config.go

@@ -1,19 +1,19 @@
-package txpoollatencyanalysis
+package txpool_latency_analysis
 
 type Config struct {
 	PrivateKey string `yaml:"privateKey" json:"privateKey"`
 
 	TPS                  int   `yaml:"tps" json:"tps"`
 	Duration_s           int   `yaml:"duration_s" json:"duration_s"`
-	MeasureInterval      int   `yaml:"measureInterval" json:"measureInterval"`
+	LogInterval          int   `yaml:"logInterval" json:"logInterval"`
 	SecondsBeforeRunning int64 `yaml:"secondsBeforeRunning" json:"secondsBeforeRunning"`
 }
 
 func DefaultConfig() Config {
 	return Config{
 		TPS:                  100,
 		Duration_s:           60,
-		MeasureInterval:      100,
+		LogInterval:          100,
 		SecondsBeforeRunning: 0,
 	}
 }