replica

Aug 1, 2026

Changes in this version

type Manifest

+ func NewManifestForFrameType(groupID, schemaID string, epoch uint64, frameType crdt.FrameType, ...) (Manifest, error)

type Protocol

+ func ProtocolFromFrameType(frameType crdt.FrameType, codecID string) (Protocol, error)

type SessionBuilder

+ func NewSessionBuilderForFrameType(groupID, schemaID string, epoch uint64, frameType crdt.FrameType, ...) (SessionBuilder, error)

Jul 30, 2026

Changes in this version

type Protocol

+ WireFormatVersion uint64

+ func (p Protocol) FrameFormatVersion() uint64

Jul 29, 2026

Changes in this version

+ type SessionBuilder struct

+ func NewSessionBuilder(groupID, schemaID string, epoch uint64, protocol Protocol, ...) (SessionBuilder, error)

+ func NewSessionBuilderFromManifest(manifest Manifest, policy crdt.ProtocolPolicy) (SessionBuilder, error)

+ func (b SessionBuilder) Manifest() Manifest

+ func (b SessionBuilder) NewChange(dot Dot, delta []byte) (Change, error)

+ func (b SessionBuilder) NewCheckpoint(state []byte, frontier Frontier, clockState clock.State, ...) (Checkpoint, error)

+ func (b SessionBuilder) NewInbox(frontier Frontier, maxPending, maxBytes int, apply ApplyDelta) (*Inbox, error)

+ func (b SessionBuilder) NewSession() (*Session, error)

Jul 29, 2026

Changes in this version

type Delivery

+ Duplicate bool

+ func (d Delivery) Accepted() bool

Jul 29, 2026

Changes in this version

type Change

+ func NewChangeWithPolicy(manifest Manifest, dot Dot, delta []byte, policy crdt.ProtocolPolicy) (Change, error)

type Checkpoint

+ func NewCheckpointWithPolicy(manifest Manifest, state []byte, frontier Frontier, clockState clock.State, ...) (Checkpoint, error)

type Inbox

+ func NewInboxWithPolicy(manifest Manifest, frontier Frontier, maxPending, maxBytes int, ...) (*Inbox, error)

type Session

+ func NewSessionWithPolicy(manifest Manifest, policy crdt.ProtocolPolicy) (*Session, error)

Jul 28, 2026

Changes in this version

+ var ErrCheckpointChanged = errors.New("replica: a different checkpoint is already installed")

+ var ErrDotConflict = errors.New("replica: conflicting payload for one dot")

+ var ErrFrontierGap = errors.New("replica: non-contiguous frontier advance")

+ var ErrInvalidChange = errors.New("replica: invalid change")

+ var ErrInvalidCheckpoint = errors.New("replica: invalid checkpoint")

+ var ErrInvalidDot = errors.New("replica: invalid dot")

+ var ErrInvalidManifest = errors.New("replica: invalid manifest")

+ var ErrManifestMismatch = errors.New("replica: manifest mismatch")

+ var ErrNilApply = errors.New("replica: nil delta apply function")

+ var ErrNilStore = errors.New("replica: nil checkpoint store")

+ var ErrNilValidator = errors.New("replica: nil state validator")

+ var ErrNotInstalled = errors.New("replica: checkpoint is not installed")

+ var ErrPendingLimit = errors.New("replica: pending change limit exceeded")

+ var ErrProtocolMismatch = errors.New("replica: protocol mismatch")

+ type Acknowledgement struct

+ CheckpointID [sha256.Size]byte

+ Epoch uint64

+ Frontier Frontier

+ GroupID string

+ type ApplyDelta func([]byte) error

+ type Change struct

+ Dot Dot

+ func NewChange(manifest Manifest, dot Dot, delta []byte) (Change, error)

+ func (c Change) Delta() []byte

+ type Checkpoint struct

+ func NewCheckpoint(manifest Manifest, state []byte, frontier Frontier, clockState clock.State, ...) (Checkpoint, error)

+ func (c Checkpoint) ClockState() (clock.State, bool)

+ func (c Checkpoint) Frontier() Frontier

+ func (c Checkpoint) ID() [sha256.Size]byte

+ func (c Checkpoint) Manifest() Manifest

+ func (c Checkpoint) State() []byte

+ type CheckpointStore interface

+ SaveCheckpoint func(Checkpoint) error

+ type Delivery struct

+ Applied []Dot

+ Buffered bool

+ type Dot struct

+ Actor string

+ Counter uint64

+ type Frontier struct

+ func NewFrontier(entries map[string]uint64) (Frontier, error)

+ func (f Frontier) Advance(dot Dot) (Frontier, error)

+ func (f Frontier) Counter(actor string) uint64

+ func (f Frontier) Covers(dot Dot) bool

+ func (f Frontier) Entries() map[string]uint64

+ type Inbox struct

+ func NewInbox(manifest Manifest, frontier Frontier, maxPending, maxBytes int, ...) (*Inbox, error)

+ func (i *Inbox) Frontier() Frontier

+ func (i *Inbox) Pending() (changes, bytes int)

+ func (i *Inbox) Receive(change Change) (Delivery, error)

+ type Manifest struct

+ Epoch uint64

+ GroupID string

+ Protocol Protocol

+ SchemaID string

+ func NewManifest(groupID, schemaID string, epoch uint64, protocol Protocol, ...) (Manifest, error)

+ func (m Manifest) Compatible(remote Manifest) error

+ type Protocol struct

+ CodecID string

+ DeltaID uint64

+ SemanticsVersion uint64

+ StateID uint64

+ type Session struct

+ func NewSession(manifest Manifest) (*Session, error)

+ func (s *Session) Acknowledge() (Acknowledgement, error)

+ func (s *Session) Install(checkpoint Checkpoint, store CheckpointStore) error

+ type StateValidator func([]byte) error