Struct LocalHealthObserver 

pub struct LocalHealthObserver { /* private fields */ }

Implementations

impl LocalHealthObserverService

pub const ACTOR_BOUNDARY_CATEGORY: BoundaryDeclarationCategory = ::aura_core::BoundaryDeclarationCategory::ActorOwned

pub const ACTOR_OWNER_NAME: &'static str = "local_health_observer"

pub const ACTOR_DOMAIN_NAME: &'static str = "adaptive_privacy_health"

pub const ACTOR_INGRESS_GATE: &'static str = "local_health_command_ingress"

pub const ACTOR_DECLARATION_CATEGORY_LITERAL: &'static str = "actor_owned"

pub fn actor_declaration() -> ActorDeclaration<Self, LocalHealthObserverCommand>

pub fn actor_ingress() -> BoundedActorIngress<Self, LocalHealthObserverCommand>

pub fn register_actor_supervision<HandleId>( handle_id: HandleId, shutdown: OwnedShutdownToken, ) -> SupervisionRegistration<Self, LocalHealthObserverCommand, HandleId>

impl LocalHealthObserverService

pub fn new(config: LocalHealthObserverConfig) -> Self

pub async fn snapshot(&self) -> LocalHealthSnapshot

pub async fn observe_provider_set( &self, candidates: &[ProviderCandidate], route_diversity: u8, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_rtt_ms( &self, rtt_ms: u32, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_loss_bps( &self, loss_bps: u32, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_traffic_volume( &self, traffic_bytes: u64, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_sync_blended_retrieval_volume( &self, retrieval_bytes: u64, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_accountability_reply_volume( &self, reply_bytes: u64, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_churn( &self, churn_events: u32, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_queue_pressure( &self, pressure: u32, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_hold_outcome( &self, success: bool, now_ms: u64, ) -> LocalHealthSnapshot

pub async fn observe_sync_opportunity(&self, now_ms: u64) -> LocalHealthSnapshot

Trait Implementations

impl Clone for LocalHealthObserverService

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for LocalHealthObserverService

fn default() -> LocalHealthObserverService

Returns the “default value” for a type.

impl RuntimeService for LocalHealthObserverService

fn name(&self) -> &'static str

Returns the unique name of this service

fn dependencies(&self) -> &[&'static str]

Returns the names of services this service depends on

fn start<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RuntimeServiceContext, ) -> Pin<Box<dyn Future<Output = Result<(), ServiceError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start the service

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), ServiceError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop the service gracefully

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ServiceHealth> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the current health status of the service