Struct scheduling::net::rpc::worker_rpc_client::WorkerRpcClient

pub struct WorkerRpcClient {
    server_port: u16,
    host_clients: DashMap<HostId, WorkerApiClient<Channel>>,
}

Fields

server_port: u16

host_clients: DashMap<HostId, WorkerApiClient<Channel>>

Implementations

impl WorkerRpcClient

pub fn new(server_port: u16) -> Self

async fn get_client( &self, host_id: &HostId ) -> Result<WorkerApiClient<Channel>, String>

pub async fn forward_task_completion( &self, task_completion_notification: TaskCompletionNotification, host_idx: HostIdx, target_host: &HostId ) -> Result<(), String>

pub async fn schedule_nando( &self, activation_intent_request: NandoActivationIntent, target_host: &HostId ) -> Result<(Vec<ActivationOutput>, Vec<(ObjectId, ObjectVersion)>), String>

pub async fn forward_spawned_task( &self, spawned_task: SpawnedTask, target_host: &HostId ) -> Result<NandoActivationResolution, String>

pub async fn schedule_task_graph( &self, spawned_tasks: &Vec<SpawnedTask>, target_host: &HostId ) -> Result<Vec<NandoActivationResolution>, String>

pub async fn assume_ownership( &self, assume_ownership_request: AssumeOwnershipRequest, target_host: &HostId ) -> Result<Vec<u8>, String>

pub async fn move_ownership( &self, move_ownership_request: MoveOwnershipRequest, target_host: &HostId ) -> Result<MoveOwnershipResponse, String>

pub async fn fault_shared_cache( &self, host_idx: HostIdx, original_object_id: ObjectId, cached_object_id: ObjectId, cache_version: ObjectVersion, target_host: &HostId ) -> Result<(), String>

pub async fn add_cache_mapping( &self, original_object: &IPtr, cache_object: &IPtr, version: ObjectVersion, target_host: &HostId, own_idx: HostIdx ) -> Result<(), String>

Trait Implementations

impl Debug for WorkerRpcClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.