Struct Embed 

pub struct Embed { /* private fields */ }

Turning text into a vector, as an observation rather than a computation.

An embedding service does not promise the same floats for the same text — batching, hardware and an unannounced model revision each move the last bits. The vector then enters SemanticRecall’s key, so a run that computed one outside the protocol would derive a different key on replay and quarantine itself, with nothing on the record saying why.

Journaling it makes the vector history rather than a recomputation, puts the revision that produced it beside it, and meters the call like any other.

Trait Implementations

impl Clone for Embed

fn clone(&self) -> Embed

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Embed

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

Formats the value using the given formatter.

impl Effect for Embed

type Output = Vec<f32>

What comes back. Must round-trip through JSON: replay reconstructs it from the journal rather than from the driver.

fn descriptor(&self) -> EffectDescriptor

What this effect does. Hashed (with position) into the effect key.

fn mutates(&self) -> bool

Whether this mutates external state.

fn recovery(&self) -> Recovery

What to do when the outcome is unknown — after a crash, or after an InDoubt failure. The two are the same situation reached from different directions.

fn sink_arguments(&self) -> Option<&Value>

The exact value this effect will send to its sink.

fn perform<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, EffectError>> + Send + 'async_trait>>

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

Do the thing. Called at most once per key per run; never called during replay.

fn attach(&mut self, _provenance: &Provenance)

Receive the run-scoped provenance for this call.

fn gen_ai_operation(&self) -> Option<&'static str>

Which OpenTelemetry GenAI operation this effect is, if it is one.

fn retry(&self) -> RetryPolicy

How many times to repeat this effect when it fails, and how far apart.

fn max_sensitivity(&self) -> Sensitivity

The highest data sensitivity this sink may receive.

fn protected_fields(&self) -> &[ProtectedField]

Field-specific source and sensitivity rules for a structured sink.

fn delegation_depth(&self) -> Option<usize>

The resulting delegation depth when this effect hands authority onward.

fn source(&self) -> SourceId

The provenance identity an untrusted result of this effect carries.

fn trust(&self) -> Trust

How much this effect’s output may be trusted.

fn output_sensitivity(&self) -> Sensitivity

How sensitive this effect’s output is, at minimum.

fn spend(&self, _output: &Self::Output) -> Spend

What this effect consumed.

fn reconcile<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Reconciliation<Self::Output>, EffectError>> + Send + 'async_trait>>

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

Ask the provider whether a call landed.