Struct RemoteQueryRequest 

pub struct RemoteQueryRequest { /* private fields */ }

One complete remote invocation of a reusable validated plan.

Implementations

impl RemoteQueryRequest

pub fn new( plan: &QueryPlan, invocation: &QueryInvocation, advertisement: &RemoteCapabilities, limits: RemoteLimits, nonce: impl Into<String>, prepared_at_unix_ms: u64, ) -> Result<Self, Diagnostic>

Bind one plan invocation and caller budgets into a request envelope.

pub fn encode(&self) -> Result<Vec<u8>, Diagnostic>

Encode exact canonical envelope bytes.

pub fn decode(bytes: &[u8]) -> Result<Self, Diagnostic>

Decode one request envelope, rejecting unknown fields and formats.

pub fn plan(&self) -> Result<QueryPlan, Diagnostic>

Rebuild the trusted plan from the embedded canonical document.

The embedded tree re-encodes to exact canonical bytes and runs the full plan wire decoder, so every structural plan check applies to remote plans exactly as it does to local ones.

pub fn invocation( &self, plan: &QueryPlan, ) -> Result<QueryInvocation, Diagnostic>

Rebuild the validated invocation against the carried plan.

pub const fn limits(&self) -> RemoteLimits

Return the caller budgets.

pub fn nonce(&self) -> &str

Return the caller nonce echoed by the response.

pub fn binds_advertisement( &self, advertisement: &RemoteCapabilities, ) -> Result<bool, Diagnostic>

Return whether this request binds the executor’s exact advertisement.

pub fn remaining_lifetime_ms(&self, now_unix_ms: u64) -> Result<u64, Diagnostic>

Validate this request’s absolute lifetime at one executor clock sample.

Clients at most MAX_REMOTE_CLOCK_SKEW_MS ahead are accepted. The expiry itself is exclusive: a request at or beyond it is rejected. The returned duration reaches the absolute expiry and is the replay retention horizon. It can exceed the declared execution duration by the admitted positive clock skew; use Self::remaining_execution_ms to bound execution itself.

pub fn remaining_execution_ms( &self, now_unix_ms: u64, ) -> Result<u64, Diagnostic>

Return the remaining execution duration without granting clock skew.

Positive skew can place absolute expiry later than now + declared duration. Execution therefore uses the smaller of the absolute remaining horizon and the fingerprint-bound declared lifetime, while replay retention continues through the full absolute horizon.

pub const fn expires_at_unix_ms(&self) -> u64

Return the request’s exclusive absolute expiry timestamp.

Trait Implementations

impl Clone for RemoteQueryRequest

fn clone(&self) -> RemoteQueryRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RemoteQueryRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RemoteQueryRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RemoteQueryRequest

fn eq(&self, other: &RemoteQueryRequest) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for RemoteQueryRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RemoteQueryRequest