Struct StreamNode 

pub struct StreamNode {
    pub node_id: String,
    pub address: String,
    pub status: NodeStatus,
    pub assigned_partitions: usize,
    pub capacity: f64,
    pub last_heartbeat: SystemTime,
    pub weight: u32,
}

Metadata for a node participating in distributed stream processing

Fields

node_id: String

Unique identifier for this node

address: String

Network address of the node

status: NodeStatus

Current health status

assigned_partitions: usize

Number of partitions assigned to this node

capacity: f64

Processing capacity (0.0 to 1.0)

last_heartbeat: SystemTime

Timestamp of last heartbeat

weight: u32

Node weight for load balancing (higher = more load)

Implementations

impl StreamNode

pub fn new(node_id: impl Into<String>, address: impl Into<String>) -> Self

Creates a new healthy stream node

pub fn is_available(&self) -> bool

Returns true if this node can accept new partitions

Trait Implementations

impl Clone for StreamNode

fn clone(&self) -> StreamNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamNode

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamNode

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamNode

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

where __S: Serializer,

Serialize this value into the given Serde serializer.