fuser-async 0.1.1

Build FUSE filesystems where the system calls are directed to async functions. With an example S3 implementation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

#![doc = include_str!("../README.md")]
#![doc(html_root_url = "https://docs.rs/fuser-async/0.1.1")]
// Implementations
// pub mod implementations;
// pub use implementations::local;
// #[cfg(feature = "s3")]
// pub use implementations::s3;
// Internals
mod async_readseek;
mod error;
mod filesystem;
mod fuse;
// Interface
pub use async_readseek::FileHandle;
pub use error::Error;
pub use filesystem::Filesystem;
pub use fuse::FilesystemFUSE;
// Utils
pub mod cache;
pub mod remapping;
pub mod rwlockoption;
pub mod utils;

use std::path::Path;

trait_set::trait_set! {
    /// Trait alias for a  [`Filesystem`] that is [`Send`], [`Sync`], [`std::marker::Unpin`] and `'static`.
    pub trait FilesystemSSUS = Filesystem + Send + Sync  + std::marker::Unpin + 'static;
}

/// Directory entry (returned by [`Filesystem::readdir`]).
#[derive(Debug)]
pub struct DirEntry {
    pub inode: u64,
    pub file_type: fuser::FileType,
    pub name: String, // TODO: Use OsStr and/or Cow
}
impl DirEntry {
    pub fn path(&self) -> &Path {
        Path::new(&self.name)
    }
}

/// Trait for filesystems that can be refreshed.
#[async_trait::async_trait]
pub trait Refresh {
    type Error;
    /// Refresh filesystem
    async fn refresh(&mut self) -> Result<(), Self::Error>;
    /// Cleanup caches
    async fn cleanup(&self) -> Result<(), Self::Error>;
}