Struct JsonCrdt 

pub struct JsonCrdt { /* private fields */ }

Collaborative JSON document CRDT.

Provides Automerge-like semantics for editing nested JSON structures with conflict-free concurrent operations.

Implementations

impl JsonCrdt

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

Create a new empty JSON document.

pub fn replica_id(&self) -> &str

Get the replica ID.

pub fn get(&self, path: &JsonPath) -> Option<&JsonValue>

Get a value at a path.

pub fn set(&mut self, path: &JsonPath, value: JsonValue) -> Result<(), DbError>

Set a value at a path.

pub fn delete(&mut self, path: &JsonPath) -> Result<(), DbError>

Delete a value at a path.

pub fn create_object(&mut self) -> ObjectId

Create a new object and return its ID.

pub fn create_array(&mut self) -> ArrayId

Create a new array and return its ID.

pub fn set_object(&mut self, path: &JsonPath) -> Result<ObjectId, DbError>

Set a nested object at a path.

pub fn set_array(&mut self, path: &JsonPath) -> Result<ArrayId, DbError>

Set a nested array at a path.

pub fn array_insert( &mut self, array_id: &ArrayId, index: usize, value: JsonValue, ) -> Result<(), DbError>

Insert into an array.

pub fn array_push( &mut self, array_id: &ArrayId, value: JsonValue, ) -> Result<(), DbError>

Push to an array.

pub fn array_remove( &mut self, array_id: &ArrayId, index: usize, ) -> Result<JsonValue, DbError>

Remove from an array.

pub fn array_len(&self, array_id: &ArrayId) -> Option<usize>

Get array length.

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

Get all keys in the root object.

pub fn contains_key(&self, key: &str) -> bool

Check if a key exists in the root object.

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

Take the pending delta.

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

Apply a delta from another replica.

pub fn to_json(&self) -> Value

Convert to a serde_json::Value.

Trait Implementations

impl Clone for JsonCrdt

fn clone(&self) -> JsonCrdt

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JsonCrdt

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

Formats the value using the given formatter.

impl Default for JsonCrdt

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JsonCrdt

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Lattice for JsonCrdt

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 JsonCrdt

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for JsonCrdt