atomr-cluster-sharding 0.3.1

Sharded entities for atomr — allocation strategies, rebalance, three-phase handoff, remember-entities.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! A typed handle to an entity inside a shard region.

use std::marker::PhantomData;
use std::sync::Arc;

use crate::shard_region::ShardRegion;

#[derive(Clone)]
pub struct EntityRef<E: crate::extractor::MessageExtractor> {
    pub(crate) region: Arc<ShardRegion<E>>,
    pub(crate) entity_id: String,
    _marker: PhantomData<E>,
}

impl<E: crate::extractor::MessageExtractor> EntityRef<E> {
    pub fn new(region: Arc<ShardRegion<E>>, entity_id: String) -> Self {
        Self { region, entity_id, _marker: PhantomData }
    }

    pub fn entity_id(&self) -> &str {
        &self.entity_id
    }

    pub fn tell(&self, msg: E::Message) {
        self.region.deliver(msg);
    }
}