Struct TextCrdt 

pub struct TextCrdt { /* private fields */ }

A collaborative text CRDT based on RGA (Replicated Growable Array) principles.

Each character is assigned a unique identifier (actor, counter) and is stored in an internal sequence. Deletions use tombstones: characters are marked as deleted but remain in the internal list so that concurrent operations from different replicas can be merged deterministically.

Ordering of concurrent inserts at the same position is resolved by comparing (counter, actor) tuples — higher counters come first, and ties are broken lexicographically by actor ID.

Example

use crdt_kit::prelude::*;

let mut t1 = TextCrdt::new("alice");
t1.insert_str(0, "hello");

let mut t2 = TextCrdt::new("bob");
t2.insert_str(0, "world");

t1.merge(&t2);
t2.merge(&t1);

// Both replicas converge to the same text.
assert_eq!(t1.to_string(), t2.to_string());

Implementations

impl TextCrdt

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

Create a new empty text CRDT for the given actor.

pub fn fork(&self, new_actor: impl Into<String>) -> Self

Create a fork of this replica with a different actor ID.

The returned replica contains an identical copy of the current content and version state, but subsequent inserts will use the new actor, preventing ID collisions between the two replicas.

pub fn insert(&mut self, index: usize, ch: char)

Insert a character at the given visible index.

Panics

Panics if index is greater than self.len().

pub fn insert_str(&mut self, index: usize, s: &str)

Insert a string at the given visible index.

Characters are inserted left-to-right so that the resulting visible text contains the string starting at index.

Panics

Panics if index is greater than self.len().

pub fn remove(&mut self, index: usize)

Remove (tombstone) the character at the given visible index.

Panics

Panics if index is greater than or equal to self.len().

pub fn remove_range(&mut self, start: usize, len: usize)

Remove a range of characters starting at start with the given len.

Panics

Panics if start + len is greater than self.len().

pub fn len(&self) -> usize

Return the number of visible (non-deleted) characters.

pub fn is_empty(&self) -> bool

Check whether the visible text is empty.

pub fn actor(&self) -> &str

Get this replica’s actor ID.

Trait Implementations

impl Clone for TextCrdt

fn clone(&self) -> TextCrdt

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Crdt for TextCrdt

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

Merge another replica’s state into this one.

impl Debug for TextCrdt

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

Formats the value using the given formatter.

impl Display for TextCrdt

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

Formats the value using the given formatter.

impl PartialEq for TextCrdt

fn eq(&self, other: &TextCrdt) -> 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 Eq for TextCrdt

impl StructuralPartialEq for TextCrdt