monarch_messages::worker

Trait WorkerMessageClient

Source 
pub trait WorkerMessageClient: Send + Sync {

Show 29 methods    // Required methods
    fn backend_network_init<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        arg0: UniqueId,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn backend_network_point_to_point_init<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        from_stream: StreamRef,
        to_stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn call_function<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        arg0: CallFunctionParams,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn command_group<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        arg0: Vec<WorkerMessage>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn create_stream<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        id: StreamRef,
        stream_creation: StreamCreationMode,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn create_device_mesh<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        names: Vec<String>,
        ranks: Slice,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn create_remote_process_group<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        device_mesh: Ref,
        dims: Vec<String>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn borrow_create<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        borrow: u64,
        tensor: Ref,
        from_stream: StreamRef,
        to_stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn borrow_first_use<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        borrow: u64,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn borrow_last_use<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        borrow: u64,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn borrow_drop<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        borrow: u64,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn delete_refs<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        arg0: Vec<Ref>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn request_status<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        controller: bool,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn reduce<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        tensor: Ref,
        factory: Factory,
        mesh: Ref,
        stream: StreamRef,
        dims: Vec<String>,
        reduction: Reduction,
        scatter: bool,
        in_place: bool,
        out: Option<Ref>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn split_comm<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        dims: Vec<String>,
        device_mesh: Ref,
        stream: StreamRef,
        config: Option<NcclConfig>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn split_comm_for_process_group<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        remote_process_group: Ref,
        stream: StreamRef,
        config: Option<NcclConfig>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_tensor<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        from_ranks: Slice,
        to_ranks: Slice,
        tensor: Ref,
        factory: Factory,
        from_stream: StreamRef,
        to_stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn create_pipe<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        key: String,
        function: ResolvableFunction,
        max_messages: i64,
        mesh: Ref,
        args: Vec<WireValue>,
        kwargs: HashMap<String, WireValue>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_value<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        destination: Option<Ref>,
        mutates: Vec<Ref>,
        function: Option<ResolvableFunction>,
        args: Vec<WireValue>,
        kwargs: HashMap<String, WireValue>,
        stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send_result_of_actor_call<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        arg0: ActorCallParams,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn call_actor_method<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        arg0: ActorMethodParams,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn pipe_recv<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        results: Vec<Option<Ref>>,
        pipe: Ref,
        stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn exit<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        error: Option<(Option<ActorId>, String)>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn define_recording<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        nresults: usize,
        nformals: usize,
        commands: Vec<WorkerMessage>,
        ntotal_messages: usize,
        index: usize,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn recording_formal<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        argument_index: usize,
        stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn recording_result<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        result: Ref,
        output_index: usize,
        stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn call_recording<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        recording: Ref,
        results: Vec<Ref>,
        actuals: Vec<Ref>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn set_ref_unit_tests_only<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        reference: Ref,
        value: WireValue,
        stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_ref_unit_tests_only<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort),
        value: Ref,
        stream: StreamRef,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Result<WireValue, String>>, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;

}
Expand description

The custom client trait for this message type.

Required Methods§

Source

fn backend_network_init<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: UniqueId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn backend_network_point_to_point_init<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn call_function<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: CallFunctionParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn command_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: Vec<WorkerMessage>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn create_stream<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), id: StreamRef, stream_creation: StreamCreationMode, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn create_device_mesh<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, names: Vec<String>, ranks: Slice, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn create_remote_process_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, device_mesh: Ref, dims: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn borrow_create<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, borrow: u64, tensor: Ref, from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn borrow_first_use<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn borrow_last_use<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn borrow_drop<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn delete_refs<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: Vec<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn request_status<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, controller: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn reduce<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, tensor: Ref, factory: Factory, mesh: Ref, stream: StreamRef, dims: Vec<String>, reduction: Reduction, scatter: bool, in_place: bool, out: Option<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn split_comm<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), dims: Vec<String>, device_mesh: Ref, stream: StreamRef, config: Option<NcclConfig>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn split_comm_for_process_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), remote_process_group: Ref, stream: StreamRef, config: Option<NcclConfig>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn send_tensor<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, from_ranks: Slice, to_ranks: Slice, tensor: Ref, factory: Factory, from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn create_pipe<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, key: String, function: ResolvableFunction, max_messages: i64, mesh: Ref, args: Vec<WireValue>, kwargs: HashMap<String, WireValue>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn send_value<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, destination: Option<Ref>, mutates: Vec<Ref>, function: Option<ResolvableFunction>, args: Vec<WireValue>, kwargs: HashMap<String, WireValue>, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn send_result_of_actor_call<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: ActorCallParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn call_actor_method<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: ActorMethodParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn pipe_recv<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, results: Vec<Option<Ref>>, pipe: Ref, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn exit<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), error: Option<(Option<ActorId>, String)>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn define_recording<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, nresults: usize, nformals: usize, commands: Vec<WorkerMessage>, ntotal_messages: usize, index: usize, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn recording_formal<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, argument_index: usize, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn recording_result<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, output_index: usize, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn call_recording<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, recording: Ref, results: Vec<Ref>, actuals: Vec<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn set_ref_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), reference: Ref, value: WireValue, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn get_ref_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), value: Ref, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<Option<Result<WireValue, String>>, Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl<A> WorkerMessageClient for ActorHandle<A>
where A: Handler<WorkerMessage>,

Source§

fn backend_network_init<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: UniqueId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn backend_network_point_to_point_init<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn call_function<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: CallFunctionParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn command_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: Vec<WorkerMessage>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_stream<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), id: StreamRef, stream_creation: StreamCreationMode, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_device_mesh<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, names: Vec<String>, ranks: Slice, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_remote_process_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, device_mesh: Ref, dims: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_create<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, borrow: u64, tensor: Ref, from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_first_use<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_last_use<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_drop<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn delete_refs<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: Vec<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn request_status<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, controller: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn reduce<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, tensor: Ref, factory: Factory, mesh: Ref, stream: StreamRef, dims: Vec<String>, reduction: Reduction, scatter: bool, in_place: bool, out: Option<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn split_comm<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), dims: Vec<String>, device_mesh: Ref, stream: StreamRef, config: Option<NcclConfig>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn split_comm_for_process_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), remote_process_group: Ref, stream: StreamRef, config: Option<NcclConfig>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn send_tensor<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, from_ranks: Slice, to_ranks: Slice, tensor: Ref, factory: Factory, from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_pipe<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, key: String, function: ResolvableFunction, max_messages: i64, mesh: Ref, args: Vec<WireValue>, kwargs: HashMap<String, WireValue>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn send_value<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, destination: Option<Ref>, mutates: Vec<Ref>, function: Option<ResolvableFunction>, args: Vec<WireValue>, kwargs: HashMap<String, WireValue>, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn send_result_of_actor_call<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: ActorCallParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn call_actor_method<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: ActorMethodParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn pipe_recv<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, results: Vec<Option<Ref>>, pipe: Ref, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn exit<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), error: Option<(Option<ActorId>, String)>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn define_recording<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, nresults: usize, nformals: usize, commands: Vec<WorkerMessage>, ntotal_messages: usize, index: usize, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn recording_formal<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, argument_index: usize, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn recording_result<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, output_index: usize, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn call_recording<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, recording: Ref, results: Vec<Ref>, actuals: Vec<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn set_ref_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), reference: Ref, value: WireValue, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_ref_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), value: Ref, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<Option<Result<WireValue, String>>, Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

impl<A> WorkerMessageClient for ActorRef<A>
where A: RemoteHandles<WorkerMessage>,

Source§

fn backend_network_init<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: UniqueId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn backend_network_point_to_point_init<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn call_function<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: CallFunctionParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn command_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: Vec<WorkerMessage>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_stream<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), id: StreamRef, stream_creation: StreamCreationMode, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_device_mesh<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, names: Vec<String>, ranks: Slice, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_remote_process_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, device_mesh: Ref, dims: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_create<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, borrow: u64, tensor: Ref, from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_first_use<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_last_use<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn borrow_drop<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), borrow: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn delete_refs<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: Vec<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn request_status<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, controller: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn reduce<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, tensor: Ref, factory: Factory, mesh: Ref, stream: StreamRef, dims: Vec<String>, reduction: Reduction, scatter: bool, in_place: bool, out: Option<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn split_comm<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), dims: Vec<String>, device_mesh: Ref, stream: StreamRef, config: Option<NcclConfig>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn split_comm_for_process_group<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), remote_process_group: Ref, stream: StreamRef, config: Option<NcclConfig>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn send_tensor<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, from_ranks: Slice, to_ranks: Slice, tensor: Ref, factory: Factory, from_stream: StreamRef, to_stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn create_pipe<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, key: String, function: ResolvableFunction, max_messages: i64, mesh: Ref, args: Vec<WireValue>, kwargs: HashMap<String, WireValue>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn send_value<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, destination: Option<Ref>, mutates: Vec<Ref>, function: Option<ResolvableFunction>, args: Vec<WireValue>, kwargs: HashMap<String, WireValue>, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn send_result_of_actor_call<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: ActorCallParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn call_actor_method<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), arg0: ActorMethodParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn pipe_recv<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, results: Vec<Option<Ref>>, pipe: Ref, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn exit<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), error: Option<(Option<ActorId>, String)>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn define_recording<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, nresults: usize, nformals: usize, commands: Vec<WorkerMessage>, ntotal_messages: usize, index: usize, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn recording_formal<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, argument_index: usize, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn recording_result<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), result: Ref, output_index: usize, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn call_recording<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, recording: Ref, results: Vec<Ref>, actuals: Vec<Ref>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn set_ref_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), reference: Ref, value: WireValue, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

fn get_ref_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), value: Ref, stream: StreamRef, ) -> Pin<Box<dyn Future<Output = Result<Option<Result<WireValue, String>>, Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors§