Struct AttributeProcessor 

pub struct AttributeProcessor { /* private fields */ }

Processor that extracts multiple attribute values from each array.

Implementations

impl AttributeProcessor

pub fn new(attr_name: &str, num_channels: usize) -> Self

num_channels is C maxAttributes_ (the per-frame channel count, floored to >=1; NDPluginAttribute.cpp:184). Channel 0 is seeded with attr_name.

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

pub fn params(&self) -> &AttributeParams

Access the registered param indices (populated after register_params).

pub fn reset(&self)

Reset value and value_sum for all channels (C parity: resets all, not just one).

pub fn value(&self) -> f64

Current extracted value for channel 0.

pub fn value_sum(&self) -> f64

Current accumulated sum for channel 0.

pub fn attr_name(&self) -> String

The attribute name being tracked by channel 0.

pub fn set_attr_name(&self, name: &str)

Set the attribute name for channel 0.

Trait Implementations

impl NDPluginProcess for AttributeProcessor

fn does_array_callbacks(&self) -> bool

C NDPluginAttribute.cpp:203 sets NDArrayCallbacks = 0: this plugin extracts attribute time series and does not deliver arrays downstream.

fn process_array(&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( &self, reason: usize, params: &PluginParamSnapshot, ) -> ParamChangeResult

Called when a param changes. Reason is the param index. Return param updates to be written back to the port driver.

fn compression_aware(&self) -> bool

Whether this plugin can process compressed (codec != None) arrays (C++ compressionAware_, G3). Defaults to false: a plugin that operates on raw pixels must not be handed compressed bytes — the runtime drops compressed input and counts it into DroppedArrays. A codec/file plugin that understands compressed data overrides this.

fn array_data_handle( &self, ) -> Option<Arc<Mutex<RawMutex, Option<Arc<NDArray>>>>>

Return a handle to the latest NDArray data for array reads. Override this in plugins like NDPluginStdArrays that serve pixel data via readInt8Array/readInt16Array/etc.