type v2v3Store …
const maxPathDepth …
var errUnsupported …
func NewStore(c *clientv3.Client, pfx string) v2store.Store { … }
func newStore(c *clientv3.Client, pfx string) *v2v3Store { … }
func (s *v2v3Store) Index() uint64 { … }
func (s *v2v3Store) Get(nodePath string, recursive, sorted bool) (*v2store.Event, error) { … }
func (s *v2v3Store) getDir(nodePath string, recursive, sorted bool, rev int64) ([]*v2store.NodeExtern, error) { … }
func (s *v2v3Store) getDirDepth(nodePath string, depth int, rev int64) ([]*v2store.NodeExtern, error) { … }
func (s *v2v3Store) Set(
nodePath string,
dir bool,
value string,
expireOpts v2store.TTLOptionSet,
) (*v2store.Event, error) { … }
func (s *v2v3Store) Update(nodePath, newValue string, expireOpts v2store.TTLOptionSet) (*v2store.Event, error) { … }
func (s *v2v3Store) Create(
nodePath string,
dir bool,
value string,
unique bool,
expireOpts v2store.TTLOptionSet,
) (*v2store.Event, error) { … }
func (s *v2v3Store) CompareAndSwap(
nodePath string,
prevValue string,
prevIndex uint64,
value string,
expireOpts v2store.TTLOptionSet,
) (*v2store.Event, error) { … }
func (s *v2v3Store) Delete(nodePath string, dir, recursive bool) (*v2store.Event, error) { … }
func (s *v2v3Store) deleteEmptyDir(nodePath string) (*v2store.Event, error) { … }
func (s *v2v3Store) deleteNode(nodePath string) (*v2store.Event, error) { … }
func (s *v2v3Store) CompareAndDelete(nodePath, prevValue string, prevIndex uint64) (*v2store.Event, error) { … }
func compareFail(nodePath, prevValue string, prevIndex uint64, resp *clientv3.TxnResponse) error { … }
func (s *v2v3Store) mkCompare(nodePath, prevValue string, prevIndex uint64) []clientv3.Cmp { … }
func (s *v2v3Store) JsonStats() []byte { … }
func (s *v2v3Store) DeleteExpiredKeys(cutoff time.Time) { … }
func (s *v2v3Store) Version() int { … }
func (s *v2v3Store) Save() ([]byte, error) { … }
func (s *v2v3Store) Recovery(state []byte) error { … }
func (s *v2v3Store) Clone() v2store.Store { … }
func (s *v2v3Store) SaveNoCopy() ([]byte, error) { … }
func (s *v2v3Store) HasTTLKeys() bool { … }
func (s *v2v3Store) mkPath(nodePath string) string { … }
func (s *v2v3Store) mkNodePath(p string) string { … }
func (s *v2v3Store) mkPathDepth(nodePath string, depth int) string { … }
func (s *v2v3Store) mkActionKey() string { … }
func isRoot(s string) bool { … }
func mkV2Rev(v3Rev int64) uint64 { … }
func mkV3Rev(v2Rev uint64) int64 { … }
func (s *v2v3Store) mkV2Node(kv *mvccpb.KeyValue) *v2store.NodeExtern { … }
func prevKeyFromPuts(resp *clientv3.TxnResponse) *mvccpb.KeyValue { … }
func (s *v2v3Store) newSTM(applyf func(concurrency.STM) error) (*clientv3.TxnResponse, error) { … }