clear_for_reflector

Function clear_for_reflector 

Source
pub(crate) async fn clear_for_reflector(
    pool: &PgPool,
    reflector: &str,
) -> Result<(), Error>
Expand description

Deletes all connected node entries for a reflector.

Called before upserting a fresh node snapshot so that nodes that have disconnected since the last update are removed. This simple delete-then-reinsert pattern avoids the complexity of diff-based eviction.

ยงErrors

Returns sqlx::Error on query failure.