Struct RegistrationHealthTracker 

pub(crate) struct RegistrationHealthTracker {
    next_sequence: Arc<AtomicU64>,
    state: Arc<RwLock<RegistrationTrackerState>>,
}

Retains detail-free runtime registration results for public health queries.

Fields

next_sequence: Arc<AtomicU64>

Next sequence used to order attempts when they begin.

state: Arc<RwLock<RegistrationTrackerState>>

Retained observations and leave/rejoin invalidation watermarks.

Implementations

impl RegistrationHealthTracker

pub(crate) fn begin_lnv1_attempt( &self, federation_id: FederationId, protocol: RegisteredProtocol, ) -> RegistrationAttemptToken

Starts an LNv1 registration attempt and returns its ordering token.

pub(crate) async fn complete_attempt( &self, token: RegistrationAttemptToken, succeeded: bool, completed_wall_time: SystemTime, completed_monotonic: Instant, )

Retains a finite result unless an attempt begun later already completed.

Begin order, rather than completion wall time, defines freshness so a slow stale request cannot overwrite the result of a newer logical attempt. Successful TTL is measured from monotonic completion time.

pub(crate) async fn lnv1_status( &self, federation_id: FederationId, protocols: impl IntoIterator<Item = RegisteredProtocol>, ttl: Duration, now: Instant, ) -> BTreeMap<RegisteredProtocol, RegistrationEndpointStatus>

Returns status for every configured LNv1 public transport.

pub(crate) async fn clear_federation(&self, federation_id: FederationId)

Removes observations after the gateway leaves a federation.

Trait Implementations

impl Clone for RegistrationHealthTracker

fn clone(&self) -> RegistrationHealthTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RegistrationHealthTracker

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

Formats the value using the given formatter.

impl Default for RegistrationHealthTracker

fn default() -> RegistrationHealthTracker

Returns the “default value” for a type.