Versions in this module Expand all Collapse all v1 v1.0.0 Jan 8, 2021 Changes in this version + var DefaultIgnores map[backend.IgnoreKey]struct + var ErrCanceled = errors.New("mvcc: watcher is canceled") + var ErrClosed = errors.New("mvcc: closed") + var ErrCompacted = errors.New("mvcc: required revision has been compacted") + var ErrFutureRev = errors.New("mvcc: required revision is a future revision") + var ErrRevisionNotFound = errors.New("mvcc: revision not found") + var ErrWatcherNotExist = errors.New("mvcc: watcher does not exist") + func NewStore(b backend.Backend, le lease.Lessor, ig ConsistentIndexGetter) *store + func ReportEventReceived(n int) + func UpdateConsistentIndex(be backend.Backend, index uint64) + func WriteKV(be backend.Backend, kv mvccpb.KeyValue) + type ConsistentIndexGetter interface + ConsistentIndex func() uint64 + type ConsistentWatchableKV interface + ConsistentIndex func() uint64 + func New(b backend.Backend, le lease.Lessor, ig ConsistentIndexGetter) ConsistentWatchableKV + type FilterFunc func(e mvccpb.Event) bool + type KV interface + Close func() error + Commit func() + Compact func(rev int64) (<-chan struct{}, error) + Hash func() (hash uint32, revision int64, err error) + HashByRev func(rev int64) (hash uint32, revision int64, compactRev int64, err error) + Read func() TxnRead + Restore func(b backend.Backend) error + Write func() TxnWrite + type RangeOptions struct + Count bool + Limit int64 + Rev int64 + type RangeResult struct + Count int + KVs []mvccpb.KeyValue + Rev int64 + type ReadView interface + FirstRev func() int64 + Range func(key, end []byte, ro RangeOptions) (r *RangeResult, err error) + Rev func() int64 + type TxnRead interface + End func() + type TxnWrite interface + Changes func() []mvccpb.KeyValue + func NewReadOnlyTxnWrite(txn TxnRead) TxnWrite + type WatchID int64 + type WatchResponse struct + CompactRevision int64 + Events []mvccpb.Event + Revision int64 + WatchID WatchID + type WatchStream interface + Cancel func(id WatchID) error + Chan func() <-chan WatchResponse + Close func() + RequestProgress func(id WatchID) + Rev func() int64 + Watch func(key, end []byte, startRev int64, fcs ...FilterFunc) WatchID + type Watchable interface + NewWatchStream func() WatchStream + type WatchableKV interface + type WriteView interface + DeleteRange func(key, end []byte) (n, rev int64) + Put func(key, value []byte, lease lease.LeaseID) (rev int64) Incompatible versions in this module v3.3.27+incompatible Aug 25, 2020