Struct RemoteProcessAllocator

pub struct RemoteProcessAllocator { /* private fields */ }

Allocator with a service frontend that wraps ProcessAllocator.

Implementations

impl RemoteProcessAllocator

pub fn new() -> Arc<Self>

Create a new allocator. It will not start until start() is called.

pub fn terminate(&self)

Stop the allocator. This will stop any ongoing allocations.

pub async fn start( &self, cmd: Command, serve_addr: ChannelAddr, timeout: Option<Duration>, ) -> Result<(), Error>

Start a remote process allocator with given cmd listening for RemoteProcessAllocatorMessage on serve_addr. Call will block until cancelled. The implementation is simple such that it can only handle one Alloc at a time. Generally that’s the most common use-case. Flow works as follows:

1. Client sends Allocate message to serve_addr.
2. Allocator connects to bootstrap_addr, creates Alloc and sends Allocated message.
3. Allocator streams one or more Update messages to bootstrap_addr as Alloc progresses making the following changes:
   • Remap mesh_agent listen address to our own forwarder actor address.
4. Allocator sends Done message to bootstrap_addr when Alloc is done.

At any point, client can send Stop message to serve_addr to stop the allocator. If timeout is Some, the allocator will exit if no client connects within that timeout, and no child allocation is running.

pub async fn start_with_allocator<A: Allocator + Send + Sync + 'static>( &self, serve_addr: ChannelAddr, process_allocator: A, timeout: Option<Duration>, ) -> Result<(), Error>

where <A as Allocator>::Alloc: Send + Sync,

Start a remote process allocator with given allocator listening for RemoteProcessAllocatorMessage on serve_addr. Used for testing.