Change statement names

Author: C

postgresql/stats.go

@@ -2,36 +2,52 @@ package postgresql
 
 import (
 	"github.com/lib/pq"
-
-	"github.com/benchttp/worker/stats"
 )
 
+type Common struct {
+	Min    float64
+	Max    float64
+	Mean   float64
+	Median float64
+	StdDev float64
+
+	Deciles [9]float64
+}
+
+type StatusDistribution struct {
+	Status1xx int
+	Status2xx int
+	Status3xx int
+	Status4xx int
+	Status5xx int
+}
+
 // nolint:gocognit
-func (s StatsService) Create(statsToStore stats.Stats, statsID, userID, tag string) error {
+func (s StatsService) Create(statsToStore Common, statusToStore StatusDistribution, statsID, userID, tag string) error {
 	tx, err := s.db.Begin()
 	if err != nil {
 		return err
 	}
 
-	insertIntoStatsDescriptor, err := tx.Prepare(`INSERT INTO public.stats_descriptor(id, user_id, tag, finished_at) VALUES($1, $2, $3, '2022-03-03 17:36:38-02')`)
+	insertStatsDescriptor, err := tx.Prepare(`INSERT INTO public.stats_descriptor(id, user_id, tag, finished_at) VALUES($1, $2, $3, '2022-03-03 17:36:38-02')`)
 	if err != nil {
 		err = tx.Rollback()
 		if err != nil {
 			return ErrExecutingRollback
 		}
 		return ErrPreparingStmt
 	}
-	defer insertIntoStatsDescriptor.Close()
+	defer insertStatsDescriptor.Close()
 
-	if _, err = insertIntoStatsDescriptor.Exec(statsID, userID, tag); err != nil {
+	if _, err = insertStatsDescriptor.Exec(statsID, userID, tag); err != nil {
 		err = tx.Rollback()
 		if err != nil {
 			return ErrExecutingRollback
 		}
 		return ErrExecutingPreparedStmt
 	}
 
-	insertIntoTimestats, err := tx.Prepare(`INSERT INTO public.timestats(stats_descriptor_id, min, max, mean, median, standard_deviation, deciles) VALUES
+	insertTimestats, err := tx.Prepare(`INSERT INTO public.timestats(stats_descriptor_id, min, max, mean, median, standard_deviation, deciles) VALUES
 	($1, $2, $3, $4, $5, $6, $7)`)
 	if err != nil {
 		err = tx.Rollback()
@@ -40,9 +56,9 @@ func (s StatsService) Create(statsToStore stats.Stats, statsID, userID, tag stri
 		}
 		return ErrPreparingStmt
 	}
-	defer insertIntoTimestats.Close()
+	defer insertTimestats.Close()
 
-	if _, err = insertIntoTimestats.Exec(statsID, statsToStore.Min, statsToStore.Max, statsToStore.Mean, statsToStore.Median, statsToStore.StdDev, pq.Array(statsToStore.Deciles)); err != nil {
+	if _, err = insertTimestats.Exec(statsID, statsToStore.Min, statsToStore.Max, statsToStore.Mean, statsToStore.Median, statsToStore.StdDev, pq.Array(statsToStore.Deciles)); err != nil {
 		err = tx.Rollback()
 		if err != nil {
 			return ErrExecutingRollback