Struct EngineContext

Source

pub struct EngineContext {
    pub process_store: Option<Arc<dyn ProcessInstanceStore>>,
    pub token_store: Option<Arc<dyn TokenStore>>,
    pub process_def_store: Option<Arc<dyn ProcessDefinitionStore>>,
    pub parallel_join_repo: Option<Arc<dyn ParallelJoinRepo>>,
    pub timer_store: Option<Arc<dyn TimerStore>>,
    pub compensation_repo: Option<Arc<dyn CompensationRecordRepo>>,
    pub outbox_repo: Option<Arc<dyn OutboxRepo>>,
    pub external_task_store: Option<Arc<dyn ExternalTaskStore>>,
    pub history_repo: Option<Arc<dyn HistoryRepo>>,
    pub tenant_id: Option<String>,
}

Expand description

Design: handler.md §6 — execution environment for handlers (stores from storage).

Fields§

§process_store: Option<Arc<dyn ProcessInstanceStore>>§token_store: Option<Arc<dyn TokenStore>>§process_def_store: Option<Arc<dyn ProcessDefinitionStore>>§parallel_join_repo: Option<Arc<dyn ParallelJoinRepo>>§timer_store: Option<Arc<dyn TimerStore>>§compensation_repo: Option<Arc<dyn CompensationRecordRepo>>§outbox_repo: Option<Arc<dyn OutboxRepo>>§external_task_store: Option<Arc<dyn ExternalTaskStore>>§history_repo: Option<Arc<dyn HistoryRepo>>§tenant_id: Option<String>

EngineContext

Struct EngineContext Copy item path

Fields§

Trait Implementations§

impl Default for EngineContext

fn default() -> EngineContext

Auto Trait Implementations§

impl !RefUnwindSafe for EngineContext

impl !UnwindSafe for EngineContext

impl Freeze for EngineContext

impl Send for EngineContext

impl Sync for EngineContext

impl Unpin for EngineContext

impl UnsafeUnpin for EngineContext

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, 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 EngineContext

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>,

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>,