Struct nydus::FusedevDaemon

pub struct FusedevDaemon { /* private fields */ }

Nydus daemon to implement FUSE servers by accessing /dev/fuse.

One FUSE mountpoint will be created for each FusedevDaemon object. Every FusedevDaemon object has a built-in Vfs object, which can be used to mount multiple RAFS and/or passthroughfs instances.

Implementations

impl FusedevDaemon

pub fn new( trigger: Sender<DaemonStateMachineInput>, receiver: Receiver<Result<(), Error>>, vfs: Arc<Vfs>, mountpoint: &Path, threads_cnt: u32, waker: Arc<Waker>, bti: BuildTimeInfo, id: Option<String>, supervisor: Option<String>, readonly: bool, fp: FailoverPolicy ) -> Result<FusedevDaemon, Error>

Create a new instance of FusedevDaemon.

Trait Implementations

impl DaemonStateMachineSubscriber for FusedevDaemon

fn on_event(&self, event: DaemonStateMachineInput) -> Result<(), Error>

Event handler to process state transition events.

impl NydusDaemon for FusedevDaemon

fn as_any(&self) -> &(dyn Any + 'static)

Cast self to trait object of Any to support object downcast.

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

Get optional daemon identifier.

fn version(&self) -> BuildTimeInfo

Get build and version information.

fn get_state(&self) -> DaemonState

Get daemon working state.

fn set_state(&self, state: DaemonState)

Set daemon working state.

fn start(&self) -> Result<(), Error>

Start the daemon object to serve incoming requests.

fn umount(&self) -> Result<(), Error>

Umount the FUSE filesystem.

fn stop(&self)

Stop the daemon object.

fn wait(&self) -> Result<(), Error>

Wait for daemon to exit.

fn wait_service(&self) -> Result<(), Error>

Wait for service worker thread to exit.

fn wait_state_machine(&self) -> Result<(), Error>

Wait for state machine worker thread to exit.

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

Get supervisor configuration information.

fn save(&self) -> Result<(), Error>

Save state for online upgrade.

fn restore(&self) -> Result<(), Error>

Restore state for online upgrade.

fn get_default_fs_service(&self) -> Option<Arc<dyn FsService + 'static>>

Set default filesystem service object.

fn export_info(&self, include_fs_info: bool) -> Result<String, Error>

Get status information about the daemon.

fn trigger_stop(&self) -> Result<(), Error>

Trigger Stop transition event to stop the daemon.

fn trigger_exit(&self) -> Result<(), Error>

Trigger transition events to move the state machine to STOPPED state.

fn trigger_takeover(&self) -> Result<(), Error>

Trigger Takeover transition event to take over control from old instance.

fn trigger_start(&self) -> Result<(), Error>

Trigger Start transition event to start the new instance.

fn get_blob_cache_mgr(&self) -> Option<Arc<BlobCacheMgr>>

Get the optional BlobCacheMgr object.

fn delete_blob(&self, _blob_id: String) -> Result<(), Error>

Delete a blob object managed by the daemon.