Trait ExecutableItem 

pub trait ExecutableItem: Send + 'static {
    // Required method
    fn execute(&mut self, ctx: &mut Context<'_>) -> ExecuteResult;

    // Provided methods
    fn declare_triggers(
        &mut self,
        d: &mut TriggerDeclarer<'_>,
    ) -> Result<(), ExecutorError> { ... }
    fn task_id(&self) -> Option<&str> { ... }
    fn app_id(&self) -> Option<u32> { ... }
    fn app_instance_id(&self) -> Option<u32> { ... }
}

Trait implemented by every unit of work the executor schedules.

Implementors are moved into the executor and dispatched to pool workers. Send + 'static is required; Sync is not — the executor guarantees at most one thread at a time invokes execute on a given item.

Required Methods

fn execute(&mut self, ctx: &mut Context<'_>) -> ExecuteResult

Called by the executor when any declared trigger fires.

Provided Methods

fn declare_triggers( &mut self, d: &mut TriggerDeclarer<'_>, ) -> Result<(), ExecutorError>

Called once when the item is added to an executor. The implementor registers its trigger handles via the TriggerDeclarer.

fn task_id(&self) -> Option<&str>

Optional human-readable id used for monitor/observer correlation. None means “use the auto-assigned id”.

fn app_id(&self) -> Option<u32>

Optional application id; Some(_) enables Observer per-app callbacks.

fn app_instance_id(&self) -> Option<u32>

Optional application instance id.

Trait Implementations

impl ExecutableItem for Box<dyn ExecutableItem>

Allows Vec<Box<dyn ExecutableItem>> to be passed directly to crate::Executor::add_chain without a secondary wrapper.

fn declare_triggers( &mut self, d: &mut TriggerDeclarer<'_>, ) -> Result<(), ExecutorError>

Called once when the item is added to an executor. The implementor registers its trigger handles via the TriggerDeclarer.

fn execute(&mut self, ctx: &mut Context<'_>) -> ExecuteResult

Called by the executor when any declared trigger fires.

fn task_id(&self) -> Option<&str>

Optional human-readable id used for monitor/observer correlation. None means “use the auto-assigned id”.

fn app_id(&self) -> Option<u32>

Optional application id; Some(_) enables Observer per-app callbacks.

fn app_instance_id(&self) -> Option<u32>

Optional application instance id.

Implementations on Foreign Types

impl ExecutableItem for Box<dyn ExecutableItem>

Allows Vec<Box<dyn ExecutableItem>> to be passed directly to crate::Executor::add_chain without a secondary wrapper.

fn declare_triggers( &mut self, d: &mut TriggerDeclarer<'_>, ) -> Result<(), ExecutorError>

fn execute(&mut self, ctx: &mut Context<'_>) -> ExecuteResult

fn task_id(&self) -> Option<&str>

fn app_id(&self) -> Option<u32>

fn app_instance_id(&self) -> Option<u32>

Implementors

impl<D, E> ExecutableItem for FnItemWithTriggers<D, E>

where D: FnOnce(&mut TriggerDeclarer<'_>) -> Result<(), ExecutorError> + Send + 'static, E: FnMut(&mut Context<'_>) -> ExecuteResult + Send + 'static,

impl<F> ExecutableItem for FnItem<F>

where F: FnMut(&mut Context<'_>) -> ExecuteResult + Send + 'static,

impl<I, F> ExecutableItem for Conditional<I, F>

where I: ExecutableItem, F: FnMut() -> bool + Send + 'static,

impl<T: Payload + Default + Copy + Send> ExecutableItem for SignalItem<T>

impl<T: Payload + Copy + Send> ExecutableItem for SlotItem<T>