Struct QvnContainer

pub struct QvnContainer {
    pub container: Arc<DockerContainer>,
    pub error_counter: Arc<RwLock<i32>>,
    pub start_time: Arc<RwLock<u64>>,
    pub is_ready: Arc<RwLock<bool>>,
    pub addr: Uri,
    /* private fields */
}

Fields

container: Arc<DockerContainer>

error_counter: Arc<RwLock<i32>>

start_time: Arc<RwLock<u64>>

is_ready: Arc<RwLock<bool>>

addr: Uri

Implementations

impl QvnContainer

pub fn new( docker: Arc<Docker>, image_name: String, env: Vec<String>, config: Config<String>, addr: Option<String>, ) -> Self

pub async fn create( docker: Docker, image_name: &str, qvn_env: Vec<String>, default_docker_config: Option<Config<String>>, ) -> ContainerResult<Self>

pub async fn send_result( &self, fn_result: &FunctionResult, ) -> ContainerResult<()>

pub async fn watch(self: Arc<Self>) -> ContainerResult<JoinHandle<()>>

Trait Implementations

impl Clone for QvnContainer

fn clone(&self) -> QvnContainer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Container for QvnContainer

fn docker(&self) -> &Arc<Docker>

fn id(&self) -> &String

fn image_name(&self) -> &String

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

where Self: Sync + 'async_trait, 'life0: 'async_trait,

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

where Self: Sync + 'async_trait, 'life0: 'async_trait,

fn kill<'life0, 'async_trait>( &'life0 self, remove: bool, ) -> Pin<Box<dyn Future<Output = ContainerResult<()>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

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

where Self: Sync + 'async_trait, 'life0: 'async_trait,

fn run_and_decode<'life0, 'async_trait, F, Fut>( &'life0 self, timeout_secs: Option<u64>, on_log: F, ) -> Pin<Box<dyn Future<Output = ContainerResult<FunctionResult>> + Send + 'async_trait>>

where F: Fn(String) -> Fut + Send + Sync + 'async_trait, Fut: Future<Output = ()> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

fn run<'life0, 'async_trait, F, Fut>( &'life0 self, timeout_secs: Option<u64>, on_log: F, ) -> Pin<Box<dyn Future<Output = ContainerResult<String>> + Send + 'async_trait>>

where F: Fn(String) -> Fut + Send + Sync + 'async_trait, Fut: Future<Output = ()> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

fn run_command<'life0, 'async_trait, F, Fut>( &'life0 self, cmd: Vec<String>, timeout_secs: Option<u64>, on_log: F, ) -> Pin<Box<dyn Future<Output = ContainerResult<String>> + Send + 'async_trait>>

where F: Fn(String) -> Fut + Send + Sync + 'async_trait, Fut: Future<Output = ()> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

fn attach_and_collect_logs<'life0, 'async_trait, F, Fut>( &'life0 self, timeout_secs: Option<u64>, on_log: F, ) -> Pin<Box<dyn Future<Output = ContainerResult<String>> + Send + 'async_trait>>

where F: Fn(String) -> Fut + Send + Sync + 'async_trait, Fut: Future<Output = ()> + Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait,

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

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

fn fetch_measurement<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ContainerResult<String>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

fn run_get_measurement<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ContainerResult<String>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

fn get_ip_address<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ContainerResult<String>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

impl Debug for QvnContainer

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

Formats the value using the given formatter.