Struct CommandComposeInspector 

pub struct CommandComposeInspector<E> { /* private fields */ }

Compose inspector backed by a soma-fleet command executor.

Implementations

impl<E> CommandComposeInspector<E>

pub fn new(executor: Arc<E>) -> Self

Creates a Compose inspector using the supplied fleet executor.

Trait Implementations

impl<E> ComposeDownMutator for CommandComposeInspector<E>

where E: CommandExecutor,

fn down_compose<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ComposeDownRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ComposeDownReceipt>> + Send + 'async_trait>>

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

Performs one shell-free Compose down command.

impl<E> ComposeInspector for CommandComposeInspector<E>

where E: CommandExecutor,

fn list_projects<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, deadline: Timestamp, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Vec<ComposeProject>>> + Send + 'async_trait>>

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

Lists Compose projects visible on one host.

fn status<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, host: &'life1 HostRecord, project: &'life2 ComposeProjectRef, service: Option<&'life3 str>, deadline: Timestamp, cancellation: &'life4 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ComposeStatus>> + Send + 'async_trait>>

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

Returns status for one project, optionally restricted to a service.

fn config<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, project: &'life2 ComposeProjectRef, deadline: Timestamp, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ComposeConfig>> + Send + 'async_trait>>

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

Returns selected normalized project configuration.

fn logs<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, host: &'life1 HostRecord, project: &'life2 ComposeProjectRef, request: &'life3 ComposeLogRequest, cancellation: &'life4 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ComposeLogs>> + Send + 'async_trait>>

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

Reads bounded project logs.

impl<E> ComposeMutator for CommandComposeInspector<E>

where E: CommandExecutor,

fn mutate_compose<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ComposeMutationRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ComposeMutationReceipt>> + Send + 'async_trait>>

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

Sends one Compose mutation while preserving send uncertainty.

impl<E> ComposePullMutator for CommandComposeInspector<E>

where E: CommandExecutor,

fn pull_compose_images<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ComposePullRequest, progress: &'life3 dyn MutationProgressReporter, cancellation: &'life4 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ComposePullReceipt>> + Send + 'async_trait>>

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

Pulls configured service images while preserving send uncertainty.

impl<E> ComposeRecreateMutator for CommandComposeInspector<E>

where E: CommandExecutor,

fn recreate_compose<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ComposeRecreateRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ComposeRecreateReceipt>> + Send + 'async_trait>>

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

Performs one force-recreate command.