Struct ResourceStateManager 

pub struct ResourceStateManager { /* private fields */ }

Thread-safe registry of collaborative document resources.

ResourceStateManager maintains the canonical state for all active resources in the system. It provides methods for creating resources, applying edits, and querying state. All operations are atomic and thread-safe.

Implementations

impl ResourceStateManager

pub fn new() -> Self

Create a new empty resource manager.

pub fn get_or_create_resource( &self, resource_id: &str, initial_agent_id: &str, requested_merge_type: Option<&str>, ) -> Arc<Mutex<ResourceState>>

Get or create a resource, initializing its CRDT if needed.

pub fn subscribe_to_indices(&self) -> Receiver<String>

Subscribe to new resource creation events.

pub fn get_resource( &self, resource_id: &str, ) -> Option<Arc<Mutex<ResourceState>>>

Get an existing resource without creating it.

pub fn list_resources(&self) -> Vec<String>

List all resource IDs currently in memory.

pub fn has_version(&self, resource_id: &str, version_id: &str) -> bool

Check if a resource has already seen a specific version.

pub fn apply_update( &self, resource_id: &str, content: &str, agent_id: &str, version_id: Option<&str>, requested_merge_type: Option<&str>, ) -> Result<Value, String>

Apply a full document update (replacement).

pub fn apply_remote_insert( &self, resource_id: &str, agent_id: &str, pos: usize, text: &str, version_id: Option<&str>, requested_merge_type: Option<&str>, ) -> Result<Value, String>

Apply a remote insertion operation.

pub fn apply_remote_insert_versioned( &self, resource_id: &str, agent_id: &str, parents: &[&str], pos: usize, text: &str, version_id: Option<&str>, requested_merge_type: Option<&str>, ) -> Result<Value, String>

Apply a remote insertion operation at a specific version.

pub fn apply_remote_delete( &self, resource_id: &str, agent_id: &str, start: usize, end: usize, version_id: Option<&str>, requested_merge_type: Option<&str>, ) -> Result<Value, String>

Apply a remote deletion operation.

pub fn apply_remote_delete_versioned( &self, resource_id: &str, agent_id: &str, parents: &[&str], range: Range<usize>, version_id: Option<&str>, requested_merge_type: Option<&str>, ) -> Result<Value, String>

Apply a remote deletion operation at a specific version.

pub fn get_resource_state(&self, resource_id: &str) -> Option<Value>

Get a snapshot of a resource’s current state.

pub fn get_merge_quality(&self, resource_id: &str) -> Option<u32>

Get the merge quality score for a resource.

pub fn register_version_mapping( &self, resource_id: &str, version: String, frontier: Frontier, )

Register a version mapping for a resource.

pub fn get_history( &self, resource_id: &str, since_versions: &[&str], ) -> Result<Vec<SerializedOpsOwned>, String>

Get history for a resource since a set of versions.

Trait Implementations

impl Clone for ResourceStateManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ResourceStateManager

fn default() -> Self

Returns the “default value” for a type.