Struct GovernedFetch 

pub struct GovernedFetch { /* private fields */ }

The effect used internally by StepCtx::fetch_media.

Trait Implementations

impl Clone for GovernedFetch

fn clone(&self) -> GovernedFetch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GovernedFetch

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

Formats the value using the given formatter.

impl Effect for GovernedFetch

type Output = FetchedMedia

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 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 output_sensitivity(&self) -> Sensitivity

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

fn trust(&self) -> Trust

How much this effect’s output may be trusted.

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

The exact value this effect will send to its sink.

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

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

fn perform<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<FetchedMedia, 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 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 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.