Struct SupervisorServer 

pub struct SupervisorServer<W: Worker> { /* private fields */ }

Server that wraps a SupervisorHandle and accepts remote commands

Implementations

impl<W: Worker> SupervisorServer<W>

pub fn new(handle: SupervisorHandle<W>) -> Self

Create a new supervisor server wrapping a SupervisorHandle

pub async fn listen_unix( self, path: impl AsRef<Path>, ) -> Result<(), DistributedError>

Start listening on a Unix socket (Unix only)

Errors

Returns an error if the socket cannot be bound or a connection fails.

pub async fn listen_tcp( self, addr: impl AsRef<str>, ) -> Result<(), DistributedError>

Start listening on a TCP socket

Errors

Returns an error if the socket cannot be bound or a connection fails.