Struct BackgroundRunner 

pub struct BackgroundRunner { /* private fields */ }

Implementations

impl BackgroundRunner

pub fn new( registry: TaskExecutorRegistry, config: BackgroundRunnerConfig, ) -> Self

pub fn subscribe(&self) -> Receiver<RoderEvent>

pub fn processes(&self) -> ProcessRegistry

pub async fn submit( &self, executor_id: impl Into<TaskExecutorId>, input: Value, options: TaskSubmitOptions, ) -> Result<TaskHandle>

pub async fn cancel( &self, task_id: &str, reason: Option<String>, ) -> Result<bool>

pub async fn list(&self) -> Vec<TaskHandle>

pub async fn get(&self, task_id: &str) -> Option<TaskHandle>

pub async fn logs(&self, task_id: &str) -> Option<(Vec<TaskLogEntry>, u64)>

pub async fn handle_event(&self, envelope: &EventEnvelope) -> Result<()>

Trait Implementations

impl Clone for BackgroundRunner

fn clone(&self) -> BackgroundRunner

Returns a duplicate of the value.

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

Performs copy-assignment from source.