Struct figaro::orchestration::registry::OwnershipRegistry

pub struct OwnershipRegistry {
    past_ownership: RwLock<HashMap<ObjectId, RwLock<Vec<VersionRange>>>>,
    pub current_ownership: RwLock<HashMap<ObjectId, RwLock<VersionRange>>>,
}

Fields

past_ownership: RwLock<HashMap<ObjectId, RwLock<Vec<VersionRange>>>>

current_ownership: RwLock<HashMap<ObjectId, RwLock<VersionRange>>>

Implementations

impl OwnershipRegistry

fn new() -> Self

pub(crate) fn get_ownership_registry() -> &'static Arc<OwnershipRegistry>

pub fn get_owning_host(&self, object_id: &ObjectId) -> Option<HostIdx>

pub fn get_owning_hosts( &self, object_ids: &Vec<ObjectId> ) -> HashMap<HostIdx, Vec<ObjectId>>

pub fn objects_are_colocated( &self, object_ids: &Vec<ObjectId> ) -> Option<HostIdx>

Returns option with host id if objects are colocated, none otherwise.

pub fn handle_publish( &self, published_object_id: ObjectId, owner: HostIdx ) -> bool

pub fn update_ownership( &self, target_object: ObjectId, whomstone_version: ObjectVersion, old_owner: HostIdx, new_owner: HostIdx )

pub fn reset_state(&self)