Struct MockPlugin 

pub struct MockPlugin {
    pub plugin_name: String,
    pub received: Arc<Mutex<Vec<Command>>>,
    pub response: Response,
    pub started: Arc<AtomicBool>,
    pub stopped: Arc<AtomicBool>,
}

Fields

plugin_name: String

received: Arc<Mutex<Vec<Command>>>

response: Response

started: Arc<AtomicBool>

stopped: Arc<AtomicBool>

Implementations

impl MockPlugin

pub fn new(name: impl Into<String>) -> Self

pub fn with_response(name: impl Into<String>, response: Response) -> Self

Trait Implementations

impl Plugin for MockPlugin

fn name(&self) -> &str

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

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

Subscribe to plugin.outbound.{name} and start publishing to plugin.inbound.{name}.

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

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

Release resources and stop publishing events.

fn send_command<'life0, 'async_trait>( &'life0 self, cmd: Command, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

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

Send a command directly and await a response.