Skip to main content

RuntimeEffect

runx_runtime::effects

Trait RuntimeEffect 

Source 
pub trait RuntimeEffect: Send + Sync {

Show 13 methods    // Required method
    fn family(&self) -> &'static str;

    // Provided methods
    fn can_run_parallel(&self, step: &GraphStep) -> bool { ... }
    fn find_replay(
        &self,
        request: EffectStepRequest<'_>,
    ) -> Result<Option<EffectReplay>, RuntimeEffectError> { ... }
    fn recover_pending(
        &self,
        request: EffectStepRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn admit(
        &self,
        request: EffectStepRequest<'_>,
    ) -> Result<Option<EffectAdmission>, RuntimeEffectError> { ... }
    fn prepare_output(
        &self,
        request: EffectOutputRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn finalize_output(
        &self,
        request: EffectReceiptRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn persist(
        &self,
        request: EffectReceiptRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn prepare_replay_output(
        &self,
        request: EffectReplayOutputRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn validate_replay(
        &self,
        request: EffectReplayReceiptRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn refresh_output_metadata(
        &self,
        request: EffectMetadataRefreshRequest<'_>,
    ) -> Result<(), RuntimeEffectError> { ... }
    fn authority_grant_refs(
        &self,
        admission: &EffectAdmission,
    ) -> Result<Vec<Reference>, RuntimeEffectError> { ... }
    fn replay_authority_grant_refs(
        &self,
        replay: &EffectReplay,
    ) -> Result<Vec<Reference>, RuntimeEffectError> { ... }

}

Required Methods§

Source

fn family(&self) -> &'static str

Provided Methods§

Source

fn can_run_parallel(&self, step: &GraphStep) -> bool

Source

fn find_replay( &self, request: EffectStepRequest<'_>, ) -> Result<Option<EffectReplay>, RuntimeEffectError>

Source

fn recover_pending( &self, request: EffectStepRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn admit( &self, request: EffectStepRequest<'_>, ) -> Result<Option<EffectAdmission>, RuntimeEffectError>

Source

fn prepare_output( &self, request: EffectOutputRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn finalize_output( &self, request: EffectReceiptRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn persist( &self, request: EffectReceiptRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn prepare_replay_output( &self, request: EffectReplayOutputRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn validate_replay( &self, request: EffectReplayReceiptRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn refresh_output_metadata( &self, request: EffectMetadataRefreshRequest<'_>, ) -> Result<(), RuntimeEffectError>

Source

fn authority_grant_refs( &self, admission: &EffectAdmission, ) -> Result<Vec<Reference>, RuntimeEffectError>

Source

fn replay_authority_grant_refs( &self, replay: &EffectReplay, ) -> Result<Vec<Reference>, RuntimeEffectError>

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§