Minor fixes

Author: niksajakovljevic

main.go

@@ -93,8 +93,8 @@ var (
 		},
 		[]string{"path"},
 	)
-	writeThroughtput = util.NewThroughputCalc(tickInterval)
-	election         util.Election
+	writeThroughput = util.NewThroughputCalc(tickInterval)
+	election        util.Election
 )
 
 func init() {
@@ -103,7 +103,7 @@ func init() {
 	prometheus.MustRegister(failedSamples)
 	prometheus.MustRegister(sentBatchDuration)
 	prometheus.MustRegister(httpRequestDuration)
-	writeThroughtput.Start()
+	writeThroughput.Start()
 }
 
 func main() {
@@ -241,10 +241,10 @@ func write(writer writer) http.Handler {
 		if err != nil {
 			log.Warn("msg", "Couldn't get a counter", "labelValue", writer.Name(), "err", err)
 		}
-		writeThroughtput.SetCurrent(getCounterValue(counter))
+		writeThroughput.SetCurrent(getCounterValue(counter))
 
 		select {
-		case d := <-writeThroughtput.Values:
+		case d := <-writeThroughput.Values:
 			log.Info("msg", "Samples write throughput", "samples/sec", d)
 		default:
 		}

util/lock.go

@@ -94,7 +94,7 @@ func (l *PgAdvisoryLock) TryLock() (bool, error) {
 	}
 	defer rows.Close()
 	if !rows.Next() {
-		return false, fmt.Errorf("error while trying to read reponse rows from `pg_try_advisory_lock` function")
+		return false, fmt.Errorf("error while trying to read response rows from `pg_try_advisory_lock` function")
 	}
 	var success bool
 	if err := rows.Scan(&success); err != nil {

util/util.go

@@ -8,8 +8,8 @@ import (
 	"github.com/timescale/prometheus-postgresql-adapter/log"
 )
 
-//ThroughtputCalc runs on scheduled interval to calculate the throughput per second and sends results to a channel
-type ThroughtputCalc struct {
+//ThroughputCalc runs on scheduled interval to calculate the throughput per second and sends results to a channel
+type ThroughputCalc struct {
 	tickInterval time.Duration
 	previous     float64
 	current      chan float64
@@ -18,18 +18,18 @@ type ThroughtputCalc struct {
 	lock         sync.Mutex
 }
 
-func NewThroughputCalc(interval time.Duration) *ThroughtputCalc {
-	return &ThroughtputCalc{tickInterval: interval, current: make(chan float64, 1), Values: make(chan float64, 1)}
+func NewThroughputCalc(interval time.Duration) *ThroughputCalc {
+	return &ThroughputCalc{tickInterval: interval, current: make(chan float64, 1), Values: make(chan float64, 1)}
 }
 
-func (dt *ThroughtputCalc) SetCurrent(value float64) {
+func (dt *ThroughputCalc) SetCurrent(value float64) {
 	select {
 	case dt.current <- value:
 	default:
 	}
 }
 
-func (dt *ThroughtputCalc) Start() {
+func (dt *ThroughputCalc) Start() {
 	dt.lock.Lock()
 	defer dt.lock.Unlock()
 	if !dt.running {