Struct figaro::orchestration::client::OrchestrationClientManager

pub(crate) struct OrchestrationClientManager {
    host_clients: RwLock<HashMap<HostIdx, Arc<Client>>>,
}

Fields

host_clients: RwLock<HashMap<HostIdx, Arc<Client>>>

Implementations

impl OrchestrationClientManager

pub fn new() -> Self

fn get_client_manager() -> &'static Arc<OrchestrationClientManager>

fn get_client(&self, host_idx: &HostIdx) -> Result<Arc<Client>, InternalError>

pub async fn request_ownership_change( objects_to_move: &Vec<ObjectId>, current_owner: HostIdx, new_owner: HostIdx ) -> Result<Vec<(ObjectId, ObjectVersion)>, OwnershipTransferError>

pub async fn request_cache_spawn( cache_spawn_intent: &NandoActivationIntentSerializable, current_owner: HostIdx ) -> Result<ObjectId, InternalError>

pub async fn notify_add_cache_mapping( to: HostIdx, original_object_id: ObjectId, cached_object_id: ObjectId, version: ObjectVersion, original_owner_idx: HostIdx ) -> Result<(), InternalError>