Struct ExchangeParams 

pub struct ExchangeParams<'a> {

    pub executor: &'a Handle,
    pub transaction_id: TransactionId,
    pub connector: &'a dyn Connector,
    pub encoder: &'a dyn OutboundDialectEncoder,
    pub interpreter: &'a dyn InterpreterFactory,
    pub endpoint_ref: &'a str,
    pub credential_ref: Option<&'a str>,
    pub session_attachment: Option<Arc<SessionAttachment>>,
    pub input: &'a CanonicalInput,
    pub config: &'a EffectiveConfig,
    pub tools: &'a [ToolSpec],
    pub interpretation_limits: InterpretationLimits,
    pub deadline: Duration,
    pub cleanup_deadline: Duration,
    pub max_encoded_exchange_bytes: usize,
    pub unit_tx: Option<Sender<CanonicalUnitEvent>>,
    pub session_id_tx: Option<Sender<ExternalSessionId>>,
}

Parameters for running one exchange.

Fields

executor: &'a Handle

Injected Tokio handle for owned exchange children (D-032).

transaction_id: TransactionId

Transaction id.

connector: &'a dyn Connector

Connector instance.

encoder: &'a dyn OutboundDialectEncoder

Encoder.

interpreter: &'a dyn InterpreterFactory

Interpreter factory.

endpoint_ref: &'a str

Endpoint ref.

credential_ref: Option<&'a str>

Credential ref.

session_attachment: Option<Arc<SessionAttachment>>

Optional session attachment.

input: &'a CanonicalInput

Canonical input.

config: &'a EffectiveConfig

Effective config.

tools: &'a [ToolSpec]

Tool specs for encoder.

interpretation_limits: InterpretationLimits

Interpretation limits.

deadline: Duration

Overall deadline for the exchange.

cleanup_deadline: Duration

Join/abort grace for exchange children after cancel or terminal (D-012).

max_encoded_exchange_bytes: usize

Channel max encoded body size (D-015).

unit_tx: Option<Sender<CanonicalUnitEvent>>

Optional live unit sink (D-011); when set, units are forwarded as produced.

session_id_tx: Option<Sender<ExternalSessionId>>

Optional oneshot: authoritative external session id immediately after open (D-013).