monarch_messages::controller

Trait ControllerMessageClient

Source 
pub trait ControllerMessageClient: Send + Sync {
    // Required methods
    fn attach<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort),
        client_actor: ActorRef<ClientActor>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn node<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        defs: Vec<Ref>,
        uses: Vec<Ref>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn drop_refs<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        refs: Vec<Ref>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn send<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        ranks: Ranks,
        message: Serialized,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn remote_function_failed<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        error: WorkerError,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn status<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        worker_actor_id: ActorId,
        controller: bool,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn fetch_result<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        seq: Seq,
        value: Result<Serialized, WorkerError>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_first_incomplete_seqs_unit_tests_only<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort),
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Seq>, Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn check_supervision<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn debugger_message<'life0, 'life1, 'async_trait>(
        &'life0 self,
        caps: &'life1 (impl 'async_trait + CanSend),
        debugger_actor_id: ActorId,
        action: DebuggerAction,
    ) -> Pin<Box<dyn Future<Output = Result<(), 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 attach<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), client_actor: ActorRef<ClientActor>, ) -> 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 node<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, defs: Vec<Ref>, uses: 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 drop_refs<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), refs: 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 send<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), ranks: Ranks, message: Serialized, ) -> 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 remote_function_failed<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, error: WorkerError, ) -> 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 status<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, worker_actor_id: ActorId, 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 fetch_result<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), seq: Seq, value: Result<Serialized, WorkerError>, ) -> 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_first_incomplete_seqs_unit_tests_only<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), ) -> Pin<Box<dyn Future<Output = Result<Vec<Seq>, Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The generated client method for this enum variant.

Source

fn check_supervision<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), ) -> 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 debugger_message<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), debugger_actor_id: ActorId, action: DebuggerAction, ) -> 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.

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> ControllerMessageClient for ActorHandle<A>
where A: Handler<ControllerMessage>,

Source§

fn attach<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), client_actor: ActorRef<ClientActor>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

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

Source§

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

Source§

fn send<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), ranks: Ranks, message: Serialized, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

fn debugger_message<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), debugger_actor_id: ActorId, action: DebuggerAction, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

impl<A> ControllerMessageClient for ActorRef<A>
where A: RemoteHandles<ControllerMessage>,

Source§

fn attach<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend + CanOpenPort), client_actor: ActorRef<ClientActor>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

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

Source§

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

Source§

fn send<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), ranks: Ranks, message: Serialized, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

fn debugger_message<'life0, 'life1, 'async_trait>( &'life0 self, caps: &'life1 (impl 'async_trait + CanSend), debugger_actor_id: ActorId, action: DebuggerAction, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors§