Struct RunningDockerExecutor

pub struct RunningDockerExecutor {
    pub container_id: String,
    pub host_port: String,
    /* private fields */
}

Fields

container_id: String

host_port: String

Implementations

impl RunningDockerExecutor

pub async fn start( container_uuid: Uuid, context_path: &Path, dockerfile: Option<&Path>, image_name: &str, user: Option<&str>, ) -> Result<RunningDockerExecutor, DockerExecutorError>

Starts a docker container with a given context and image name

pub async fn container_state( &self, ) -> Result<ContainerState, DockerExecutorError>

Returns the underlying bollard status of the container

Useful for checking if the executor is running or not

pub async fn is_running(&self) -> bool

Check if the executor and its underlying container is running

Will ignore any errors and assume it is not if there are

pub async fn logs(&self) -> Result<Vec<String>, DockerExecutorError>

Returns the logs of the container

impl RunningDockerExecutor

pub fn into_file_loader<V: IntoIterator<Item = T>, T: Into<String>>( self, path: impl Into<PathBuf>, extensions: V, ) -> FileLoader<'static>

Creates an owned file loader from the executor. If needed it is safe to clone the executor.

The loader can be used with a swiftide indexing pipeline.

pub fn as_file_loader<'a, V: IntoIterator<Item = T>, T: Into<String>>( &'a self, path: impl Into<PathBuf>, extensions: V, ) -> FileLoader<'a>

Creates a borrowed file loader from the executor.

Trait Implementations

impl Clone for RunningDockerExecutor

fn clone(&self) -> RunningDockerExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunningDockerExecutor

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

Formats the value using the given formatter.

impl Drop for RunningDockerExecutor

fn drop(&mut self)

Executes the destructor for this type.

impl From<RunningDockerExecutor> for Arc<dyn ToolExecutor>

fn from(val: RunningDockerExecutor) -> Self

Converts to this type from the input type.

impl ToolExecutor for RunningDockerExecutor

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

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

Execute a command in the executor

fn stream_files<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, extensions: Option<Vec<String>>, ) -> Pin<Box<dyn Future<Output = Result<IndexingStream>> + Send + 'async_trait>>

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

Stream files from the executor