crdt

Sep 26, 2026

Changes in this version

type Composite

+ func (c *Composite) Digest() Digest

+ type Digest [32]byte

+ func (d Digest) String() string

type Doc

+ func (d *Doc) Digest() Digest

type List

+ func (l *List) Digest() Digest

type Map

+ func (m *Map) Digest() Digest

Sep 25, 2026

Changes in this version

+ var ErrTooManyOps = errors.New("crdt: more operations than allowed")

type ListOp

+ func ParseListOpsLimit(data []byte, max int) ([]ListOp, error)

type MapOp

+ func ParseMapOpsLimit(data []byte, max int) ([]MapOp, error)

type Op

+ func ParseOpsLimit(data []byte, max int) ([]Op, error)

type PartOps

+ func ParsePartOpsLimit(data []byte, max int) ([]PartOps, error)

Sep 23, 2026

Changes in this version

+ var ErrCollidingID = errors.New("crdt: two operations share one ID")

Sep 2, 2026

Changes in this version

+ var ErrPurged = errors.New("crdt: a purge discarded characters this version still needs")

type Composite

+ func (c *Composite) CanServe(v CompositeVersion) error

type Doc

+ func (d *Doc) CanServe(v VersionVector) error

+ func (d *Doc) Purge() int

+ func (d *Doc) PurgedBelow() uint64

Sep 1, 2026

Changes in this version

+ func Reads(f Format) []byte

+ func Writes(f Format) byte

+ type Format uint8

+ const FormatComposite

+ const FormatList

+ const FormatMap

+ const FormatText

+ func Formats() []Format

+ func (f Format) String() string

Aug 31, 2026

Changes in this version

+ var ErrUnknownFormat = fmt.Errorf("%w: format version this build does not know", ErrMalformed)

Aug 30, 2026

Changes in this version

type ListOp

+ Span uint64

type Op

+ Span uint64

type OpKind

+ const OpSuperseded

Aug 30, 2026

Changes in this version

type Composite

+ func (c *Composite) Clocks() CompositeClocks

+ type CompositeClocks map[Part]uint64

+ func (c *CompositeClocks) UnmarshalBinary(in []byte) error

+ func (c CompositeClocks) MarshalBinary() ([]byte, error)

type Map

+ func (m *Map) Clock() uint64

+ func (m *Map) LastClocks() map[SiteID]uint64

Aug 27, 2026

Changes in this version

+ var ErrCollected = errors.New("crdt: history below the collection floor")

+ var ErrStranded = errors.New("crdt: operation names a collected character")

type Composite

+ func (c *Composite) CanReplay(v CompositeVersion) bool

+ func (c *Composite) Collect(stable CompositeVersion) int

type Doc

+ func (d *Doc) CanReplay(v VersionVector) bool

+ func (d *Doc) Collect(stable VersionVector) int

+ func (d *Doc) Floor() VersionVector

+ func (d *Doc) Rewritten(site SiteID) (*Doc, error)

type List

+ func (l *List) CanReplay(v VersionVector) bool

+ func (l *List) Collect(stable VersionVector) int

+ func (l *List) Floor() VersionVector

+ func (l *List) Rewritten(site SiteID) (*List, error)

type Map

+ func (m *Map) Collect(stable VersionVector) int

+ func (m *Map) CollectedBelow() uint64

+ func (m *Map) Rewritten(site SiteID) (*Map, error)

Aug 26, 2026

Changes in this version

type Composite

+ func (c *Composite) ApplyAbsorbed(batches ...PartOps) ([]PartOps, error)

type Doc

+ func (d *Doc) ApplyAbsorbed(ops ...Op) ([]Op, error)

type List

+ func (l *List) ApplyAbsorbed(ops ...ListOp) ([]ListOp, error)

type Map

+ func (m *Map) ApplyAbsorbed(ops ...MapOp) ([]MapOp, error)

Aug 24, 2026

Changes in this version

type Composite

+ func (c *Composite) DropPending() int

type Doc

+ func (d *Doc) DropPending() int

type List

+ func (l *List) DropPending() int

type Map

+ func (m *Map) DropPending() int

Aug 23, 2026

Changes in this version

type Doc

+ func (d *Doc) ChangesSince(v VersionVector) []Change

+ func (d *Doc) LenAt(v VersionVector) int

+ func (d *Doc) TextAt(v VersionVector) string

type List

+ func (l *List) LenAt(v VersionVector) int

+ func (l *List) ValuesAt(v VersionVector) [][]byte

Aug 18, 2026

Changes in this version

type Map

+ func (m *Map) Site() SiteID

+ func (m *Map) Stamp(key string) (clock uint64, site SiteID, ok bool)

Aug 17, 2026

Changes in this version

type Composite

+ func (c *Composite) ApplyChanges(batches ...PartOps) ([]PartChange, error)

type List

+ func (l *List) ApplyChanges(ops ...ListOp) (bool, error)

type Map

+ func (m *Map) ApplyChanges(ops ...MapOp) ([]string, error)

+ type PartChange struct

+ Keys []string

+ Part Part

+ Text []Change

Aug 17, 2026

Changes in this version

+ func AppendListOps(dst []byte, ops []ListOp) ([]byte, error)

+ func AppendPartOps(dst []byte, batches []PartOps) ([]byte, error)

type ListOp

+ func ParseListOps(data []byte) ([]ListOp, error)

+ func (o *ListOp) UnmarshalBinary(data []byte) error

+ func (o ListOp) MarshalBinary() ([]byte, error)

type PartOps

+ func ParsePartOps(data []byte) ([]PartOps, error)

Aug 17, 2026

Changes in this version

+ var ErrInvalidPart = errors.New("crdt: invalid part")

+ type Composite struct

+ func LoadComposite(site SiteID, snapshot []byte) (*Composite, error)

+ func NewComposite(site SiteID) *Composite

+ func (c *Composite) Apply(batches ...PartOps) error

+ func (c *Composite) List(name string) (*List, error)

+ func (c *Composite) Map(name string) (*Map, error)

+ func (c *Composite) OpsSince(v CompositeVersion) []PartOps

+ func (c *Composite) Parts() []Part

+ func (c *Composite) Pending() int

+ func (c *Composite) Site() SiteID

+ func (c *Composite) Snapshot() []byte

+ func (c *Composite) Text(name string) (*Doc, error)

+ func (c *Composite) Version() CompositeVersion

+ type CompositeVersion map[Part]VersionVector

+ func (v *CompositeVersion) UnmarshalBinary(data []byte) error

+ func (v CompositeVersion) Clone() CompositeVersion

+ func (v CompositeVersion) Equal(other CompositeVersion) bool

+ func (v CompositeVersion) MarshalBinary() ([]byte, error)

+ type Part struct

+ Kind PartKind

+ Name string

+ type PartKind uint8

+ const PartList

+ const PartMap

+ const PartText

+ func (k PartKind) String() string

+ type PartOps struct

+ List []ListOp

+ Map []MapOp

+ Part Part

+ Text []Op

Aug 16, 2026

Changes in this version

+ const MaxClock

+ var ErrExhausted = errors.New("crdt: the site has no clock left")

+ func AppendMapOps(dst []byte, ops []MapOp) ([]byte, error)

+ type Map struct

+ func LoadMap(site SiteID, snapshot []byte) (*Map, error)

+ func NewMap(site SiteID) *Map

+ func (m *Map) Apply(ops ...MapOp) error

+ func (m *Map) Delete(key string) (MapOp, error)

+ func (m *Map) Get(key string) ([]byte, bool)

+ func (m *Map) Keys() []string

+ func (m *Map) Len() int

+ func (m *Map) OpsSince(vv VersionVector) []MapOp

+ func (m *Map) Pending() int

+ func (m *Map) Set(key string, value []byte) (MapOp, error)

+ func (m *Map) Snapshot() []byte

+ func (m *Map) Tombstones() int

+ func (m *Map) Version() VersionVector

+ type MapOp struct

+ Clock uint64

+ ID ID

+ Key string

+ Kind MapOpKind

+ Span uint64

+ Value []byte

+ func ParseMapOps(data []byte) ([]MapOp, error)

+ func (o *MapOp) UnmarshalBinary(data []byte) error

+ func (o MapOp) MarshalBinary() ([]byte, error)

+ type MapOpKind uint8

+ const MapDelete

+ const MapSet

+ const MapSuperseded

+ func (k MapOpKind) String() string

Aug 16, 2026

Changes in this version

+ var ErrEmptyValue = errors.New("crdt: a list value must not be empty")

+ type List struct

+ func LoadList(site SiteID, snapshot []byte) (*List, error)

+ func NewList(site SiteID) *List

+ func (l *List) Anchor(pos int) (ID, error)

+ func (l *List) Apply(ops ...ListOp) error

+ func (l *List) Delete(pos, count int) ([]ListOp, error)

+ func (l *List) Get(pos int) ([]byte, error)

+ func (l *List) Insert(pos int, values ...[]byte) ([]ListOp, error)

+ func (l *List) Len() int

+ func (l *List) OpsSince(vv VersionVector) []ListOp

+ func (l *List) Pending() int

+ func (l *List) Position(anchor ID) (pos int, ok bool)

+ func (l *List) Site() SiteID

+ func (l *List) Snapshot() []byte

+ func (l *List) Tombstones() int

+ func (l *List) Values() [][]byte

+ func (l *List) Version() VersionVector

+ func (l *List) Visible(anchor ID) bool

+ type ListOp struct

+ Clock uint64

+ ID ID

+ Kind OpKind

+ Origin ID

+ Target ID

+ Value []byte

Aug 16, 2026

Changes in this version

+ var ErrSurrogateBoundary = errors.New("crdt: UTF-16 offset splits a surrogate pair")

type Doc

+ func (d *Doc) DeleteUTF16(pos, length int) ([]Op, error)

+ func (d *Doc) InsertUTF16(pos int, text string) ([]Op, error)

+ func (d *Doc) LenUTF16() int

+ func (d *Doc) RuneOffset(pos int) (int, error)

+ func (d *Doc) UTF16Offset(pos int) (int, error)

Aug 16, 2026

Changes in this version

+ type AuthorRun struct

+ Len int

+ Pos int

+ Site SiteID

+ type Change struct

+ Pos int

+ Removed int

+ Text string

+ func ChangesFrom(text, want string) []Change

type Doc

+ func (d *Doc) Anchor(pos int) (ID, error)

+ func (d *Doc) ApplyChanges(ops ...Op) ([]Change, error)

+ func (d *Doc) Author(pos int) (SiteID, error)

+ func (d *Doc) AuthorRuns() []AuthorRun

+ func (d *Doc) Position(anchor ID) (pos int, ok bool)

+ func (d *Doc) Visible(anchor ID) bool

Aug 16, 2026

Changes in this version

type VersionVector

+ func (v *VersionVector) UnmarshalBinary(data []byte) error

+ func (v VersionVector) MarshalBinary() ([]byte, error)

Aug 16, 2026

Changes in this version

+ var ErrInvalidOp = errors.New("crdt: invalid operation")

+ var ErrInvalidText = errors.New("crdt: invalid UTF-8")

+ var ErrMalformed = errors.New("crdt: malformed encoding")

+ var ErrOutOfRange = errors.New("crdt: position out of range")

+ func AppendOps(dst []byte, ops []Op) ([]byte, error)

+ type Doc struct

+ func Load(site SiteID, snapshot []byte) (*Doc, error)

+ func New(site SiteID) *Doc

+ func (d *Doc) Apply(ops ...Op) error

+ func (d *Doc) Delete(pos, length int) ([]Op, error)

+ func (d *Doc) Insert(pos int, text string) ([]Op, error)

+ func (d *Doc) Len() int

+ func (d *Doc) OpsSince(vv VersionVector) []Op

+ func (d *Doc) Pending() int

+ func (d *Doc) Site() SiteID

+ func (d *Doc) Snapshot() []byte

+ func (d *Doc) String() string

+ func (d *Doc) Tombstones() int

+ func (d *Doc) Version() VersionVector

+ type ID struct

+ Seq uint64

+ Site SiteID

+ func (id ID) IsRoot() bool

+ func (id ID) String() string

+ type Op struct

+ Char rune

+ Clock uint64

+ ID ID

+ Kind OpKind

+ Origin ID

+ Target ID

+ func ParseOps(data []byte) ([]Op, error)

+ func (o *Op) UnmarshalBinary(data []byte) error

+ func (o Op) MarshalBinary() ([]byte, error)

+ type OpKind uint8

+ const OpDelete

+ const OpInsert

+ func (k OpKind) String() string

+ type SiteID uint64

+ func DeriveSiteID(b []byte) SiteID

+ type VersionVector map[SiteID]uint64

+ func (v VersionVector) Clone() VersionVector

+ func (v VersionVector) Equal(other VersionVector) bool

+ func (v VersionVector) Get(site SiteID) uint64

+ func (v VersionVector) Includes(id ID) bool