kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/v2v3/store.go

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 { … }

// mkPathDepth makes a path to a key that encodes its directory depth
// for fast directory listing. If a depth is provided, it is added
// to the computed depth.
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 { … }

// mkV2Node creates a V2 NodeExtern from a V3 KeyValue
func (s *v2v3Store) mkV2Node(kv *mvccpb.KeyValue) *v2store.NodeExtern { … }

// prevKeyFromPuts gets the prev key that is being put; ignores
// the put action response.
func prevKeyFromPuts(resp *clientv3.TxnResponse) *mvccpb.KeyValue { … }

func (s *v2v3Store) newSTM(applyf func(concurrency.STM) error) (*clientv3.TxnResponse, error) { … }