Struct HttpEndpointRegistry 

pub struct HttpEndpointRegistry { /* private fields */ }

Thread-safe map of BackendId → Option<u16> per the design in #483 §2.

None means the backend exists but has not yet reported a port (its HTTP server hasn’t bound). Some(port) means it has, and the aggregator iframe can resolve a URL.

Implementations

impl HttpEndpointRegistry

pub fn new() -> Self

Create an empty registry.

pub fn track(&self, backend_id: BackendId)

Mark backend_id as tracked with no port yet.

pub fn register_backend_http_endpoint( &self, backend_id: BackendId, port: u16, ) -> Option<u16>

Record that backend_id’s HTTP server has bound port.

Inserts the backend if it wasn’t already tracked. Returns the previous port for that backend if any.

pub fn lookup(&self, backend_id: &str) -> Option<u16>

Look up the port for backend_id, if any.

Returns None both when the backend is untracked AND when it is tracked but hasn’t reported a port yet — the aggregator uses the broader state() API below when it needs the distinction.

pub fn state(&self, backend_id: &str) -> Option<Option<u16>>

Get the current state for backend_id.

Some(Some(port)) = registered + bound. Some(None) = tracked but starting. None = untracked.

pub fn snapshot(&self) -> Vec<(BackendId, Option<u16>)>

Snapshot of all currently-tracked backends and their state. Used by the aggregator selector and by tests.

Trait Implementations

impl Debug for HttpEndpointRegistry

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

Formats the value using the given formatter.

impl Default for HttpEndpointRegistry

fn default() -> HttpEndpointRegistry

Returns the “default value” for a type.