Struct SimulatorEngine 

pub struct SimulatorEngine { /* private fields */ }

Simulator engine that manages all virtual devices.

Implementations

impl SimulatorEngine

pub fn new(config: EngineConfig) -> SimulatorEngine

Create a new simulator engine.

pub fn config(&self) -> &EngineConfig

Get the engine configuration.

pub fn state(&self) -> EngineState

Get the current engine state.

pub fn metrics(&self) -> &MetricsCollector

Get metrics collector.

pub fn subscribe(&self) -> Receiver<EngineEvent>

Subscribe to engine events.

pub fn device_count(&self) -> usize

Get device count.

pub fn point_count(&self) -> usize

Get total data points across all devices.

pub async fn add_device(&self, device: Box<dyn Device>) -> Result<(), Error>

Add a device to the engine.

pub async fn remove_device(&self, device_id: &str) -> Result<(), Error>

Remove a device from the engine.

pub fn device(&self, device_id: &str) -> Option<DeviceHandle>

Get device by ID.

pub fn list_devices(&self) -> Vec<DeviceInfo>

List all devices.

pub fn list_devices_by_protocol(&self, protocol: Protocol) -> Vec<DeviceInfo>

List devices by protocol.

pub async fn read_point( &self, device_id: &str, point_id: &str, ) -> Result<DataPoint, Error>

Read a data point.

pub async fn write_point( &self, device_id: &str, point_id: &str, value: Value, ) -> Result<(), Error>

Write a data point.

pub async fn start(&self) -> Result<(), Error>

Start the engine.

pub async fn stop(&self) -> Result<(), Error>

Stop the engine.

pub async fn tick(&self) -> Result<(), Error>

Process one tick (update all devices).

pub async fn run(&self) -> Result<(), Error>

Run the engine (blocking).

pub fn uptime(&self) -> Option<Duration>

Get uptime.

pub fn tick_count(&self) -> u64

Get tick count.

pub fn is_shutdown_requested(&self) -> bool

Check if shutdown is requested.

pub fn request_shutdown(&self)

Request shutdown.

Trait Implementations

impl Drop for SimulatorEngine

fn drop(&mut self)

Executes the destructor for this type.