summaryrefslogtreecommitdiff
path: root/internal/cache
diff options
context:
space:
mode:
authorradhitya <alif@radhitya.org>2026-06-14 17:17:56 +0700
committerradhitya <alif@radhitya.org>2026-06-14 17:17:56 +0700
commitd173554892339e5211020c60d6af610840eef7ed (patch)
tree295ce37851532e6180b47c63ed34146a01adc12c /internal/cache
parent4e6a897a0b55ee533c05f89fa38dbe0704f2798d (diff)
config, rebranding, fix cache
Diffstat (limited to 'internal/cache')
-rw-r--r--internal/cache/cache.go9
1 files changed, 8 insertions, 1 deletions
diff --git a/internal/cache/cache.go b/internal/cache/cache.go
index a2d86a0..d6a31f3 100644
--- a/internal/cache/cache.go
+++ b/internal/cache/cache.go
@@ -2,6 +2,7 @@ package cache
import (
"database/sql"
+ "log/slog"
"sync"
"sync/atomic"
"time"
@@ -199,16 +200,22 @@ func (c *Cache) evictLoop() {
}
}
func (c *Cache) writeToDB(key Key, e *entry) {
+ if c.db == nil {
+ return
+ }
data, err := e.msg.Pack()
if err != nil {
return
}
- c.db.Exec(
+ _, err = c.db.Exec(
`INSERT OR REPLACE INTO cache (name, qtype, class, data, stored_at, ttl_ns)
VALUES (?, ?, ?, ?, ?, ?)`,
key.Name, key.Qtype, key.Class, data,
e.storedAt.UnixNano(), int64(e.ttl),
)
+ if err != nil {
+ slog.Warn("cache write to db failed", "err", err)
+ }
}
func (c *Cache) loadFromDB() {