plistsync.core.crdt.fugue¶

Fugue — a list CRDT with interleaving of concurrent operations.

Inspired by The Art of the Fugue by Weidner & Kleppmann.

Overview¶

Classes¶
`InsertPos`	Positional info needed to reconstruct a Node on a remote replica.
`InsertOp`	Serialisable insert — structural pos + value.
`DeleteOp`	Serialisable delete.
`Ops`	Operation list with value lookup.
`Fugue`	Replicatable list with non-interleaving concurrent operations.

class plistsync.core.crdt.fugue.InsertPos¶: Positional info needed to reconstruct a Node on a remote replica.

class plistsync.core.crdt.fugue.InsertOp¶

Bases: Generic[T]

Serialisable insert — structural pos + value.

classmethod from_node(node: plistsync.core.crdt.graph.Node, value: T) → InsertOp[T]¶: Construct an InsertOp from a Node and value.

class plistsync.core.crdt.fugue.Ops¶

Bases: Generic[T]

Operation list with value lookup.

get_value(node_id: plistsync.core.crdt.graph.NodeID) → T¶: Return the value for a given node_id.

class plistsync.core.crdt.fugue.Fugue(replica_id: int = 0, initial_counter: int = 0)¶

Bases: Generic[T]

Replicatable list with non-interleaving concurrent operations.

apply(op: InsertOp[T] | DeleteOp) → None¶: Apply a remote operation to this replica.

fork(replica_id: int) → Fugue[T]¶: Return an independent copy with a new replica_id.

time_travel(version: plistsync.core.crdt.graph.NodeID) → Fugue[T]¶: Return a new replica containing only operations causally before version.