malbox_plugin_sdk::runtime::guest::stream

Struct TaskExecution

pub(super) struct TaskExecution {
    pub task_id: i32,
    pub sample_path: PathBuf,
    pub config: HashMap<String, String>,
    pub result_tx: ResultSender,
    pub proto_tx: Sender<Result<TaskResult, Status>>,
    pub stash: Arc<ResultStash>,
    pub artifact_dir: PathBuf,
    pub external_log_dir: PathBuf,
    pub auto_collect_artifacts: AutoCollectSection,
    pub auto_collect_external_logs: AutoCollectSection,
    pub default_timeout: u64,
}

Expand description

All parameters for a single guest task execution (everything except the generic plugin instance).

Fields§

§task_id: i32§sample_path: PathBuf§config: HashMap<String, String>§result_tx: ResultSender§proto_tx: Sender<Result<TaskResult, Status>>§stash: Arc<ResultStash>§artifact_dir: PathBuf§external_log_dir: PathBuf§auto_collect_artifacts: AutoCollectSection§auto_collect_external_logs: AutoCollectSection§default_timeout: u64

Auto Trait Implementations§

§

TaskExecution

Struct TaskExecution Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for TaskExecution

impl RefUnwindSafe for TaskExecution

impl Send for TaskExecution

impl Sync for TaskExecution

impl Unpin for TaskExecution

impl UnsafeUnpin for TaskExecution

impl UnwindSafe for TaskExecution

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct TaskExecution

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,