Merge branch 'main' of github.com:fabricekabongo/loggerhead

Author: fabricekabongo

admin/ops.go

@@ -3,13 +3,14 @@ package admin
 import (
 	"embed"
 	"encoding/json"
-	"github.com/fabricekabongo/loggerhead/clustering"
-	"github.com/fabricekabongo/loggerhead/config"
-	"github.com/prometheus/client_golang/prometheus/promhttp"
 	"html/template"
 	"log"
 	"net/http"
 	"runtime"
+
+	"github.com/fabricekabongo/loggerhead/clustering"
+	"github.com/fabricekabongo/loggerhead/config"
+	"github.com/prometheus/client_golang/prometheus/promhttp"
 )
 
 var (
@@ -128,8 +129,8 @@ func (o *OpsServer) AdminData() http.Handler {
 	})
 }
 
-func (o *OpsServer) AdminUI() http.Handler {
-	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+func (*OpsServer) AdminUI() http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
 		err := TMPL.Execute(w, nil)
 		if err != nil {
 			http.Error(w, err.Error(), http.StatusInternalServerError)

clustering/broadcast-delegate.go

@@ -1,13 +1,14 @@
 package clustering
 
 import (
+	"log"
+	"os"
+
 	"github.com/fabricekabongo/loggerhead/query"
 	"github.com/fabricekabongo/loggerhead/world"
 	"github.com/hashicorp/memberlist"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
-	"log"
-	"os"
 )
 
 var (
@@ -52,7 +53,7 @@ func newBroadcastDelegate(engine *query.Engine, broadcasts *memberlist.TransmitL
 	}
 }
 
-func (d *BroadcastDelegate) NodeMeta(limit int) []byte {
+func (*BroadcastDelegate) NodeMeta(_ int) []byte {
 	return []byte{}
 }
 

query/query.go

@@ -206,7 +206,7 @@ func (p *GetQueryProcessor) Execute(query string) string {
 	return stringBuilder.String()
 }
 
-func (p *GetQueryProcessor) CanProcess(query string) bool {
+func (*GetQueryProcessor) CanProcess(query string) bool {
 	chunks := strings.Split(query, " ")
 	if len(chunks) != 3 {
 		return false
@@ -249,7 +249,7 @@ func (p *DeleteQueryProcessor) Execute(query string) string {
 	return version + ",deleted\n"
 }
 
-func (p *DeleteQueryProcessor) CanProcess(query string) bool {
+func (*DeleteQueryProcessor) CanProcess(query string) bool {
 	chunks := strings.Split(query, " ")
 	if len(chunks) != 3 {
 		return false
@@ -306,7 +306,7 @@ func (p *SaveQueryProcessor) Execute(query string) string {
 	return version + ",saved\n"
 }
 
-func (p *SaveQueryProcessor) CanProcess(query string) bool {
+func (*SaveQueryProcessor) CanProcess(query string) bool {
 	chunks := strings.Split(query, " ")
 	if len(chunks) != 5 {
 		return false
@@ -371,7 +371,7 @@ func (p *PolyQueryProcessor) Execute(query string) string {
 	return result.String()
 }
 
-func (p *PolyQueryProcessor) CanProcess(query string) bool {
+func (*PolyQueryProcessor) CanProcess(query string) bool {
 	chunks := strings.Split(query, " ")
 	if len(chunks) != 6 {
 		return false

world/location.go

@@ -4,9 +4,10 @@ import (
 	"encoding/gob"
 	"errors"
 	"fmt"
+	"time"
+
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
-	"time"
 )
 
 var (
@@ -58,7 +59,7 @@ func NewLocation(ns string, id string, lat float64, lon float64) (*Location, err
 	return loc, nil
 }
 
-func (l *Location) init(ns string, id string, lat float64, lon float64) (*Location, error) {
+func (*Location) init(ns string, id string, lat float64, lon float64) (*Location, error) {
 	if len(id) == 0 {
 		validationOps.Inc()
 		return nil, LocationErrorRequiredId

world/tree.go

@@ -2,10 +2,11 @@ package world
 
 import (
 	"errors"
-	"github.com/prometheus/client_golang/prometheus"
-	"github.com/prometheus/client_golang/prometheus/promauto"
 	"math"
 	"sync"
+
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promauto"
 )
 
 var (
@@ -155,7 +156,7 @@ func (node *TreeNode) divide() {
 	node.mu.Unlock()
 }
 
-func (q *QuadTree) reBalance() {
+func (*QuadTree) reBalance() {
 	// TODO: Implement rebalancing
 }