Struct PluginHandle 

pub struct PluginHandle { /* private fields */ }

A handle to a specific plugin for making calls.

Implementations

impl PluginHandle

pub async fn call_response( &self, entry: &str, payload: &[u8], ) -> Result<(NrStatus, Vec<u8>)>

Call a plugin entry point with a request-response pattern.

pub async fn call_response_timeout( &self, entry: &str, payload: &[u8], timeout: Duration, ) -> Result<(NrStatus, Vec<u8>)>

Like PluginHandle::call_response but bounded by a timeout.

If the plugin does not deliver a response within timeout, the pending entry is removed from the host’s tracking map and Err(Timeout) is returned. Use this for any production caller that cannot afford to hang indefinitely on a misbehaving plugin.

pub async fn call_response_fast( &self, entry: &str, payload: &[u8], ) -> Result<(NrStatus, Vec<u8>)>

Ultra-fast unary call for synchronous plugins.

pub async fn call(&self, entry: &str, payload: &[u8]) -> Result<NrStatus>

Fire-and-forget call to a plugin entry point.

pub async fn call_stream( &self, entry: &str, payload: &[u8], ) -> Result<(u64, StreamReceiver)>

Call a plugin entry point with a streaming response pattern.

pub fn send_stream_data(&self, sid: u64, data: &[u8]) -> Result<NrStatus>

Send data to an active stream.

pub fn close_stream(&self, sid: u64) -> Result<NrStatus>

Close an active stream from the host side.

Trait Implementations

impl Clone for PluginHandle

fn clone(&self) -> PluginHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.