Merge branch 'feat/txpool-latency-qps' of https://github.com/noku-team/assertoor into feat/txpool-latency-qps

Author: tosettil-polimi

pkg/coordinator/tasks/tx_pool_latency_analysis/README.md

@@ -23,6 +23,9 @@ The `tx_pool_latency_analysis` task evaluates latency of transaction processing
 - **`tx_count`**:
   The total number of transactions sent.
 
+- **`min_latency_mus`**:
+  The min latency of the transactions in microseconds.
+
 - **`max_latency_mus`**:
   The max latency of the transactions in microseconds.
 

pkg/coordinator/tasks/tx_pool_throughput_analysis/README.md

@@ -23,8 +23,8 @@ The `tx_pool_throughput_analysis` task evaluates the throughput of transaction p
 - **`tx_count`**:
   The total number of transactions sent.
 
-- **`max_latency_mus`**:
-  The max latency of the transactions in microseconds.
+- **`mean_tps_throughput`**:
+  The mean throughput (tps)
 
 ### Defaults
 

pkg/coordinator/tasks/tx_pool_throughput_analysis/task.go

@@ -280,16 +280,16 @@ func (t *Task) Execute(ctx context.Context) error {
 	// Calculate statistics
 	processed_tx_per_second := float64(sentTxCount) / lastMeasureTime.Seconds()
 
-	t.ctx.Outputs.SetVar("mean_throughput", processed_tx_per_second)
+	t.ctx.Outputs.SetVar("mean_tps_throughput", processed_tx_per_second)
 	t.logger.Infof("Processed %d transactions in %.2fs, mean throughput: %.2f tx/s", sentTxCount, lastMeasureTime.Seconds(), processed_tx_per_second)
 	t.ctx.Outputs.SetVar("tx_count", totNumberOfTxes)
 	t.logger.Infof("Sent %d transactions in %.2fs", sentTxCount, lastMeasureTime.Seconds())
 
 	t.ctx.SetResult(types.TaskResultSuccess)
 
 	outputs := map[string]interface{}{
-		"tx_count":        totNumberOfTxes,
-		"mean_throughput": processed_tx_per_second,
+		"tx_count":            totNumberOfTxes,
+		"mean_tps_throughput": processed_tx_per_second,
 	}
 
 	outputsJSON, _ := json.Marshal(outputs)