Struct PollerCache 

pub struct PollerCache { /* private fields */ }

Shared handle to the background poll cache.

Why: The Arc<RwLock<…>> is shared between the background task and every request handler, so all handlers read from the same live snapshot without contention. What: Wraps an Arc<RwLock<Option<CachedSnapshot>>>. None means the first poll has not completed yet; handlers must fall back to a suitable loading state in that case. Test: Constructed in start; cloned into request handlers via AppState.

Implementations

impl PollerCache

pub fn new() -> Self

Create a new, empty PollerCache.

Why: Start with None so handlers can detect “first poll not done yet”. What: Allocates the Arc<RwLock<None>>. Test: Called by start.

pub async fn snapshot(&self) -> Option<CachedSnapshot>

Read the current snapshot (may be None on first startup).

Why: Routes call this to serve /api/console/services from cache. What: Acquires a read lock, clones the snapshot, releases the lock. Test: test_cache_initialises_with_connectors.

pub async fn poll_once( &self, connectors: Arc<Vec<Box<dyn ServiceConnector>>>, ) -> CachedSnapshot

Run one poll cycle for the given connectors (passed as an Arc).

Why: Lets tests and the initial eager-load before the first HTTP request force a synchronous poll without spinning up the background task. What: Calls each connector’s detect() in a spawn_blocking task (connectors are Send + Sync so the Arc can cross the thread boundary), writes the result into the shared cache, and returns the new snapshot. Test: test_cache_initialises_with_connectors.

Trait Implementations

impl Clone for PollerCache

fn clone(&self) -> PollerCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PollerCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PollerCache

fn default() -> Self

Why: Required by clippy’s new_without_default lint when new() takes no arguments — also convenient for test setup. What: Delegates to PollerCache::new(). Test: Implicitly tested wherever PollerCache::new() is called.