Struct EimBackend

pub struct EimBackend {
    path: PathBuf,
    socket_path: PathBuf,
    tempdir: Option<TempDir>,
    socket: UnixStream,
    debug: bool,
    debug_callback: Option<DebugCallback>,
    _process: Child,
    model_info: Option<ModelInfo>,
    message_id: AtomicU32,
    model_parameters: ModelParameters,
}

EIM backend implementation for socket-based communication

Fields

path: PathBuf

Path to the Edge Impulse model file (.eim)

socket_path: PathBuf

Path to the Unix socket used for IPC

tempdir: Option<TempDir>

Handle to the temporary directory for the socket (ensures cleanup)

socket: UnixStream

Active Unix socket connection to the model process

debug: bool

Enable debug logging of socket communications

debug_callback: Option<DebugCallback>

Optional debug callback for receiving debug messages

_process: Child

Handle to the model process (kept alive while model exists)

model_info: Option<ModelInfo>

Cached model information received during initialization

message_id: AtomicU32

Atomic counter for generating unique message IDs

model_parameters: ModelParameters

Model parameters extracted from model info

Implementations

impl EimBackend

pub fn new(config: BackendConfig) -> Result<Self, EdgeImpulseError>

Create a new EIM backend

fn ensure_executable<P: AsRef<Path>>(path: P) -> Result<(), EdgeImpulseError>

Ensure the model file has execution permissions for the current user

fn connect_with_retry( socket_path: &Path, timeout: Duration, ) -> Result<UnixStream, EdgeImpulseError>

Connect to the socket with retry logic

fn send_hello(&mut self) -> Result<(), EdgeImpulseError>

Send hello message to get model information

fn next_message_id(&self) -> u32

Generate the next unique message ID

pub fn set_debug_callback(&mut self, callback: DebugCallback)

Set the debug callback

fn debug_message(&self, msg: &str)

Send a debug message if a callback is set

fn classify( &mut self, input: &[f32], ) -> Result<InferenceResult, EdgeImpulseError>

Classify a single input

Trait Implementations

impl InferenceBackend for EimBackend

fn new(config: BackendConfig) -> Result<Self, EdgeImpulseError>

Create a new backend instance

fn infer( &mut self, features: Vec<f32>, _debug: Option<bool>, ) -> Result<InferenceResponse, EdgeImpulseError>

Run inference on features

fn parameters(&self) -> Result<&ModelParameters, EdgeImpulseError>

Get model parameters

fn sensor_type(&self) -> Result<SensorType, EdgeImpulseError>

Get sensor type

fn input_size(&self) -> Result<usize, EdgeImpulseError>

Get input size

fn set_debug_callback(&mut self, callback: Box<dyn Fn(&str) + Send + Sync>)

Set debug callback

fn normalize_visual_anomaly( &self, anomaly: f32, max: f32, mean: f32, regions: &[(f32, u32, u32, u32, u32)], ) -> VisualAnomalyResult

Normalize visual anomaly results