Struct InferHub 

pub struct InferHub { /* private fields */ }

Adverts, forwarded requests and their responses between peers.

Implementations

impl InferHub

pub fn new( rt: Arc<MeshRuntime>, upstream: Arc<Upstream>, gate: Arc<ServeGate>, audit: Option<Arc<dyn ProxyAudit>>, ) -> Arc<Self>

A hub over rt. Call attach with the table built around it, then install.

pub fn attach(&self, table: Arc<PlacementTable>)

The placement table this hub serves and feeds.

pub fn install(self: &Arc<Self>)

Register as the runtime’s control sink for INFER_TOPIC, and forget a peer’s standing when it leaves.

pub fn set_max_pending(&self, n: usize)

Cap on exchanges in flight (default 256).

pub async fn announce(&self, now_secs: u64)

Send this node’s adverts for every exposed role to each connected peer that is allowed to use it and qualifies. Called periodically; receivers expire adverts they stop hearing.

pub fn qualifying_peers(&self) -> Vec<String>

Peers this node currently holds a qualifying grant for.

Trait Implementations

impl MeshDialer for InferHub

fn standing(&self, node_id: &str) -> Option<Grant>

The admission grant of the connected peer node_id, if any.

fn dial<'life0, 'life1, 'async_trait>( &'life0 self, node_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn MeshStream>, ProxyError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

An authenticated stream to the peer.

fn is_admitted(&self, node_id: &str) -> bool

Whether node_id is an enforced-admission full node with a trusted scope right now.

impl PeerControlSink for InferHub

fn on_peer_control( &self, ctx: &PeerCtx, conn: u64, payload: &Value, ) -> Vec<Value>

Handle one control payload from ctx.peer_id; return replies.