Struct DataRef 

pub struct DataRef {
    pub input: String,
    pub uri: String,
    pub elem: usize,
    pub shard_start: usize,
    pub shard_len: usize,
}

One data tensor the worker feeds to a graph input every step. Resolved node-locally from uri (a file:// raw-f32 blob, or gguf/safetensors), then row-sharded: this rank owns samples [shard_start, shard_start+len), each elem floats wide.

Fields

input: String

Graph input node name this tensor feeds (e.g. "x", "labels").

uri: String

Where the full (unsharded) tensor lives — resolved on the worker.

elem: usize

Per-sample element count (row stride into the resolved flat array).

shard_start: usize

First sample index of this rank’s shard.

shard_len: usize

Number of samples in this rank’s shard.

Trait Implementations

impl Clone for DataRef

fn clone(&self) -> DataRef

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataRef

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DataRef

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DataRef

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

where __S: Serializer,

Serialize this value into the given Serde serializer.