Enum RemoteProcessAllocatorMessage

pub enum RemoteProcessAllocatorMessage {
    Allocate {
        view: View,
        bootstrap_addr: ChannelAddr,
        hosts: Vec<String>,
        client_context: Option<ClientContext>,
    },
    Stop,
    HeartBeat,
}

Control messages sent from remote process allocator to local allocator.

Variants

Allocate

Create allocation with given spec and send updates to bootstrap_addr.

Fields

view: View

The view of a larger allocation for which this remote allocator is responsible.

bootstrap_addr: ChannelAddr

Bootstrap address to be used for sending updates.

hosts: Vec<String>

Ordered list of hosts in this allocation. Can be used to pre-populate the any local configurations such as torch.dist.

client_context: Option<ClientContext>

Client context which is passed to the ProcessAlloc Todo: Once RemoteProcessAllocator moves to mailbox, the client_context will go to the message header instead

Stop

Stop allocation.

HeartBeat

Heartbeat message to check if remote process allocator and its host are alive.

Trait Implementations

impl Clone for RemoteProcessAllocatorMessage

fn clone(&self) -> RemoteProcessAllocatorMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RemoteProcessAllocatorMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RemoteProcessAllocatorMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Named for RemoteProcessAllocatorMessage

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

The globally unique port for this type. Typed ports are in the range of 1<<63..1<<64-1.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl Serialize for RemoteProcessAllocatorMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.