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() {}