kubernetes/vendor/go.etcd.io/etcd/server/v3/mvcc/backend/read_tx.go

type ReadTx …

type baseReadTx …

func (baseReadTx *baseReadTx) UnsafeForEach(bucket Bucket, visitor func(k, v []byte) error) error { … }

func (baseReadTx *baseReadTx) UnsafeRange(bucketType Bucket, key, endKey []byte, limit int64) ([][]byte, [][]byte) { … }

type readTx …

func (rt *readTx) Lock()    { … }

func (rt *readTx) Unlock()  { … }

func (rt *readTx) RLock()   { … }

func (rt *readTx) RUnlock() { … }

func (rt *readTx) reset() { … }

type concurrentReadTx …

func (rt *concurrentReadTx) Lock()   { … }

func (rt *concurrentReadTx) Unlock() { … }

// RLock is no-op. concurrentReadTx does not need to be locked after it is created.
func (rt *concurrentReadTx) RLock() { … }

// RUnlock signals the end of concurrentReadTx.
func (rt *concurrentReadTx) RUnlock() { … }