Struct NativePlugin 

pub struct NativePlugin { /* private fields */ }

A loaded native plugin that can be called via FFI.

The plugin is automatically shut down when dropped.

Implementations

impl NativePlugin

pub fn call(&self, type_tag: &str, request: &str) -> ConsumerResult<String>

Make a JSON call to the plugin.

Arguments

• type_tag - Message type identifier (e.g., “echo”, “user.create”)
• request - JSON request payload as a string

Returns

The JSON response payload as a string, or an error.

Example

let response = plugin.call("echo", r#"{"message": "Hello"}"#)?;

pub fn call_typed<Req, Res>( &self, type_tag: &str, request: &Req, ) -> ConsumerResult<Res>

where Req: Serialize, Res: DeserializeOwned,

Make a typed call to the plugin with automatic serialization.

Arguments

• type_tag - Message type identifier
• request - Request value to serialize to JSON

Returns

The deserialized response, or an error.

Example

#[derive(Serialize)]
struct EchoRequest { message: String }

#[derive(Deserialize)]
struct EchoResponse { message: String, length: usize }

let response: EchoResponse = plugin.call_typed("echo", &EchoRequest {
    message: "Hello".to_string(),
})?;

pub fn call_raw( &self, message_id: u32, request: &[u8], ) -> ConsumerResult<Vec<u8>>

Make a binary call to the plugin.

This is used for high-performance binary transport.

Arguments

• message_id - Numeric message identifier
• request - Raw request bytes

Returns

The raw response bytes, or an error.

Errors

Returns ConsumerError::MissingSymbol if binary transport is not available.

pub fn state(&self) -> LifecycleState

Get the current lifecycle state of the plugin.

pub fn rejected_request_count(&self) -> u64

Get the number of requests rejected due to concurrency limits.

pub fn has_binary_transport(&self) -> bool

Check if binary transport is available.

pub fn set_log_level(&self, level: LogLevel)

Set the log level for the plugin.

pub fn shutdown(&self) -> ConsumerResult<()>

Shutdown the plugin gracefully.

This is called automatically when the plugin is dropped, but can be called explicitly to handle shutdown errors.

Trait Implementations

impl Drop for NativePlugin

fn drop(&mut self)

Executes the destructor for this type.

impl Send for NativePlugin

impl Sync for NativePlugin