Struct FilesystemTrigger 

pub struct FilesystemTrigger { /* private fields */ }

Filesystem event trigger.

Watches a directory for file changes and fires events.

Configuration

triggers:
  - id: file_watcher
    type: trigger::filesystem
    params:
      path: "/data/incoming"
      recursive: true
      events:
        - create
        - modify

Parameters

• path - Directory path to watch (required)
• recursive - Watch subdirectories (default: false)
• events - Event types to watch (default: all)
  • create - File created
  • modify - File modified
  • remove - File deleted
  • rename - File renamed

Implementations

impl FilesystemTrigger

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

Create a new filesystem trigger.

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

Create from configuration.

pub fn recursive(self) -> Self

Enable recursive watching.

pub fn watch_create_only(self) -> Self

Watch only for create events.

Trait Implementations

impl Trigger for FilesystemTrigger

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.