strata

Apr 3, 2026

Changes in this version

type Config

+ FollowerWaitMode FollowerWaitMode

+ type FollowerWaitMode string

+ const FollowerWaitAll

+ const FollowerWaitNone

+ const FollowerWaitQuorum

Apr 2, 2026

Changes in this version

+ func Fork(ctx context.Context, sourceStore object.Store, branchID string) (checkpointKey string, err error)

+ func Unfork(ctx context.Context, sourceStore object.Store, branchID string) error

+ type BranchPoint struct

+ CheckpointKey string

+ SourceStore object.Store

type Config

+ AncestorStore object.Store

+ BranchPoint *BranchPoint

+ ReadConsistency ReadConsistency

+ WALSyncUpload *bool

type Node

+ func (n *Node) LinearizableCount(ctx context.Context, prefix string) (int64, error)

+ func (n *Node) LinearizableGet(ctx context.Context, key string) (*KeyValue, error)

+ func (n *Node) LinearizableList(ctx context.Context, prefix string) ([]*KeyValue, error)

+ func (n *Node) ReadConsistency() ReadConsistency

+ type ReadConsistency string

+ const ReadConsistencyLinearizable

+ const ReadConsistencySerializable

Mar 29, 2026

Changes in this version

+ var ErrCompacted = errors.New("strata: required revision has been compacted")

Mar 28, 2026

Changes in this version

+ var ErrClosed = errors.New("strata: node is closed")

Mar 27, 2026

Changes in this version

type Config

+ RestorePoint *RestorePoint

+ type PinnedObject struct

+ Key string

+ VersionID string

+ type RestorePoint struct

+ CheckpointArchive PinnedObject

+ Store object.VersionedStore

+ WALSegments []PinnedObject

Mar 27, 2026

Changes in this version

+ var ErrKeyExists = errors.New("strata: key already exists")

+ var ErrNotLeader = errors.New("strata: this node is not the leader; writes are rejected")

+ type Config struct

+ AdvertisePeerAddr string

+ CheckpointEntries int64

+ CheckpointInterval time.Duration

+ DataDir string

+ FollowerMaxRetries int

+ LeaderWatchInterval time.Duration

+ MetricsAddr string

+ NodeID string

+ ObjectStore object.Store

+ PeerBufferSize int

+ PeerClientTLS credentials.TransportCredentials

+ PeerListenAddr string

+ PeerServerTLS credentials.TransportCredentials

+ SegmentMaxAge time.Duration

+ SegmentMaxSize int64

+ type Event struct

+ KV *KeyValue

+ PrevKV *KeyValue

+ Type EventType

+ type EventType int

+ const EventDelete

+ const EventPut

+ type KeyValue struct

+ CreateRevision int64

+ Key string

+ Lease int64

+ PrevRevision int64

+ Revision int64

+ Value []byte

+ type Node struct

+ func Open(cfg Config) (*Node, error)

+ func (n *Node) Close() error

+ func (n *Node) Compact(ctx context.Context, revision int64) error

+ func (n *Node) CompactRevision() int64

+ func (n *Node) Config() Config

+ func (n *Node) Count(prefix string) (int64, error)

+ func (n *Node) Create(ctx context.Context, key string, value []byte, lease int64) (int64, error)

+ func (n *Node) CurrentRevision() int64

+ func (n *Node) Delete(ctx context.Context, key string) (int64, error)

+ func (n *Node) DeleteIfRevision(ctx context.Context, key string, revision int64) (int64, *KeyValue, bool, error)

+ func (n *Node) Get(key string) (*KeyValue, error)

+ func (n *Node) HandleForward(ctx context.Context, req *peer.ForwardRequest) (*peer.ForwardResponse, error)

+ func (n *Node) IsLeader() bool

+ func (n *Node) List(prefix string) ([]*KeyValue, error)

+ func (n *Node) Put(ctx context.Context, key string, value []byte, lease int64) (int64, error)

+ func (n *Node) Update(ctx context.Context, key string, value []byte, revision, lease int64) (int64, *KeyValue, bool, error)

+ func (n *Node) WaitForRevision(ctx context.Context, rev int64) error

+ func (n *Node) Watch(ctx context.Context, prefix string, startRev int64) (<-chan Event, error)