Struct kompact::lookup::ActorStore

pub struct ActorStore { /* fields omitted */ }

Lookup structure for storing and retrieving ActorRefs.

UUID-based references are stored in a HashMap, and path-based named references are stored in a Trie structure.

Notes

The sequence trie supports the use case of grouping many [ActorRefs] under the same path, similar to a directory structure. Thus, actors can broadcast to all actors under a certain path without requiring explicit identifiers for them. Ex: Broadcasting a message to actors stored on the system path "tcp://127.0.0.1:8080/pongers/*"

This use case is not currently being utilized, but it may be in the future.

Methods

impl ActorStore

pub fn new() -> Self

Trait Implementations

impl ActorLookup for ActorStore

fn insert(&mut self, actor: ActorRef, path: PathResolvable) -> Option<ActorRef>

Inserts or replaces the path in the lookup structure. If an entry already exists, it is removed and returned before being replaced.

fn contains(&self, path: &PathResolvable) -> bool

Returns true if the evaluated path is already stored.

fn get_by_uuid(&self, id: &Uuid) -> Option<&ActorRef>

fn get_by_named_path(&self, path: &Vec<String>) -> Option<&ActorRef>

fn get_mut_by_uuid(&mut self, id: &Uuid) -> Option<&mut ActorRef>

fn get_mut_by_named_path(&mut self, path: &Vec<String>) -> Option<&mut ActorRef>

fn remove(&mut self, actor: ActorRef) -> usize

Removes all entries that point to the provided actor, returning how many were removed (most likely O(n), subject to implementation details)

fn remove_by_uuid(&mut self, id: &Uuid) -> bool

Removes the value at the given key, returning true if it existed.

fn remove_by_named_path(&mut self, path: &Vec<String>) -> bool

Removes the value at the given key, returning true if it existed.

fn cleanup(&mut self) -> usize

Performs cleanup on this lookup table, returning how many entries were affected.

fn get_by_actor_path(&self, path: &ActorPath) -> Option<&ActorRef>

fn get_mut_by_actor_path(&mut self, path: &ActorPath) -> Option<&mut ActorRef>

impl Clone for ActorStore

fn clone(&self) -> ActorStore

Returns a copy of the value.

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

Performs copy-assignment from source.