Struct EffectExecutor 

pub struct EffectExecutor { /* private fields */ }

Capability-gated write-ahead external-effect coordinator.

Implementations

impl EffectExecutor

pub fn new(store: Arc<dyn EffectStore>) -> Self

Creates an executor using the given durable-state boundary.

pub const fn with_event_payload_policy( self, policy: EffectEventPayloadPolicy, ) -> Self

Sets explicit Journal output-capture behavior.

pub async fn execute( &self, request: EffectRequest, run: &RunContext, handler: &dyn EffectHandler, recovery: EffectRecoveryPolicy, ) -> Result<EffectOutcome, EffectExecutorError>

Executes or recovers one logical effect.

Errors

Returns EffectExecutorError for authority, persistence, lifecycle, ambiguity, handler, or observability failures.

Trait Implementations

impl Clone for EffectExecutor

fn clone(&self) -> EffectExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EffectExecutor

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

Formats the value using the given formatter.