Trait 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);
    fn emit_file_line_too_long(
        &self,
        truncated_bytes: &BytesMut,
        configured_limit: usize,
        encountered_size_so_far: usize,
    );
}

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)

fn emit_file_line_too_long( &self, truncated_bytes: &BytesMut, configured_limit: usize, encountered_size_so_far: usize, )

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors