Versions in this module Expand all Collapse all v0 v0.12.0 Aug 27, 2026 v0.11.0 Aug 13, 2026 Changes in this version + const AbortedTS + const ConflictStoreCount + const DepthBuckets + const HorizonCapacity + const StoreAdjacency + const StoreEdgePropsHandle + const StoreEdgePropsOrd + const StoreEdgeTypes + const StoreEdgeTypesHandle + const StoreEdgeTypesOrd + const StoreNodeConstraint + const StoreNodeExistence + const StoreNodeLabels + const StoreNodeProperties + const StoreOther + const TxIDBase + var ErrSerializationConflict = errors.New(...) + func ConflictStoreIndex(store string) int + func ConflictStoreMetric(i int) string + func ConflictStoreName(i int) string + func Conflicts(headTS, startTS, txID uint64) bool + func DepthBucketLabel(i int) string + func DepthBucketLow(i int) int + func Visible(ts, startTS, txID uint64) bool + type Clock struct + func (c *Clock) AbandonCommitTS(ts uint64) + func (c *Clock) AwaitQuiescent(ctx context.Context) error + func (c *Clock) AwaitVisible(ctx context.Context, floor uint64) error + func (c *Clock) AwaitingVisible() int64 + func (c *Clock) InFlightCommits() uint64 + func (c *Clock) NextCommitTS() uint64 + func (c *Clock) NextTxID() uint64 + func (c *Clock) PublishCommitTS(ts uint64) + func (c *Clock) RatchetTo(floor uint64) uint64 + func (c *Clock) ReadTS() uint64 + type CommitInfo struct + func NewCommitInfo(txID uint64) *CommitInfo + func NewCommittedInfo(ts uint64) *CommitInfo + func (c *CommitInfo) Abort() + func (c *CommitInfo) Commit(commitTS uint64) + func (c *CommitInfo) TS() uint64 + type Conflict struct + HeadTS uint64 + StartTS uint64 + Store string + TxID uint64 + func NewConflict(store string, headTS, startTS, txID uint64) *Conflict + func (c *Conflict) ConcurrentWriter() bool + func (c *Conflict) Error() string + func (c *Conflict) Unwrap() error + type DepthHist struct + func (h *DepthHist) Load() Depths + func (h *DepthHist) Observe(depth int) + func (h *DepthHist) Reset() + type Depths struct + Buckets [DepthBuckets]uint64 + Deepest uint64 + func (d *Depths) Add(o Depths) + func (d *Depths) Chains() uint64 + type Gate struct + func (g *Gate) StrongLock() + func (g *Gate) StrongLockCtx(ctx context.Context) error + func (g *Gate) StrongUnlock() + func (g *Gate) TryWeakLock(hint uint64) (int, bool) + func (g *Gate) WeakHolders() int + func (g *Gate) WeakLock(hint uint64) int + func (g *Gate) WeakLockAuto() int + func (g *Gate) WeakLockCtx(ctx context.Context, hint uint64) (int, error) + func (g *Gate) WeakLockCtxAuto(ctx context.Context) (int, error) + func (g *Gate) WeakUnlock(slot int) + type Horizon struct + func (h *Horizon) Active() int + func (h *Horizon) Enter(startTS uint64) int + func (h *Horizon) EnterHolding() int + func (h *Horizon) Leave(slot int) + func (h *Horizon) Oldest(fallback uint64) uint64 + func (h *Horizon) Publish(slot int, startTS uint64) + func (h *Horizon) SlotState(slot int) (startTS uint64, occupied bool) + func (h *Horizon) StaleLeaves() int64 + func (h *Horizon) Unregistered() int64 + type Tx struct + func NewTx(st *TxState) Tx + func (tx Tx) ID() uint64 + func (tx Tx) Record() *CommitInfo + func (tx Tx) Valid() bool + type TxState struct + func (st *TxState) Arm(txID uint64) bool + func (st *TxState) Ensure() *CommitInfo + func (st *TxState) OpenRecord() *CommitInfo + func (st *TxState) Retract() (*CommitInfo, int64) + func (st *TxState) Reusable() bool + func (st *TxState) TxID() uint64 + type WriteCounters struct + func (c *WriteCounters) Abort(txID uint64) + func (c *WriteCounters) BeginWriter(txID uint64) + func (c *WriteCounters) Commit(txID uint64) + func (c *WriteCounters) Conflict(storeIdx int) + func (c *WriteCounters) EndWriter(txID uint64) + func (c *WriteCounters) Load() WriteCounts + func (c *WriteCounters) Writers() int64 + type WriteCounts struct + Aborts uint64 + ByStore [ConflictStoreCount]uint64 + Commits uint64 + Conflicts uint64 + Writers int64 + func (c *WriteCounts) ConflictRate() float64 + type WriteStamp struct + func (w *WriteStamp) AmbientResolutions() int64 + func (w *WriteStamp) Armed() bool + func (w *WriteStamp) Clock() *Clock + func (w *WriteStamp) End() (*CommitInfo, int64) + func (w *WriteStamp) EndFor(st *TxState) (*CommitInfo, int64) + func (w *WriteStamp) Info() *CommitInfo + func (w *WriteStamp) OpenInfo() *CommitInfo + func (w *WriteStamp) OpenTxID() uint64 + func (w *WriteStamp) Publish(st *TxState) + func (w *WriteStamp) SetClock(c *Clock) + func (w *WriteStamp) Stamp() (*CommitInfo, uint64) + func (w *WriteStamp) TakeAmbient() int64 + func (w *WriteStamp) TakeUntracked() int64 + func (w *WriteStamp) UntransactedStamp() (*CommitInfo, uint64)
Go to main page