Struct FileManager

pub struct FileManager { /* private fields */ }

Main file manager

Implementations

impl FileManager

pub fn new(config: FileConfig) -> Self

Create a new file manager

pub fn set_event_bus(&mut self, event_bus: Arc<EventBusManager>)

Set event bus for publishing file events

pub async fn read_file(&self, path: impl AsRef<Path>) -> Result<Vec<u8>>

Read file contents

pub async fn read_file_to_string( &self, path: impl AsRef<Path>, ) -> Result<String>

Read file contents as string

pub async fn write_file( &self, path: impl AsRef<Path>, data: &[u8], options: Option<FileOperationOptions>, ) -> Result<()>

Write data to file

pub async fn copy_file( &self, source: impl AsRef<Path>, destination: impl AsRef<Path>, options: Option<FileOperationOptions>, ) -> Result<u64>

Copy file

pub async fn move_file( &self, source: impl AsRef<Path>, destination: impl AsRef<Path>, options: Option<FileOperationOptions>, ) -> Result<()>

Move/rename file

pub async fn delete_file(&self, path: impl AsRef<Path>) -> Result<()>

Delete file

pub async fn create_directory( &self, path: impl AsRef<Path>, recursive: bool, ) -> Result<()>

Create directory

pub async fn delete_directory( &self, path: impl AsRef<Path>, recursive: bool, ) -> Result<()>

Delete directory

pub async fn list_directory( &self, path: impl AsRef<Path>, ) -> Result<Vec<FileMetadata>>

List directory contents

pub async fn get_metadata(&self, path: impl AsRef<Path>) -> Result<FileMetadata>

Get file metadata

pub async fn exists(&self, path: impl AsRef<Path>) -> bool

Check if file exists

pub async fn file_size(&self, path: impl AsRef<Path>) -> Result<u64>

Get file size

pub async fn create_temp_file( &self, prefix: Option<&str>, suffix: Option<&str>, ) -> Result<PathBuf>

Create temporary file

pub async fn cleanup_temp_files(&self, max_age: Duration) -> Result<u64>

Clean up temporary files

pub async fn watch_path( &mut self, path: impl AsRef<Path>, recursive: bool, ) -> Result<()>

Start watching a path for changes

pub async fn unwatch_path(&mut self, path: impl AsRef<Path>) -> Result<()>

Stop watching a path

pub fn subscribe_to_changes(&self) -> Option<Receiver<FileChangeEvent>>

Subscribe to file change events

pub async fn compress_file( &self, source: impl AsRef<Path>, destination: impl AsRef<Path>, ) -> Result<()>

Compress file using configured compression

pub async fn decompress_file( &self, source: impl AsRef<Path>, destination: impl AsRef<Path>, ) -> Result<()>

Decompress file

pub async fn get_active_operations(&self) -> Vec<FileOperationProgress>

Get active file operations

pub async fn get_temp_usage(&self) -> Result<(u64, usize)>

Get temp directory usage

Trait Implementations

impl Debug for FileManager

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

Formats the value using the given formatter.

impl Manager for FileManager

fn name(&self) -> &str

Returns the manager name

fn id(&self) -> Uuid

Returns the manager ID

fn initialize<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initializes the manager

fn shutdown<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Shuts down the manager

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ManagerStatus> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns current status

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

Performs health check

fn pause<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Pauses the manager

fn resume<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Resumes the manager

fn restart<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Restarts the manager

fn get_config<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Value>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

Gets current configuration

fn update_config<'life0, 'async_trait>( &'life0 mut self, _config: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Updates configuration

fn dependencies(&self) -> Vec<String>

Returns dependencies

fn priority(&self) -> i32

Returns initialization priority

fn is_essential(&self) -> bool

Checks if manager is essential for system operation

fn version(&self) -> Option<String>

Returns manager version

fn description(&self) -> Option<String>

Returns manager description

fn supports_runtime_reload(&self) -> bool

Checks if manager supports runtime reloading

fn reload_config<'life0, 'async_trait>( &'life0 mut self, _config: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Reloads configuration at runtime

fn required_permissions(&self) -> Vec<String>

Returns required permissions

fn platform_requirements(&self) -> PlatformRequirements

Returns platform requirements