Struct RemoteSupervisorHandle 

pub struct RemoteSupervisorHandle { /* private fields */ }

Handle to communicate with a remote supervisor

Implementations

impl RemoteSupervisorHandle

pub fn new(address: SupervisorAddress) -> Self

Create a new handle to a remote supervisor

pub async fn connect_tcp( addr: impl Into<String>, ) -> Result<Self, DistributedError>

Connect to a TCP supervisor

Errors

Returns an error if the address is invalid.

pub async fn connect_unix( path: impl Into<String>, ) -> Result<Self, DistributedError>

Connect to a Unix socket supervisor

Errors

Returns an error if the path is invalid.

pub async fn send_command( &self, cmd: RemoteCommand, ) -> Result<RemoteResponse, DistributedError>

Send a command to the remote supervisor

Errors

Returns an error if the connection fails or the command cannot be serialized.

pub async fn shutdown(&self) -> Result<(), DistributedError>

Shutdown the remote supervisor

Errors

Returns an error if the remote connection fails.

pub async fn which_children(&self) -> Result<Vec<ChildInfo>, DistributedError>

Get list of children from remote supervisor

Errors

Returns an error if the remote connection fails or returns an unexpected response.

pub async fn terminate_child(&self, id: &str) -> Result<(), DistributedError>

Terminate a child on the remote supervisor

Errors

Returns an error if the remote connection fails or returns an unexpected response.

pub async fn status(&self) -> Result<SupervisorStatus, DistributedError>

Get status from remote supervisor

Errors

Returns an error if the remote connection fails or returns an unexpected response.

Trait Implementations

impl Clone for RemoteSupervisorHandle

fn clone(&self) -> RemoteSupervisorHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.