Trait file_source::FileSourceInternalEvents

pub trait FileSourceInternalEvents: Send + Sync + Clone + 'static {
    // Required methods
    fn emit_file_added(&self, path: &Path);
    fn emit_file_resumed(&self, path: &Path, file_position: u64);
    fn emit_file_watch_error(&self, path: &Path, error: Error);
    fn emit_file_unwatched(&self, path: &Path, reached_eof: bool);
    fn emit_file_deleted(&self, path: &Path);
    fn emit_file_delete_error(&self, path: &Path, error: Error);
    fn emit_file_fingerprint_read_error(&self, path: &Path, error: Error);
    fn emit_file_checkpointed(&self, count: usize, duration: Duration);
    fn emit_file_checksum_failed(&self, path: &Path);
    fn emit_file_checkpoint_write_error(&self, error: Error);
    fn emit_files_open(&self, count: usize);
    fn emit_path_globbing_failed(&self, path: &Path, error: &Error);
}

Every internal event in this crate has a corresponding method in this trait which should emit the event.

Required Methods

fn emit_file_added(&self, path: &Path)

fn emit_file_resumed(&self, path: &Path, file_position: u64)

fn emit_file_watch_error(&self, path: &Path, error: Error)

fn emit_file_unwatched(&self, path: &Path, reached_eof: bool)

fn emit_file_deleted(&self, path: &Path)

fn emit_file_delete_error(&self, path: &Path, error: Error)

fn emit_file_fingerprint_read_error(&self, path: &Path, error: Error)

fn emit_file_checkpointed(&self, count: usize, duration: Duration)

fn emit_file_checksum_failed(&self, path: &Path)

fn emit_file_checkpoint_write_error(&self, error: Error)

fn emit_files_open(&self, count: usize)

fn emit_path_globbing_failed(&self, path: &Path, error: &Error)

Object Safety

This trait is not object safe.

Implementors