Struct DaemonRegisterRequest 

pub struct DaemonRegisterRequest {
    pub machine_id: Option<String>,
    pub labels: BTreeMap<String, String>,
    pub zenoh_listen_endpoint: Option<String>,
    pub zenoh_loopback_listen_endpoint: Option<String>,
    /* private fields */
}

Fields

machine_id: Option<String>

labels: BTreeMap<String, String>

zenoh_listen_endpoint: Option<String>

The zenoh endpoint this daemon is about to bind, so the coordinator can hand it to daemons that register after this one.

Carried in the registration rather than reported once the session is open, and that timing is the whole point. The coordinator handles registrations one at a time on its event loop, so an endpoint that arrives with the registration is already on record before the next daemon’s reply is built — two daemons starting simultaneously are ordered by that loop and the later one always learns about the earlier. Reporting after the session opened instead left a window (register → listener bound) in which both daemons could register, each be handed a list without the other, and stay partitioned: zenoh reads connect/endpoints once at session open, so neither could act on the other’s later report.

The port is reserved before registering, so this is the endpoint the daemon will bind rather than one it has bound. A bind that then fails verification is withdrawn with DaemonEvent::zenoh_listen_endpoint(None) (both advertisement fields are None), so the coordinator stops handing out a dead listener.

None when the reservation failed or the listener is loopback. Keep loopback out of this field: 1.0.x coordinators forward it to every host.

zenoh_loopback_listen_endpoint: Option<String>

Loopback listener, advertised separately so 1.0.x coordinators ignore it. New coordinators hand it only to peers on the coordinator’s host. Missing means no loopback advertisement, as in 1.0.x.

Implementations

impl DaemonRegisterRequest

pub fn new(machine_id: Option<String>, labels: BTreeMap<String, String>) -> Self

pub fn with_zenoh_endpoint( machine_id: Option<String>, labels: BTreeMap<String, String>, zenoh_listen_endpoint: Option<String>, ) -> Self

Self::new plus the zenoh endpoint this daemon will bind; see Self::zenoh_listen_endpoint and Self::zenoh_loopback_listen_endpoint. Loopback listeners are placed only in the latter field.

pub fn supports_hub_sources(&self) -> bool

Whether the registering daemon can build/spawn hub-sourced git nodes (carrying subdir / hub provenance).

pub fn check_version(&self) -> Result<(), String>

Trait Implementations

impl Debug for DaemonRegisterRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DaemonRegisterRequest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DaemonRegisterRequest

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

where __S: Serializer,

Serialize this value into the given Serde serializer.