Struct RGAText 

pub struct RGAText {
    nodes: HashMap<TextId, TextNode>,
    children: HashMap<TextId, Vec<TextId>>,
    replica_id: String,
    seq: u64,
    pending_delta: Option<RGATextDelta>,
}

Collaborative text CRDT using RGA algorithm.

Supports character-level insert and delete with deterministic conflict resolution.

Fields

nodes: HashMap<TextId, TextNode>

All nodes indexed by their ID.

children: HashMap<TextId, Vec<TextId>>

Children of each node (characters inserted after it). Maps origin -> list of children sorted by ID (descending for RGA).

replica_id: String

The replica ID for this instance.

seq: u64

Sequence counter for generating IDs.

pending_delta: Option<RGATextDelta>

Pending delta for replication.

Implementations

impl RGAText

pub fn new(replica_id: impl Into<String>) -> Self

Create a new empty text.

pub fn replica_id(&self) -> &str

Get the replica ID.

fn next_id(&mut self) -> TextId

Generate a new unique ID.

pub fn insert(&mut self, position: usize, text: &str)

Insert a string at the given position.

pub fn delete(&mut self, start: usize, length: usize)

Delete characters from start to start+length.

fn delete_by_id(&mut self, id: &TextId) -> Option<char>

Delete a character by its ID.

pub fn replace(&mut self, start: usize, end: usize, text: &str)

Replace a range with new text.

pub fn splice(&mut self, position: usize, delete_count: usize, insert: &str)

Splice: delete some characters and insert new ones.

pub fn len(&self) -> usize

Get the length (number of visible characters).

pub fn is_empty(&self) -> bool

Check if empty.

pub fn char_at(&self, position: usize) -> Option<char>

Get character at position.

pub fn slice(&self, start: usize, end: usize) -> String

Get a substring.

pub fn iter(&self) -> impl Iterator<Item = char> + '_

Iterate over visible characters.

fn id_at_index(&self, index: usize) -> Option<TextId>

Get the ID at a visible index.

fn visible_ids(&self) -> impl Iterator<Item = &TextId> + '_

Iterate over visible IDs.

pub fn id_to_position(&self, id: &TextId) -> Option<usize>

Convert a TextId to a visible position.

pub fn position_to_id(&self, position: usize) -> Option<TextId>

Convert a visible position to a TextId.

fn iter_nodes(&self) -> impl Iterator<Item = &TextNode> + '_

Iterate over all nodes in order.

fn integrate_node(&mut self, node: TextNode)

Integrate a node into the text.

pub fn take_delta(&mut self) -> Option<RGATextDelta>

Take the pending delta.

pub fn apply_delta(&mut self, delta: &RGATextDelta)

Apply a delta from another replica.

Trait Implementations

impl Clone for RGAText

fn clone(&self) -> RGAText

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RGAText

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

Formats the value using the given formatter.

impl Default for RGAText

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RGAText

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for RGAText

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

Formats the value using the given formatter.

impl Lattice for RGAText

fn bottom() -> Self

The bottom element (identity for join)

fn join(&self, other: &Self) -> Self

Join operation (least upper bound) Must be commutative, associative, and idempotent

fn partial_cmp_lattice(&self, other: &Self) -> Option<Ordering>

Partial order derived from join: a ≤ b iff a ⊔ b = b

fn leq(&self, other: &Self) -> bool

Check if self ≤ other in the lattice order

fn join_assign(&mut self, other: &Self)

Join-assign: self = self ⊔ other

impl PartialEq for RGAText

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for RGAText

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for RGAText