Struct dockertest::waitfor::MessageWait

pub struct MessageWait {
    pub message: String,
    pub source: MessageSource,
    pub timeout: u16,
}

The MessageWait WaitFor implementation for containers. This variant will wait until the message appears in the requested source.

Fields

message: String

The message to be contained in source.

source: MessageSource

The source to listen for message.

timeout: u16

Number of seconds to wait for message. Times out with an error on expire.

Trait Implementations

impl Clone for MessageWait

fn clone(&self) -> MessageWait

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MessageWait

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

Formats the value using the given formatter.

impl WaitFor for MessageWait

fn wait_for_ready<'life0, 'async_trait>( &'life0 self, container: PendingContainer, ) -> Pin<Box<dyn Future<Output = Result<OperationalContainer, DockerTestError>> + Send + 'async_trait>>

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

Method implementation should return a future that resolves once the condition described by the implementing structure is fulfilled. Once this successfully resolves, the container is marked as ready.

fn expected_state(&self) -> ContainerState

What state the container is expected to be in after completing the wait_for_ready method, defaulting to the ContainerState::Running state. NOTE: This is only relevant for the container state api on ‘OperationalContainer’ (start, stop, kill) as we deny certain operations based on the assumed container state.