Struct HostBridgeHandle 

pub struct HostBridgeHandle { /* private fields */ }

Handle for interacting with a specific host bridge node.

Implementations

impl HostBridgeHandle

pub fn push( &self, port: impl AsRef<str>, payload: EdgePayload, correlation_id: Option<u64>, ) -> u64

Push a payload for a given output port on the bridge (host -> graph).

pub fn push_any<T: Any + Send + Sync + 'static>( &self, port: impl AsRef<str>, value: T, ) -> u64

Push any typed payload (auto-wrapped).

pub fn push_serialized( &self, port: impl AsRef<str>, payload: HostBridgeSerialized, correlation_id: Option<u64>, ) -> Result<u64, NodeError>

Push a serialized payload, decoding it into a runtime payload first.

pub async fn recv(&self, port: impl AsRef<str>) -> Option<CorrelatedPayload>

Async wait for the next payload on a port.

pub async fn recv_serialized( &self, port: impl AsRef<str>, ) -> Result<Option<HostBridgeSerializedPayload>, NodeError>

Async wait for the next payload on a port and serialize it.

pub fn pull_any<T: Any + Clone>(&self, port: impl AsRef<str>) -> Option<T>

Pop and downcast a single payload from the outbound queue for a port.

pub fn try_pop(&self, port: impl AsRef<str>) -> Option<CorrelatedPayload>

Try to pop a single payload emitted by the graph on the given port.

pub fn try_pop_serialized( &self, port: impl AsRef<str>, ) -> Result<Option<HostBridgeSerializedPayload>, NodeError>

Try to pop and serialize a single payload emitted by the graph.

pub fn drain(&self, port: impl AsRef<str>) -> Vec<CorrelatedPayload>

Drain all pending payloads for the given port.

pub fn drain_serialized( &self, port: impl AsRef<str>, ) -> Result<Vec<HostBridgeSerializedPayload>, NodeError>

Drain and serialize all pending payloads for the given port.

pub fn ports(&self) -> impl Iterator<Item = &str>

Ports supported by this bridge (outgoing from host into the graph).

pub fn outgoing_ports(&self) -> impl Iterator<Item = &str>

Alias for ports() to make direction explicit (host -> graph).

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

Return a snapshot of known graph->host port names.

This uses both:

• inferred port types from the planner (preferred)
• any ports that have appeared in the outbound queues

pub fn incoming_ports(&self) -> HostPortOwnedIter<'_>

Iterate all known graph->host ports as HostPortOwned values.

This is the ergonomic path for host consumers:

for port in host.incoming_ports().filter(|p| p.can_type_to::<Value>()) {
  if let Some((_corr, value)) = port.try_pop::<Value>()? { /* ... */ }
}

pub fn iter_ports<'a>(&'a self, ports: &'a [String]) -> HostPorts<'a>

Iterate over a provided list of graph->host port names as “typed ports” that can be filtered and popped in an idiomatic Rust style.

pub fn alias(&self) -> &str

Returns the node alias associated with this bridge.

pub fn outgoing_port_type(&self, port: impl AsRef<str>) -> Option<&TypeExpr>

pub fn incoming_port_type(&self, port: impl AsRef<str>) -> Option<&TypeExpr>

pub fn try_pop_value( &self, port: impl AsRef<str>, ) -> Result<Option<(u64, Value)>, NodeError>

Try to pop a single payload for port and decode it into a Value when possible, without going through JSON string serialization.

This is intended for “non-image” / structured outputs that hosts want to sample cheaply. If the payload is not value-like (e.g. an image payload stored in Any), this returns an error.

pub fn drain_values( &self, port: impl AsRef<str>, ) -> Result<Vec<(u64, Value)>, NodeError>

Drain all pending payloads for port, decoding each into a Value when possible.

Any payload that cannot be represented as a Value produces an error.

Trait Implementations

impl Clone for HostBridgeHandle

fn clone(&self) -> HostBridgeHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.