Struct NodeInfo 

pub struct NodeInfo {
    pub node_id: u64,
    pub addr: String,
    pub state: NodeState,
    pub raft_groups: Vec<u64>,
    pub wire_version: u16,
    pub spiffe_id: Option<String>,
    pub spki_pin: Option<[u8; 32]>,
}

Information about a single node in the cluster.

Fields

node_id: u64

addr: String

Listen address for Raft RPCs (as string for serialization portability).

state: NodeState

raft_groups: Vec<u64>

Raft groups hosted on this node.

wire_version: u16

Wire format version this node is running. Stamped by the node itself on self-registration (bootstrap / join) and by handle_join when learning about a remote joiner. Read by control::rolling_upgrade::view::compute to derive the cluster-wide min/max/mixed view on demand from the live topology.

spiffe_id: Option<String>

SPIFFE URI SAN (e.g. spiffe://cluster.local/node/1) extracted from the node’s mTLS leaf certificate at join time. None for nodes that joined before SPIFFE identity was introduced or that are running in insecure transport mode.

spki_pin: Option<[u8; 32]>

SHA-256 digest of the node’s SubjectPublicKeyInfo DER blob, pinned at join time. Stable across cert renewals that reuse the same key-pair; changes on key rotation. None until the node has joined and transmitted its identity fields.

Implementations

impl NodeInfo

pub fn new(node_id: u64, addr: SocketAddr, state: NodeState) -> Self

Construct a NodeInfo stamped with this build’s wire version. Use NodeInfo::with_wire_version when stamping a remote node whose version arrived over the wire.

pub fn with_wire_version(self, wire_version: u16) -> Self

Override the wire version on an otherwise-fresh NodeInfo. Builder-style so call sites read as NodeInfo::new(id, addr, state).with_wire_version(remote_v).

pub fn with_spiffe_id(self, spiffe_id: Option<String>) -> Self

Set the SPIFFE URI SAN for this node. Builder-style.

pub fn with_spki_pin(self, spki_pin: Option<[u8; 32]>) -> Self

Set the SPKI fingerprint pin for this node. Builder-style.

pub fn socket_addr(&self) -> Option<SocketAddr>

Trait Implementations

impl Clone for NodeInfo

fn clone(&self) -> NodeInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeInfo

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeInfo

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for NodeInfo

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl Serialize for NodeInfo

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToMessagePack for NodeInfo

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.