Struct StatsProcessor 

pub struct StatsProcessor { /* private fields */ }

Pure processing logic for statistics computation.

Implementations

impl StatsProcessor

pub fn new() -> Self

pub fn stats_handle(&self) -> Arc<Mutex<StatsResult>>

Get a cloneable handle to the latest stats.

pub fn params_handle(&self) -> Arc<Mutex<NDStatsParams>>

Get a shared handle to the params (populated after register_params is called).

pub fn set_ts_sender(&mut self, sender: TimeSeriesSender)

Set the time series sender for pushing data to the TS port driver.

Trait Implementations

impl Default for StatsProcessor

fn default() -> Self

Returns the “default value” for a type.

impl NDPluginProcess for StatsProcessor

fn process_array( &mut self, array: &NDArray, _pool: &NDArrayPool, ) -> ProcessResult

Process one array. Return output arrays and param updates.

fn plugin_type(&self) -> &str

Plugin type name for PLUGIN_TYPE param.

fn register_params( &mut self, base: &mut PortDriverBase, ) -> Result<(), AsynError>

Register plugin-specific params on the base. Called once during construction.

fn on_param_change(&mut self, reason: usize, snapshot: &PluginParamSnapshot)

Called when a param changes. Reason is the param index.