Struct GuestService 

struct GuestService<P: Send + Sync + 'static> {
    plugin: Arc<P>,
    shutdown_tx: Mutex<Option<Sender<()>>>,
    sample_dir: PathBuf,
    artifact_dir: PathBuf,
    external_log_dir: PathBuf,
    log_bus: Arc<LogBus>,
    stash: Arc<ResultStash>,
    auto_collect_artifacts: AutoCollectSection,
    auto_collect_external_logs: AutoCollectSection,
    default_timeout: u64,
}

Internal gRPC service implementation that delegates RPCs to a GuestPlugin.

Fields

plugin: Arc<P>

shutdown_tx: Mutex<Option<Sender<()>>>

sample_dir: PathBuf

artifact_dir: PathBuf

external_log_dir: PathBuf

log_bus: Arc<LogBus>

stash: Arc<ResultStash>

auto_collect_artifacts: AutoCollectSection

auto_collect_external_logs: AutoCollectSection

default_timeout: u64

Trait Implementations

impl<P: GuestPlugin> GuestPluginService for GuestService<P>

type ExecuteTaskStream = Pin<Box<dyn Stream<Item = Result<TaskResult, Status>> + Send>>

Server streaming response type for the ExecuteTask method.

type PullFileStream = Pin<Box<dyn Stream<Item = Result<FileChunk, Status>> + Send>>

Server streaming response type for the PullFile method.

type StreamLogsStream = Pin<Box<dyn Stream<Item = Result<LogEntry, Status>> + Send>>

Server streaming response type for the StreamLogs method.

type PullResultStream = Pin<Box<dyn Stream<Item = Result<ResultChunk, Status>> + Send>>

Server streaming response type for the PullResult method.

fn initialize<'life0, 'async_trait>( &'life0 self, _request: Request<InitializeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<InitializeResponse>, Status>> + Send + 'async_trait>>

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

Lifecycle management

fn health_check<'life0, 'async_trait>( &'life0 self, _request: Request<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + 'async_trait>>

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

fn shutdown<'life0, 'async_trait>( &'life0 self, _request: Request<ShutdownRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ShutdownResponse>, Status>> + Send + 'async_trait>>

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

fn execute_task<'life0, 'async_trait>( &'life0 self, request: Request<TaskRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ExecuteTaskStream>, Status>> + Send + 'async_trait>>

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

Task execution — daemon sends task, guest streams results back

fn push_file<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<FileChunk>>, ) -> Pin<Box<dyn Future<Output = Result<Response<FileTransferResponse>, Status>> + Send + 'async_trait>>

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

Guest access — file transfer and command execution on guest OS

fn pull_file<'life0, 'async_trait>( &'life0 self, request: Request<PullFileRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::PullFileStream>, Status>> + Send + 'async_trait>>

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

fn execute_command<'life0, 'async_trait>( &'life0 self, _request: Request<ExecRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ExecResponse>, Status>> + Send + 'async_trait>>

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

fn stream_logs<'life0, 'async_trait>( &'life0 self, request: Request<LogStreamRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamLogsStream>, Status>> + Send + 'async_trait>>

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

Log streaming — daemon pulls logs from guest plugin

fn pull_result<'life0, 'async_trait>( &'life0 self, request: Request<PullResultRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::PullResultStream>, Status>> + Send + 'async_trait>>

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

Large result transfer — daemon pulls stashed results by opaque handle