Struct MemoryTrigger 

pub struct MemoryTrigger { /* private fields */ }

Memory trigger for benchmarking.

Provides zero-overhead event injection for performance testing. Events are injected directly via MemoryInjector.

Configuration

triggers:
  - id: bench_trigger
    type: trigger::memory
    params:
      buffer_size: 10000

Parameters

• buffer_size - Maximum events to buffer (default: 1000)

Usage

let trigger = MemoryTrigger::new("bench");
// Start the trigger...
let injector = trigger.injector().unwrap();

// Inject events for benchmarking
for _ in 0..1000 {
    injector.inject_empty().await?;
}

Implementations

impl MemoryTrigger

pub fn new(id: impl Into<String>) -> Self

Create a new memory trigger.

pub fn from_config(config: &TriggerConfig) -> Result<Self>

Create from configuration.

pub fn with_buffer_size(self, size: usize) -> Self

Set the buffer size.

pub fn injector(&self) -> Option<MemoryInjector>

Get an injector for sending events.

Returns None if the trigger hasn’t been started.

pub fn event_count(&self) -> u64

Get the number of events processed.

pub fn reset_count(&self)

Reset the event counter.

Trait Implementations

impl Trigger for MemoryTrigger

fn trigger_type(&self) -> TriggerType

Get the trigger type.

fn id(&self) -> &str

Get the trigger ID.

fn start<'a>( &'a self, callback: Box<dyn Fn(TriggerEvent) + Send + Sync + 'static>, ) -> TriggerFuture<'a, ()>

Start the trigger.

fn stop<'a>(&'a self) -> TriggerFuture<'a, ()>

Stop the trigger.

fn pause<'a>(&'a self) -> TriggerFuture<'a, ()>

Pause the trigger (stop accepting new events).

fn resume<'a>(&'a self) -> TriggerFuture<'a, ()>

Resume the trigger.

fn is_running(&self) -> bool

Check if the trigger is running.