pub struct UntrustedExecutionInputs { /* private fields */ }Expand description
Execution-owned transport, with at most one existing Inbox admission batch (128 records), each retaining only an ID and an I-W-bounded request. There is no whole-batch Clone/Arc or body/config/Source snapshot. This is not Q-B’s aggregate compact projection or its eventual current-input classification.
Implementations§
Source§impl UntrustedExecutionInputs
impl UntrustedExecutionInputs
pub fn new(observations: Vec<UntrustedInputObservation>) -> Option<Self>
Sourcepub fn sdk_execution_id(&self) -> Option<&str>
pub fn sdk_execution_id(&self) -> Option<&str>
Exact producer-reserved execution identity; generic carriers have none.
pub fn observations(&self) -> &[UntrustedInputObservation]
Sourcepub async fn admit_with_startup_observation(
session: &mut Session,
storage: Option<&Arc<dyn Storage>>,
persistence: Option<&Arc<dyn RuntimeSessionPersistence>>,
inbox: Option<&Arc<dyn SessionInboxPort>>,
) -> (TurnBoundaryRefresh, Option<Self>)
pub async fn admit_with_startup_observation( session: &mut Session, storage: Option<&Arc<dyn Storage>>, persistence: Option<&Arc<dyn RuntimeSessionPersistence>>, inbox: Option<&Arc<dyn SessionInboxPort>>, ) -> (TurnBoundaryRefresh, Option<Self>)
Additive checked boundary companion. Original public refresh layout stays unchanged; the caller still performs its original error/persist checks. An unavailable projection changes only this optional data handoff.
Sourcepub fn from_committed_messages(messages: &[Message]) -> Option<Self>
pub fn from_committed_messages(messages: &[Message]) -> Option<Self>
Caller supplies ONLY this call’s newly checkpointed messages, after its ACK/rejection checks. Never call this on stored Session history. The existing admission producer already checked their envelope proof.