Minor change in the QueryServer constructor

cmd/pqlogd/main.go

@@ -59,7 +59,7 @@ func main() {
 	}
 
 	if *enableQuery {
-		qsrv, err := pqhttp.NewQuery(*storageDir)
+		qsrv, err := pqhttp.NewQuery(filepath.Join(*storageDir, "logs.*.pq"))
 		if err != nil {
 			log.Fatal(err)
 		}

http/query.go

@@ -11,7 +11,6 @@ import (
 	"log"
 	"math/rand"
 	"net/http"
-	"path/filepath"
 	"reflect"
 	"strings"
 
@@ -31,13 +30,13 @@ type QueryServer struct {
 	db   *sql.DB
 }
 
-func NewQuery(path string) (*QueryServer, error) {
+func NewQuery(pattern string) (*QueryServer, error) {
 	db, err := sql.Open("duckdb", "")
 	if err != nil {
 		return nil, err
 	}
 	return &QueryServer{
-		glob: filepath.Join(path, "*.pq"),
+		glob: pattern,
 		db:   db,
 	}, nil
 }