rm-hull / dot-block / 26719808190

47%

Build Type

push

github

Committed by web-flow

Commit Message

refactor: implement asynchronous cache updates (#123)

* refactor: implement asynchronous cache updates

Introduced `DNSCache` with an update worker pattern to offload cache
writes to a background channel, reducing latency for primary request
processing paths. Decoupled metrics from the concrete cache type using
an interface.

* test: use assert.Eventually for cache stats verification

The previous direct assertions were flaky due to potential race
conditions where cache stats were updated asynchronously. Polling
ensures the test waits for the internal state to stabilize.

* refactor: move cache worker log to constructor

Move the startup log message from the goroutine to the constructor to
ensure the message is emitted immediately upon initialization.

* feat: add Close method to DNSCache

- Add a `done` channel to coordinate worker shutdown.
- Update `runUpdateWorker` to respect the lifecycle.
- Add `Close()` method to allow graceful termination of the worker.

* fix: ensure dispatcher resources are closed

Added a `Close` method to `DNSDispatcher` and invoked it in `RunServer`
using `defer` to prevent resource leaks when the application exits.

* refactor: use pointer for DNSCache in CacheReaper

Updated the `CacheReaper` struct to hold a pointer to `DNSCache` instead
of a value type to avoid unnecessary copying and maintain consistency
with the `DNSDispatcher` implementation.

* refactor: remove unnecessary //go:inline directives

* test: add cache verification in DNS dispatcher test

Ensure the cache item is retrievable before asserting stats in
`TestDNSDispatcher_HandleDNSRequest_CacheHit` to prevent race
conditions where cache stats update before the item is fully
accessible.

* refactor: add shutdown channel and cleanup dispatcher tests

- Added `done` channel to `DNSCache` to support proper lifecycle
management.
- Fixed typo in logger field name (`maxCcheSize` -> `maxCacheSize`).
- Added `t.Cleanup(dispatcher.Close)` to unit tests to prevent ... (continued)

Coverage Stats

83 of 111 new or added lines in 5 files covered. (74.77%)

1 existing line in 1 file now uncovered.

571 of 1364 relevant lines covered (41.86%)

0.45 hits per line