Merge pull request #53 from aykhans/feat/add-metrics

Add latency percentiles to the results table

config/config.go

@@ -6,6 +6,7 @@ import (
 	"os"
 	"time"
 
+	. "github.com/aykhans/dodo/types"
 	"github.com/aykhans/dodo/utils"
 	"github.com/jedib0t/go-pretty/v6/table"
 )
@@ -97,7 +98,7 @@ type Config struct {
 	Timeout      uint32       `json:"timeout" validate:"gte=1,lte=100000"`
 	DodosCount   uint         `json:"dodos_count" validate:"gte=1"`
 	RequestCount uint         `json:"request_count" validation_name:"request-count" validate:"gte=1"`
-	NoProxyCheck utils.Option[bool] `json:"no_proxy_check"`
+	NoProxyCheck Option[bool] `json:"no_proxy_check"`
 }
 
 func NewConfig(
@@ -105,10 +106,10 @@ func NewConfig(
 	timeout uint32,
 	dodosCount uint,
 	requestCount uint,
-	noProxyCheck utils.Option[bool],
+	noProxyCheck Option[bool],
 ) *Config {
 	if noProxyCheck == nil {
-		noProxyCheck = utils.NewNoneOption[bool]()
+		noProxyCheck = NewNoneOption[bool]()
 	}
 
 	return &Config{
@@ -155,7 +156,7 @@ func (config *Config) SetDefaults() {
 		config.RequestCount = DefaultRequestCount
 	}
 	if config.NoProxyCheck.IsNone() {
-		config.NoProxyCheck = utils.NewOption(false)
+		config.NoProxyCheck = NewOption(false)
 	}
 }
 

readers/cli.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/aykhans/dodo/config"
 	"github.com/aykhans/dodo/custom_errors"
+	. "github.com/aykhans/dodo/types"
 	"github.com/aykhans/dodo/utils"
 	"github.com/spf13/cobra"
 	"github.com/spf13/pflag"
@@ -61,7 +62,7 @@ func CLIConfigReader() (*config.CLIConfig, error) {
 		case "timeout":
 			cliConfig.Timeout = timeout
 		case "no-proxy-check":
-			cliConfig.NoProxyCheck = utils.NewOption(noProxyCheck)
+			cliConfig.NoProxyCheck = NewOption(noProxyCheck)
 		}
 	})
 	if returnNil {

requests/response.go

@@ -5,7 +5,7 @@ import (
 	"os"
 	"time"
 
-	"github.com/aykhans/dodo/utils"
+	. "github.com/aykhans/dodo/types"
 	"github.com/jedib0t/go-pretty/v6/table"
 )
 
@@ -18,24 +18,32 @@ type Response struct {
 type Responses []*Response
 
 // Print prints the responses in a tabular format, including information such as
-// response count, minimum time, maximum time, and average time.
+// response count, minimum time, maximum time, average time, and latency percentiles.
 func (respones Responses) Print() {
-	var (
+	total := struct {
-		totalMinDuration time.Duration = respones[0].Time
+		Count int
-		totalMaxDuration time.Duration = respones[0].Time
+		Min   time.Duration
-		totalDuration    time.Duration
+		Max   time.Duration
-		totalCount       int = len(respones)
+		Sum   time.Duration
-	)
+		P90   time.Duration
-	mergedResponses := make(map[string][]time.Duration)
+		P95   time.Duration
+		P99   time.Duration
+	}{
+		Count: len(respones),
+		Min:   respones[0].Time,
+		Max:   respones[0].Time,
+	}
+	mergedResponses := make(map[string]Durations)
+	var allDurations Durations
 
 	for _, response := range respones {
-		if response.Time < totalMinDuration {
+		if response.Time < total.Min {
-			totalMinDuration = response.Time
+			total.Min = response.Time
 		}
-		if response.Time > totalMaxDuration {
+		if response.Time > total.Max {
-			totalMaxDuration = response.Time
+			total.Max = response.Time
 		}
-		totalDuration += response.Time
+		total.Sum += response.Time
 
 		if response.Error != nil {
 			mergedResponses[response.Error.Error()] = append(
@@ -48,38 +56,60 @@ func (respones Responses) Print() {
 				response.Time,
 			)
 		}
+		allDurations = append(allDurations, response.Time)
 	}
+	allDurations.Sort()
+	allDurationsLenAsFloat := float64(len(allDurations) - 1)
+	total.P90 = allDurations[int(0.90*allDurationsLenAsFloat)]
+	total.P95 = allDurations[int(0.95*allDurationsLenAsFloat)]
+	total.P99 = allDurations[int(0.99*allDurationsLenAsFloat)]
 
 	t := table.NewWriter()
 	t.SetOutputMirror(os.Stdout)
 	t.SetStyle(table.StyleLight)
 	t.SetColumnConfigs([]table.ColumnConfig{
-		{Number: 1, WidthMax: 80},
+		{Number: 1, WidthMax: 40},
 	})
-
 	t.AppendHeader(table.Row{
 		"Response",
 		"Count",
 		"Min Time",
 		"Max Time",
 		"Average Time",
+		"P90",
+		"P95",
+		"P99",
 	})
+
 	for key, durations := range mergedResponses {
+		durations.Sort()
+		durationsLen := len(durations)
+		durationsLenAsFloat := float64(durationsLen - 1)
+
 		t.AppendRow(table.Row{
 			key,
-			len(durations),
+			durationsLen,
-			utils.MinDuration(durations...),
+			durations.First(),
-			utils.MaxDuration(durations...),
+			durations.Last(),
-			utils.AvgDuration(durations...),
+			durations.Avg(),
+			durations[int(0.90*durationsLenAsFloat)],
+			durations[int(0.95*durationsLenAsFloat)],
+			durations[int(0.99*durationsLenAsFloat)],
 		})
 		t.AppendSeparator()
 	}
+
+	if len(mergedResponses) > 1 {
 		t.AppendRow(table.Row{
 			"Total",
-		totalCount,
+			total.Count,
-		totalMinDuration,
+			total.Min,
-		totalMaxDuration,
+			total.Max,
-		totalDuration / time.Duration(totalCount),
+			total.Sum / time.Duration(total.Count), // Average
+			total.P90,
+			total.P95,
+			total.P99,
 		})
+	}
 	t.Render()
 }

types/durations.go

@@ -0,0 +1,41 @@
+package types
+
+import (
+	"sort"
+	"time"
+)
+
+type Durations []time.Duration
+
+func (d Durations) Sort(ascending ...bool) {
+	// If ascending is provided and is false, sort in descending order
+	if len(ascending) > 0 && ascending[0] == false {
+		sort.Slice(d, func(i, j int) bool {
+			return d[i] > d[j]
+		})
+	} else { // Otherwise, sort in ascending order
+		sort.Slice(d, func(i, j int) bool {
+			return d[i] < d[j]
+		})
+	}
+}
+
+func (d Durations) First() *time.Duration {
+	return &d[0]
+}
+
+func (d Durations) Last() *time.Duration {
+	return &d[len(d)-1]
+}
+
+func (d Durations) Sum() time.Duration {
+	sum := time.Duration(0)
+	for _, duration := range d {
+		sum += duration
+	}
+	return sum
+}
+
+func (d Durations) Avg() time.Duration {
+	return d.Sum() / time.Duration(len(d))
+}

types/option.go

@@ -1,4 +1,4 @@
-package utils
+package types
 
 import (
 	"encoding/json"

utils/time.go

@@ -1,31 +0,0 @@
-package utils
-
-import "time"
-
-func MinDuration(durations ...time.Duration) time.Duration {
-	min := durations[0]
-	for _, d := range durations {
-		if d < min {
-			min = d
-		}
-	}
-	return min
-}
-
-func MaxDuration(durations ...time.Duration) time.Duration {
-	max := durations[0]
-	for _, d := range durations {
-		if d > max {
-			max = d
-		}
-	}
-	return max
-}
-
-func AvgDuration(durations ...time.Duration) time.Duration {
-	total := time.Duration(0)
-	for _, d := range durations {
-		total += d
-	}
-	return total / time.Duration(len(durations))
-}