durable

Aug 2, 2026

Changes in this version

+ const StateVectorSubprotocol

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

type ClientConfig

+ MaxStateVectorEntries int

+ OnCatchUp func(highWater uint64) error

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ StateVector func() replica.Frontier

type Config

+ MaxStateVectorEntries int

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ RevalidateSubscription RevalidateSubscription

+ 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

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

Jul 31, 2026

Changes in this version

type Config

+ Telemetry *telemetry.Reporter

Jul 30, 2026

Changes in this version

+ 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 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 Store

+ func (store *Store) Closed() bool

Jul 29, 2026

Changes in this version

+ 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 ErrStoreFull = errors.New("crdt durable: operation log limit reached")

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

+ 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

+ MinReconnectBackoff time.Duration

+ OnEvent func(Event) error

+ Policy crdt.ProtocolPolicy

+ 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

+ OriginPatterns []string

+ Store *Store

+ 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 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 Store struct

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

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

+ func (store *Store) Close() error

+ 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