Struct RuntimeStreamLeaseScope 

pub struct RuntimeStreamLeaseScope {
    pub task_id: Option<RuntimeTaskId>,
    pub source_worker_id: Option<RuntimeWorkerId>,
    pub gpu_job_id: Option<RuntimeJobId>,
    pub gpu_worker_id: Option<RuntimeWorkerId>,
    /* private fields */
}

Explicit correlation available when a service-stream lease is acquired.

Callers compose this value at execution boundaries; stream acquisition does not consult thread-local or task-local ambient state.

Fields

task_id: Option<RuntimeTaskId>

Associated compiled task, or None when acquisition has no task binding.

source_worker_id: Option<RuntimeWorkerId>

Source worker requesting the stream, or None outside source work.

gpu_job_id: Option<RuntimeJobId>

GPU executor job requesting the stream, or None outside a job.

gpu_worker_id: Option<RuntimeWorkerId>

GPU executor worker requesting the stream, or None when unavailable.

Implementations

impl RuntimeStreamLeaseScope

pub fn for_plan(plan_execution_id: PlanExecutionId) -> Self

Creates a lease scope bound to one plan invocation with no worker or task correlation.

Trait Implementations

impl Clone for RuntimeStreamLeaseScope

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeStreamLeaseScope

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

Formats the value using the given formatter.

impl Default for RuntimeStreamLeaseScope

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RuntimeStreamLeaseScope

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RuntimeStreamLeaseScope

impl PartialEq for RuntimeStreamLeaseScope

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RuntimeStreamLeaseScope

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 RuntimeStreamLeaseScope