durable

package module

Go to main page

Versions in this module

v1

v1.0.36

Aug 3, 2026

v1.0.35

Aug 3, 2026

v1.0.34

Aug 3, 2026

Changes in this version

+ const MerkleSubprotocol

+ var ErrAntiEntropyUnavailable = errors.New("crdt durable: HLC/Merkle anti-entropy unavailable")

+ var ErrMerkleDiverged = errors.New("crdt durable: HLC/Merkle histories diverged")

type ClientConfig

+ MaxMerkleBytes int

+ MaxMerkleLeaves int

+ MerkleRoot func() [32]byte

+ OnMerkleCatchUp func(MerkleBoundary) error

+ ReconcileMerkle func([]MerkleLeaf) ([]crdt.Tag, error)

type Config

+ MaxMerkleBytes int

+ MaxMerkleLeaves int

type Event

+ HLC crdt.Tag

+ type MerkleBoundary struct

+ HLC crdt.Tag

+ HighWater uint64

+ Root [sha256.Size]byte

+ type MerkleIndex struct

+ func NewMerkleIndex() *MerkleIndex

+ func (index *MerkleIndex) Put(event Event) error

+ func (index *MerkleIndex) Reconcile(remote []MerkleLeaf) ([]crdt.Tag, error)

+ func (index *MerkleIndex) Root() [sha256.Size]byte

+ type MerkleLeaf struct

+ Digest [sha256.Size]byte

+ HLC crdt.Tag

+ type MerkleLog interface

+ MerkleEnabled func() bool

+ MerkleEvents func(groupID string, identities []crdt.Tag, maxEvents, maxBytes uint64, ...) ([]Event, error)

+ MerkleSnapshot func(groupID string, maxLeaves, maxBytes uint64, manifest replica.Manifest, ...) (MerkleSnapshot, error)

+ type MerkleSnapshot struct

+ HLC crdt.Tag

+ HighWater uint64

+ Leaves []MerkleLeaf

+ Root [sha256.Size]byte

type Store

+ func (store *Store) MerkleEnabled() bool

+ func (store *Store) MerkleEvents(groupID string, identities []crdt.Tag, maxEvents, maxBytes uint64, ...) ([]Event, error)

+ func (store *Store) MerkleSnapshot(groupID string, maxLeaves, maxBytes uint64, manifest replica.Manifest, ...) (MerkleSnapshot, error)

type StoreConfig

+ HLCReplicaID string

v1.0.33

Aug 2, 2026

v1.0.32

Aug 2, 2026

Changes in this version

+ const StateVectorSubprotocol

+ const Subprotocol

+ var ErrClosed = errors.New("crdt durable: closed")

+ var ErrConflictingDot = errors.New("crdt durable: conflicting dot")

+ var ErrCorruptStore = errors.New("crdt durable: corrupt store")

+ var ErrInvalidConfig = errors.New("crdt durable: invalid configuration")

+ var ErrQueueFull = errors.New("crdt durable: queue full")

+ var ErrReplayUnavailable = errors.New("crdt durable: replay unavailable")

+ var ErrStateVectorUnavailable = errors.New("crdt durable: state-vector catch-up unavailable")

+ var ErrStoreFull = errors.New("crdt durable: operation log limit reached")

+ var ErrUnauthorized = errors.New("crdt durable: unauthorized")

+ func DecodeChange(data []byte, maxMessageBytes, maxActorBytes int) (replica.Dot, []byte, error)

+ func EncodeChange(change replica.Change) ([]byte, error)

+ type AppendResult struct

+ Duplicate bool

+ Event Event

+ type Authenticate func(*http.Request) (Peer, error)

+ type Authorize func(Peer, replica.Manifest, replica.Dot) error

+ type AuthorizeSubscription func(Peer, replica.Manifest) error

+ type ClientConfig struct

+ Cursor uint64

+ HTTPClient *http.Client

+ HandshakeTimeout time.Duration

+ Header http.Header

+ MaxActorBytes int

+ MaxMessageBytes int

+ MaxQueuedChanges int

+ MaxReconnectBackoff time.Duration

+ MaxStateVectorEntries int

+ MinReconnectBackoff time.Duration

+ OnCatchUp func(highWater uint64) error

+ OnEvent func(Event) error

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ Policy crdt.ProtocolPolicy

+ StateVector func() replica.Frontier

+ WriteTimeout time.Duration

+ type Config struct

+ Authenticate Authenticate

+ Authorize Authorize

+ AuthorizeSubscription AuthorizeSubscription

+ Groups []*Group

+ HandshakeTimeout time.Duration

+ MaxActorBytes int

+ MaxMessageBytes int

+ MaxQueuedBytes int

+ MaxQueuedEvents int

+ MaxReplayBytes int

+ MaxReplayEvents int

+ MaxStateVectorEntries int

+ OriginPatterns []string

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ RevalidateSubscription RevalidateSubscription

+ Store Log

+ Telemetry *telemetry.Reporter

+ WriteTimeout time.Duration

+ type Event struct

+ Change replica.Change

+ Sequence uint64

+ type Group struct

+ func NewGroup(config GroupConfig) (*Group, error)

+ func (group *Group) Manifest() replica.Manifest

+ type GroupConfig struct

+ Manifest replica.Manifest

+ Policy crdt.ProtocolPolicy

+ Validate Validate

+ type Handler struct

+ func NewHandler(config Config) (*Handler, error)

+ func (handler *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ type Log interface

+ Append func(groupID string, change replica.Change) (AppendResult, error)

+ Closed func() bool

+ Replay func(groupID string, after, maxEvents, maxBytes uint64, manifest replica.Manifest, ...) ([]Event, uint64, error)

+ type Peer struct

+ ID string

+ type ReconnectClient struct

+ func NewReconnectClient(endpoint string, manifest replica.Manifest, config ClientConfig) (*ReconnectClient, error)

+ func (client *ReconnectClient) Cursor() uint64

+ func (client *ReconnectClient) Err() error

+ func (client *ReconnectClient) Publish(ctx context.Context, change replica.Change) error

+ func (client *ReconnectClient) Run(ctx context.Context) error

+ type RevalidateSubscription func(Peer, replica.Manifest) error

+ type StateVectorLog interface

+ CatchUp func(groupID string, vector replica.Frontier, maxEvents, maxBytes uint64, ...) ([]Event, uint64, error)

+ type Store struct

+ func OpenStore(path string, config StoreConfig) (*Store, error)

+ func (store *Store) Append(groupID string, change replica.Change) (AppendResult, error)

+ func (store *Store) CatchUp(groupID string, vector replica.Frontier, maxEvents, maxBytes uint64, ...) ([]Event, uint64, error)

+ func (store *Store) Close() error

+ func (store *Store) Closed() bool

+ func (store *Store) Replay(groupID string, after, maxEvents, maxBytes uint64, manifest replica.Manifest, ...) ([]Event, uint64, error)

+ type StoreConfig struct

+ MaxBytes uint64

+ MaxEvents uint64

+ OpenTimeout time.Duration

+ type Validate func([]byte) error

Other modules containing this package

github.com/DarkInno/crdt

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL