Struct FileRoller

pub struct FileRoller { /* private fields */ }

File roller for managing file rotation based on configurable policies

Implementations

impl FileRoller

pub fn new( base_path: PathBuf, max_file_size_mb: u64, max_records_per_file: u64, retention_days: u32, ) -> Self

Create a new file roller with specified policies

pub fn register_active_file(&self, writer_id: String, file_path: PathBuf)

Register a new active file for rotation management

pub fn update_file_statistics( &self, writer_id: &str, size_delta: u64, record_delta: u64, )

Update statistics for an active file

pub fn check_rotation_policy(&self, writer_id: &str) -> bool

Check if a file needs rotation based on configured policies

pub async fn execute_rotation_check(&self) -> Result<Vec<String>>

Execute rotation for all files that meet rotation criteria

pub async fn cleanup_old_files(&self) -> Result<u64>

Clean up old files based on retention policy

pub fn get_active_files_statistics(&self) -> FxHashMap<String, ActiveFileInfo>

Get statistics for all currently active files

Trait Implementations

impl Debug for FileRoller

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.