Struct McpTaskUpdate 

pub struct McpTaskUpdate { /* private fields */ }

Answers outstanding input requests on an MCP task.

Trait Implementations

impl Debug for McpTaskUpdate

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

Formats the value using the given formatter.

impl Effect for McpTaskUpdate

fn max_sensitivity(&self) -> Sensitivity

The operator’s ceiling for this server, as McpPrompt takes for a prompt’s arguments. Answering an elicitation sends data to the same server by the same connection, so a plane that may hand it internal data one way and not the other is drawing a line nobody outside could defend.

What this does not relax is the whole-value taint gate below it: tasks/update mutates, and it declares no protected fields, so an untrusted response is refused whatever this ceiling says. A model’s answer reaches an MCP server through a release or not at all.

type Output = ()

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<(), 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 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 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.