From 5e55d67716d582a825aa07e4540887979a4420db Mon Sep 17 00:00:00 2001 From: Will Hawkins Date: Sun, 20 Nov 2022 02:36:24 -0500 Subject: [Feature] Collect the number of open connections in throughput data point Include the number of open connections in a throughput data point. --- rpm/rpm.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/rpm/rpm.go b/rpm/rpm.go index dfc48a3..9a92f9f 100644 --- a/rpm/rpm.go +++ b/rpm/rpm.go @@ -68,8 +68,9 @@ type ProbeDataPoint struct { } type ThroughputDataPoint struct { - Time time.Time `Description:"Time of the generation of the data point." Formatter:"Format" FormatterArgument:"01-02-2006-15-04-05.000"` - Throughput float64 `Description:"Instantaneous throughput (b/s)."` + Time time.Time `Description:"Time of the generation of the data point." Formatter:"Format" FormatterArgument:"01-02-2006-15-04-05.000"` + Throughput float64 `Description:"Instantaneous throughput (b/s)."` + Connections int `Description: Number of parallel connections."` } type SelfDataCollectionResult struct { @@ -427,7 +428,7 @@ func LoadGenerator( } // We have generated a throughput calculation -- let's send it back to the coordinator - throughputDataPoint := ThroughputDataPoint{time.Now(), instantaneousTotalThroughput} + throughputDataPoint := ThroughputDataPoint{time.Now(), instantaneousTotalThroughput, len(*loadGeneratingConnections.LGCs)} throughputCalculations <- throughputDataPoint // Log that, if we are configured for logging. -- cgit v1.2.3