Struct SignalProcessor 

pub struct SignalProcessor { /* private fields */ }

Signal processor for handling CDC signals.

Implementations

impl SignalProcessor

pub fn new() -> Self

Create a new signal processor.

pub fn stats(&self) -> &Arc<SignalStats>

Get statistics.

pub fn is_paused(&self) -> bool

Check if processing is paused.

pub fn pause(&self)

Pause processing.

pub fn resume(&self)

Resume processing.

pub async fn register_handler<F, Fut>(&self, action: &str, handler: F)

where F: Fn(&Signal) -> Fut + Send + Sync + 'static, Fut: Future<Output = SignalResult> + Send + 'static,

Register a custom handler for an action.

pub async fn set_enabled_sources(&self, sources: Vec<SignalSource>)

Set enabled signal sources.

pub async fn is_source_enabled(&self, source: &SignalSource) -> bool

Check if signal source is enabled.

pub async fn process(&self, signal: Signal) -> SignalResult

Process a signal.

pub fn parse_from_row( id: &str, signal_type: &str, data: Option<&str>, ) -> Result<Signal, String>

Parse signal from table row.

Trait Implementations

impl Default for SignalProcessor

fn default() -> Self

Returns the “default value” for a type.