Struct WorkerRecord 

pub struct WorkerRecord {
    pub worker_rank: u32,
    pub backend_metadata: BackendMetadataRecord,
    pub tensors: Vec<TensorRecord>,
    pub status: i32,
    pub updated_at: i64,
    pub metadata_endpoint: String,
    pub agent_name: String,
    pub worker_grpc_endpoint: String,
}

Worker metadata record

Fields

worker_rank: u32

backend_metadata: BackendMetadataRecord

tensors: Vec<TensorRecord>

status: i32

Worker lifecycle status (maps to SourceStatus proto enum)

updated_at: i64

Timestamp of last status update (unix millis)

metadata_endpoint: String

P2P: NIXL listen thread endpoint (host:port)

agent_name: String

P2P: NIXL agent name for remote identification

worker_grpc_endpoint: String

P2P: Worker gRPC endpoint for tensor manifest (host:port)

Trait Implementations

impl Clone for WorkerRecord

fn clone(&self) -> WorkerRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerRecord

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

Formats the value using the given formatter.

impl From<WorkerMetadata> for WorkerRecord

fn from(meta: WorkerMetadata) -> Self

Converts to this type from the input type.

impl From<WorkerRecord> for WorkerMetadata

fn from(record: WorkerRecord) -> Self

Converts to this type from the input type.