Struct ResolveOp 

pub struct ResolveOp {
    pub from: String,
    pub via: Option<String>,
    pub direction: String,
    pub output_var: String,
}

Compiled resolve operator

Fields

from: String

Field name in context to read the entity ID from

via: Option<String>

Optional link type to follow (None = direct ID resolution)

direction: String

Direction: “forward” or “reverse”

output_var: String

Variable name to store the resolved entity

Implementations

impl ResolveOp

pub fn from_config(config: &ResolveConfig) -> Self

Create a ResolveOp from a ResolveConfig

Trait Implementations

impl Clone for ResolveOp

fn clone(&self) -> ResolveOp

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResolveOp

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

Formats the value using the given formatter.

impl PipelineOperator for ResolveOp

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut FlowContext, ) -> Pin<Box<dyn Future<Output = Result<OpResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute this operator on the given context

fn name(&self) -> &str

Human-readable name for logging/debugging