Struct DecoratedFs 

pub struct DecoratedFs<FS: AsyncFileSystem> {
    pub fs: EventEmittingFs<CrdtFs<FS>>,
    pub workspace_crdt: Arc<WorkspaceCrdt>,
    pub body_doc_manager: Arc<BodyDocManager>,
    pub event_registry: Arc<CallbackRegistry>,
    pub storage: Arc<dyn CrdtStorage>,
}

A fully decorated filesystem with runtime control handles.

This struct contains:

• The decorated filesystem stack
• Handles for runtime control (enable/disable CRDT, events)
• Access to CRDTs for observer registration

Example

use diaryx_core::fs::{DecoratedFsBuilder, InMemoryFileSystem, SyncToAsyncFs};
use diaryx_core::types::MemoryStorage;
use std::sync::Arc;

let base_fs = SyncToAsyncFs::new(InMemoryFileSystem::new());
let storage = Arc::new(MemoryStorage::new());

let decorated = DecoratedFsBuilder::new(base_fs)
    .with_crdt(storage)
    .build();

// Use the filesystem
decorated.fs.write_file(Path::new("test.md"), "content").await?;

// Access runtime controls
decorated.set_crdt_enabled(false);
decorated.set_events_enabled(false);

// Subscribe to events
decorated.on_event(Arc::new(|event| println!("{:?}", event)));

Fields

fs: EventEmittingFs<CrdtFs<FS>>

The fully decorated filesystem stack. Stack: EventEmittingFs<CrdtFs>

workspace_crdt: Arc<WorkspaceCrdt>

The workspace CRDT for file metadata.

body_doc_manager: Arc<BodyDocManager>

The body document manager for file content.

event_registry: Arc<CallbackRegistry>

The event callback registry.

storage: Arc<dyn CrdtStorage>

The CRDT storage backend.

Implementations

impl<FS: AsyncFileSystem> DecoratedFs<FS>

pub fn set_crdt_enabled(&self, enabled: bool)

Enable or disable CRDT updates.

pub fn is_crdt_enabled(&self) -> bool

Check if CRDT updates are enabled.

pub fn set_events_enabled(&self, enabled: bool)

Enable or disable event emission.

pub fn is_events_enabled(&self) -> bool

Check if event emission is enabled.

pub fn on_event(&self, callback: EventCallback) -> SubscriptionId

Subscribe to filesystem events.

Returns a subscription ID that can be used to unsubscribe.

pub fn off_event(&self, id: SubscriptionId) -> bool

Unsubscribe from filesystem events.

pub fn base_fs(&self) -> &FS

Get a reference to the inner base filesystem.

pub fn crdt_fs(&self) -> &CrdtFs<FS>

Get a reference to the CrdtFs layer.

pub fn event_fs(&self) -> &EventEmittingFs<CrdtFs<FS>>

Get a reference to the EventEmittingFs layer.

pub fn set_workspace_root(&self, root: PathBuf)

Set the workspace root on the CrdtFs layer for path normalization.

pub fn workspace_root_handle(&self) -> Arc<RwLock<Option<PathBuf>>>

Get a shared handle to the CrdtFs workspace root.

Trait Implementations

impl<FS: AsyncFileSystem + Clone> Clone for DecoratedFs<FS>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<FS: AsyncFileSystem> Debug for DecoratedFs<FS>

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

Formats the value using the given formatter.