Struct NativeBackend 

pub struct NativeBackend { /* private fields */ }

Native backend using FFI to libstdio_bus

Implementations

impl NativeBackend

pub fn new(config_path: &str) -> Result<Self>

Create from a file path (legacy)

pub fn from_config_source(source: &ConfigSource) -> Result<Self>

Create from a ConfigSource (primary)

Trait Implementations

impl Backend for NativeBackend

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Start the backend

fn stop<'life0, 'async_trait>( &'life0 self, timeout_secs: u32, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stop the backend gracefully

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

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

Send a message to workers

fn state(&self) -> BusState

Get current state

fn stats(&self) -> BusStats

Get statistics

fn worker_count(&self) -> i32

Get number of running workers (-1 if unknown)

fn client_count(&self) -> i32

Get number of connected clients (-1 if unknown)

fn subscribe(&self) -> Option<Receiver<BusMessage>>

Subscribe to incoming messages.

fn backend_type(&self) -> &'static str

Get backend type name

impl Drop for NativeBackend

fn drop(&mut self)

Executes the destructor for this type.