Struct RecallMemory 

pub struct RecallMemory { /* private fields */ }

Recalling memories, as an effect.

Journaled because memory is mutable state outside the chain: a lookup done inside the deterministic zone would make a replayed run retrieve whatever the store holds now, reach different conclusions, and produce a history that disagrees with itself.

The output is the selection — ids, versions and content digests — and not the content. Two reasons, and both matter. Personal data must not enter a hash chain that cannot be redacted; and pinning versions means a replay re-materialises exactly what was read rather than re-running a ranking that drifts as the corpus grows.

Trait Implementations

impl Clone for RecallMemory

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecallMemory

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

Formats the value using the given formatter.

impl Effect for RecallMemory

fn trust(&self) -> Trust

Trusted: this plane’s own store, not the world’s.

The contents are another matter entirely, and the caller receives them labelled from each item’s declared provenance — see StepCtx::recall.

type Output = Vec<Selected>

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 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 gen_ai_request(&self) -> Option<GenAiRequest>

Who this operation asks, and for what — the request half of the GenAI span attributes.

fn gen_ai_response(&self, output: &Self::Output) -> Option<GenAiResponse>

What came back, split the way the convention reports it.

fn retry(&self) -> RetryPolicy

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

fn retries_landed(&self) -> bool

Whether a failure that landed may be tried again, within retry.

fn max_sensitivity(&self) -> Sensitivity

The highest data sensitivity this sink may receive.

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

The exact value this effect will send to its sink.

fn rebind(&mut self, _arguments: Value) -> bool

Bind arguments in place of the ones this effect was built over, where it can — what a declared redaction at a sink needs.

fn outbound_bytes(&self) -> u64

How many bytes dispatching this effect sends out of the plane.

fn credential_binding(&self) -> Option<CredentialBinding>

Whom the credential this effect presents names, for an effect that presents one to another party.

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