cybertec-postgresql / pgwatch / 25120636498

86%

Build Type

push

github

Committed by web-flow

Commit Message

[+] implement parallel source discovery (#1378)

* [+] implement parallel source discovery

Improves dead-source handling with parallel resolution and instance_up=0
on discovery failure.

`Sources.ResolveDatabases()` previously resolved each source
sequentially. A single slow or unresponsive source
(e.g. a continuous-discovery endpoint behind a firewall) would block
discovery of all subsequent sources for the full connection timeout
duration.

Sources are now resolved concurrently using `sync.WaitGroup.Go()`.
Results are collected into a pre-allocated indexed slice to preserve
deterministic ordering. Per-source error logging with source name is
included in the resolver itself.

When a `SourcePostgresContinuous` or `SourcePatroni` source fails to
resolve any databases, `LoadSources()` now emits `instance_up=0` to
the configured sinks. This makes the failure visible in dashboards and
alerting, consistent with how unreachable directly-monitored sources are
handled.

* `reaper.WriteInstanceDown()` accepts name as an argument

* use `on_error` callback in `Sources.ResolveDatabases()`

* use const instead of hard-coded value

Coverage Stats

6 of 29 new or added lines in 4 files covered. (20.69%)

6 existing lines in 1 file now uncovered.

4434 of 5338 relevant lines covered (83.06%)

0.95 hits per line