Struct ActorRefReaper 

pub struct ActorRefReaper { /* private fields */ }

Reaps deallocated actor references from the underlying lookup table.

Implementations

impl ActorRefReaper

pub fn new( initial_interval: u64, min: u64, max: u64, incr: u64, decr: u64, algo: FeedbackAlgorithm, ) -> ActorRefReaper

Creates a reaper with the provided interval update parameters.

pub fn from_config(conf: &Config) -> ActorRefReaper

Builds a reaper from the Kompact configuration.

pub fn run(&self, table: &ArcSwapAny<Arc<ActorStore>>) -> usize

Walks through all stored [ActorRef] entries and removes the ones which have been deallocated, returning the # of removed instances.

pub fn strategy(&self) -> &UpdateStrategy

Returns the current interval update strategy.

pub fn strategy_mut(&mut self) -> &mut UpdateStrategy

Returns the mutable interval update strategy.

pub fn schedule(&mut self)

Marks the reaper as scheduled.

pub fn is_scheduled(&self) -> bool

Returns whether the reaper is already scheduled.

Trait Implementations

impl Default for ActorRefReaper

fn default() -> ActorRefReaper

Returns the “default value” for a type.