Struct DockerBackend 

pub struct DockerBackend { /* private fields */ }

Docker backend implementation

Implementations

impl DockerBackend

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

Create a new Docker backend

Trait Implementations

impl Backend for DockerBackend

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