[−][src]Struct arcon::prelude::lookup::ActorStore
Lookup structure for storing and retrieving ActorRef
s.
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
[src]
pub fn new() -> ActorStore
[src]
Trait Implementations
impl ActorLookup for ActorStore
[src]
fn insert(&mut self, actor: ActorRef, path: PathResolvable) -> Option<ActorRef>
[src]
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
[src]
fn get_by_uuid(&self, id: &Uuid) -> Option<&ActorRef>
[src]
fn get_by_named_path(&self, path: &Vec<String>) -> Option<&ActorRef>
[src]
fn get_mut_by_uuid(&mut self, id: &Uuid) -> Option<&mut ActorRef>
[src]
fn get_mut_by_named_path(&mut self, path: &Vec<String>) -> Option<&mut ActorRef>
[src]
fn remove(&mut self, actor: ActorRef) -> usize
[src]
fn remove_by_uuid(&mut self, id: &Uuid) -> bool
[src]
fn remove_by_named_path(&mut self, path: &Vec<String>) -> bool
[src]
fn cleanup(&mut self) -> usize
[src]
fn get_by_actor_path(&self, path: &ActorPath) -> Option<&ActorRef>
[src]
fn get_mut_by_actor_path(&mut self, path: &ActorPath) -> Option<&mut ActorRef>
[src]
impl Clone for ActorStore
[src]
fn clone(&self) -> ActorStore
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
Auto Trait Implementations
impl Send for ActorStore
impl Unpin for ActorStore
impl Sync for ActorStore
impl !UnwindSafe for ActorStore
impl !RefUnwindSafe for ActorStore
Blanket Implementations
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,