Struct Hub 

pub struct Hub { /* private fields */ }

Implementations

impl Hub

pub fn with_m4a(self, m4a: Box<dyn M4a>) -> Self

Talk to sessions over m4a with this gateway (wake + run.close reader).

pub fn m4a_enabled(&self) -> bool

pub fn poll_m4a(&self) -> usize

Read run.close letters from the sessions of active runs. Each letter is handled once (op id m4a:<event_id>). Returns how many runs were closed.

pub fn recommend(&self, role: &str) -> Result<Value, HubError>

Routing recommendation for role (operator API and node door).

pub fn open(data_dir: &Path) -> Result<Self, ServerError>

pub fn node_call( &self, node_id: &str, op: &str, payload: &Value, ) -> Result<Value, HubError>

A call made on behalf of a node. The caller (C2) has authenticated the node and checked its policy; the hub checks the ledger again, independently.

pub fn operator_call( &self, method: &str, path: &str, body: &Value, ) -> Result<Value, HubError>

Operator (HQ) calls, authenticated by the control bearer in the HTTP layer.