Struct VmProtoAgent 

pub struct VmProtoAgent { /* private fields */ }

The guest agent of one running VM, reached over its vsock device.

Implementations

impl VmProtoAgent

pub fn over(handle: Arc<dyn VmHandle>) -> Self

The agent inside handle’s guest.

The port lends the vsock capability out of the handle (VmHandle::vsock borrows) while callers hold the agent across awaits and hand it to detached tasks, so the agent owns the handle.

Trait Implementations

impl GuestAgent for VmProtoAgent

fn run<'life0, 'async_trait>( &'life0 self, start: StartCommand, ) -> Pin<Box<dyn Future<Output = Result<Receiver<Result<OutputChunk>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Run a command and stream its output. The final OutputChunk is always OutputChunk::Exit.

fn exec<'life0, 'async_trait>( &'life0 self, start: StartCommand, ) -> Pin<Box<dyn Future<Output = Result<(ExecInput, Receiver<Result<OutputChunk>>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start an interactive session: input sink, output stream.

fn sync_clock<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ClockSync>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Set the guest wall clock to the host’s now.

fn reconfigure_network<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 NetReconfigCommand, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Re-address the guest after a restore onto a fresh network.

fn wait_for_port<'life0, 'async_trait>( &'life0 self, port: u16, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<PortWait>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Wait until the guest’s own listen table has a listener on port — never a connect probe, which would perturb the workload.

fn files(&self) -> &dyn GuestFiles

The file channel into this Computer.

impl GuestFiles for VmProtoAgent

fn read<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read a whole file.

fn write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, mode: u32, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write a whole file, creating it with mode.

fn stat<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<FileStatDto>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stat one path; symlinks are reported, not followed.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<FileStatDto>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List a directory, non-recursively, with full per-entry metadata.

fn make_dir<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, mode: u32, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a directory and any missing parents; succeeds if it exists.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, recursive: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove a file, symlink or directory; a non-empty directory needs recursive.

fn rename<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, from: &'life1 str, to: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Rename an entry within the Computer.

fn watch<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, recursive: bool, ) -> Pin<Box<dyn Future<Output = Result<DirWatch>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Open a directory watch. The stream ends cleanly when the Computer stops; dropping it cancels the watch.