Versions in this module Expand all Collapse all v3 v3.4.16 Apr 15, 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 ErrEmptyWatcherRange = errors.New("mvcc: watcher range is empty") + var ErrFutureRev = errors.New("mvcc: required revision is a future revision") + var ErrRevisionNotFound = errors.New("mvcc: revision not found") + var ErrWatcherDuplicateID = errors.New("mvcc: duplicate watch ID provided on the WatchStream") + var ErrWatcherNotExist = errors.New("mvcc: watcher does not exist") + func NewStore(lg *zap.Logger, 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(lg *zap.Logger, b backend.Backend, le lease.Lessor, as auth.AuthStore, ...) ConsistentWatchableKV + type FilterFunc func(e mvccpb.Event) bool + type KV interface + Close func() error + Commit func() + Compact func(trace *traceutil.Trace, 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(trace *traceutil.Trace) TxnRead + Restore func(b backend.Backend) error + Write func(trace *traceutil.Trace) 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 StoreConfig struct + CompactionBatchLimit int + type TxnRead interface + End func() + type TxnWrite interface + Changes func() []mvccpb.KeyValue + func NewReadOnlyTxnWrite(txn TxnRead) TxnWrite + type WatchID int64 + const AutoWatchID + 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(id WatchID, key, end []byte, startRev int64, fcs ...FilterFunc) (WatchID, error) + 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) v3.4.15-cyral.1 Apr 15, 2021 Other modules containing this package github.com/cyralinc/etcd