Struct arcon::prelude::lookup::gc::ActorRefReaper

pub struct ActorRefReaper { /* fields omitted */ }

Reaps deallocated actor references from the underlying lookup table.

Methods

impl ActorRefReaper

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

pub fn run<T>(&self, table: &ArcSwapAny<Arc<T>, Global>) -> usize where
    T: ActorLookup, 

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

pub fn strategy(&self) -> &UpdateStrategy

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

pub fn schedule(&mut self)

pub fn is_scheduled(&self) -> bool

Trait Implementations

impl Default for ActorRefReaper

fn default() -> ActorRefReaper

Returns the "default value" for a type.