Struct SelectionManager 

pub struct SelectionManager { /* private fields */ }

Implementations

impl SelectionManagerService

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

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

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

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

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

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

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

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

impl SelectionManagerService

pub const SERVICE_SURFACE_DECLARATION_CATEGORY_LITERAL: &'static str = "service_surface"

pub const SERVICE_SURFACE_DECLARATION: ServiceSurfaceDeclaration<Self>

impl SelectionManagerService

pub fn new( config: SelectionManagerConfig, registry: Arc<ServiceRegistry>, health: LocalHealthObserverService, ) -> Self

pub async fn select_profile<E: RandomEffects + ?Sized>( &self, scope: ContextId, destination: LinkEndpoint, move_candidates: &[ProviderCandidate], hold_candidates: &[ProviderCandidate], now_ms: u64, random: &E, ) -> Result<LocalSelectionProfile, SelectionManagerError>

pub async fn remember_bootstrap_hints( &self, scope: ContextId, hints: &[BootstrapHint], )

pub async fn remember_bootstrap_contact_records( &self, scope: ContextId, records: &[BootstrapContactHint], ) -> Result<usize, SelectionManagerError>

pub async fn remember_neighborhood_reentry_records( &self, scope: ContextId, records: &[NeighborhoodReentryHint], ) -> Result<usize, SelectionManagerError>

pub async fn remember_bootstrap_introduction_records( &self, scope: ContextId, records: &[BootstrapIntroductionHint], observed_at_ms: u64, ) -> Result<usize, SelectionManagerError>

pub async fn record_reentry_attempt( &self, scope: ContextId, stage: BootstrapReentryStage, now_ms: u64, succeeded: bool, )

pub async fn stale_reentry_decision( &self, scope: ContextId, now_ms: u64, ) -> Option<BootstrapReentryDecision>

Trait Implementations

impl RuntimeService for SelectionManagerService

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