Struct Node 

pub struct Node { /* private fields */ }

Implementations

impl Node

pub fn builder(node: &str) -> NodeBuilder

impl Node

pub async fn fetch_body( self: &Arc<Self>, request: Request<WireBody>, ) -> Result<Response<WireBody>, HandlerError>

pub async fn fetch( self: &Arc<Self>, request: Request<Bytes>, ) -> Result<Response<ServiceBody>, HandlerError>

pub async fn subscribe( self: &Arc<Self>, subject: &str, payload: Value, ) -> Result<EventStream, HandlerError>

pub async fn subscribe_with( self: &Arc<Self>, subject: &str, payload: Value, headers: Map<String, Value>, ) -> Result<EventStream, HandlerError>

pub async fn subscribe_bytes( self: &Arc<Self>, subject: &str, payload: Bytes, headers: Map<String, Value>, ) -> Result<EventStream, HandlerError>

impl Node

pub async fn connect( self: &Arc<Self>, endpoints: impl Into<EndpointSet>, ) -> Result<PeerConnection, ConnectError>

Eagerly dial, verify the peer, and synchronize its routes.

The returned logical connection is retained by the node and remains observable after transport loss. No automatic retry is started; call PeerConnection::reconnect from a caller-owned policy when desired.

pub async fn link(self: &Arc<Self>, other: &Arc<Node>) -> Result<(), WsError>

pub async fn connect_transport_unchecked( self: &Arc<Self>, transport: Pipe, ) -> Result<(), WsError>

Attach one caller-provided outbound transport without imposing an expected peer name. Browser bindings use this after JavaScript completes the platform dial.

impl Node

pub async fn discover_events( self: &Arc<Self>, detail: Detail, scope: Scope, ) -> Vec<DiscoverEvent>

impl Node

pub fn cancellation(&self) -> &CancellationToken

pub fn identity(&self) -> &NodeIdentity

pub fn shutdown(&self)

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

pub fn catalog_revision(&self) -> u64

pub fn local_catalog(&self, detail_full: bool) -> Value

pub async fn remove_subject(&self, subject: &str) -> Result<(), WsError>

pub async fn add_service(&self, handler: impl Handler) -> Result<(), WsError>

pub async fn remove_operation( &self, subject: &str, operation: Operation, ) -> Result<(), WsError>

impl Node

pub fn serve_ws_upgrade(self: &Arc<Self>, upgrade: WebSocketUpgrade) -> Response

pub async fn serve_webtransport( self: &Arc<Self>, connection: Connection, ) -> Result<Arc<Wire>, WsError>

pub async fn serve_transport(self: &Arc<Self>, transport: Pipe) -> Arc<Wire>

pub async fn connect_transport( self: &Arc<Self>, peer: &str, transport: Pipe, ) -> Result<Arc<Wire>, WsError>

impl Node

pub async fn start_topology( self: &Arc<Self>, config: TopologyConfig, ) -> Result<UnbTopology, WsError>

impl Node

pub fn host_unix_child( self: &Arc<Self>, path: impl AsRef<Path>, expected_child: impl Into<String>, ) -> Result<UnixHosting, WsError>

pub fn host_unix(self: &Arc<Self>, listener: UnixListener) -> UnixHosting

Trait Implementations

impl Drop for Node

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.