Struct scheduling::net::rpc::worker_rpc_server::WorkerRpcServer

pub struct WorkerRpcServer {}

Trait Implementations

impl Debug for WorkerRpcServer

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

Formats the value using the given formatter.

impl Default for WorkerRpcServer

fn default() -> WorkerRpcServer

Returns the “default value” for a type.

impl WorkerApi for WorkerRpcServer

fn schedule_nando<'life0, 'async_trait>( &'life0 self, request: Request<ActivationIntent> ) -> Pin<Box<dyn Future<Output = Result<Response<ActivationResolution>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn schedule_spawned_task<'life0, 'async_trait>( &'life0 self, request: Request<SpawnedTask> ) -> Pin<Box<dyn Future<Output = Result<Response<ActivationResolution>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn handle_task_completion<'life0, 'async_trait>( &'life0 self, request: Request<TaskCompletion> ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn assume_ownership<'life0, 'async_trait>( &'life0 self, request: Request<AssumeOwnershipRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<AssumeOwnershipResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn move_ownership<'life0, 'async_trait>( &'life0 self, request: Request<MoveOwnershipRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<MoveOwnershipResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn fault_shared_cache<'life0, 'async_trait>( &'life0 self, request: Request<FaultCacheRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn schedule_task_graph<'life0, 'async_trait>( &'life0 self, request: Request<TaskGraph> ) -> Pin<Box<dyn Future<Output = Result<Response<TaskGraphResolution>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn add_cache_mapping<'life0, 'async_trait>( &'life0 self, request: Request<CacheMapping> ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,