Feat/Introduce the TxPool load tool (#8)

* code from branch feat/txpool-refactoring

* Refactor transaction message reading to include a timeout parameter and enhance error handling for timeout scenarios in the MeasurePropagationLatencies function.

* Update task descriptors to include tx_pool_latency_analysis and replace tx_poolthroughputanalysis with tx_pool_latency_analysis for improved task management.

* Refactor tx_pool_latency_analysis and tx_pool_throughput_analysis to replace 'measureInterval' with 'logInterval' for consistency. Update related documentation and configuration files to reflect this change, and adjust TPS values in playbooks for improved testing scenarios.

* Fix timeout handling in MeasurePropagationLatencies function by breaking the loop on timeoutExpired error instead of returning the result. This improves error handling during p2p event reading.

---------

Co-authored-by: tosettil-polimi <info@tosettil.me>

Author: mriccobene

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,
 	}
 }