From 30482aaf35d3f9c1e6261ca186e1e4a1ccdb59fa Mon Sep 17 00:00:00 2001
From: ale <ale@incal.net>
Date: Fri, 29 Dec 2023 21:09:12 +0000
Subject: [PATCH] Minor change in the QueryServer constructor
---
cmd/pqlogd/main.go | 2 +-
http/query.go | 5 ++---
2 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/cmd/pqlogd/main.go b/cmd/pqlogd/main.go
index 3d0efde..fd46c89 100644
--- a/cmd/pqlogd/main.go
+++ b/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)
}
diff --git a/http/query.go b/http/query.go
index 5551336..e6f1e7e 100644
--- a/http/query.go
+++ b/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
}
--
GitLab