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

const bucketBufferInitialSize …

type txBuffer …

func (txb *txBuffer) reset() { … }

type txWriteBuffer …

func (txw *txWriteBuffer) put(bucket Bucket, k, v []byte) { … }

func (txw *txWriteBuffer) putSeq(bucket Bucket, k, v []byte) { … }

func (txw *txWriteBuffer) putInternal(bucket Bucket, k, v []byte) { … }

func (txw *txWriteBuffer) reset() { … }

func (txw *txWriteBuffer) writeback(txr *txReadBuffer) { … }

type txReadBuffer …

func (txr *txReadBuffer) Range(bucket Bucket, key, endKey []byte, limit int64) ([][]byte, [][]byte) { … }

func (txr *txReadBuffer) ForEach(bucket Bucket, visitor func(k, v []byte) error) error { … }

// unsafeCopy returns a copy of txReadBuffer, caller should acquire backend.readTx.RLock()
func (txr *txReadBuffer) unsafeCopy() txReadBuffer { … }

type kv …

type bucketBuffer …

func newBucketBuffer() *bucketBuffer { … }

func (bb *bucketBuffer) Range(key, endKey []byte, limit int64) (keys [][]byte, vals [][]byte) { … }

func (bb *bucketBuffer) ForEach(visitor func(k, v []byte) error) error { … }

func (bb *bucketBuffer) add(k, v []byte) { … }

// merge merges data from bbsrc into bb.
func (bb *bucketBuffer) merge(bbsrc *bucketBuffer) { … }

func (bb *bucketBuffer) Len() int { … }

func (bb *bucketBuffer) Less(i, j int) bool { … }

func (bb *bucketBuffer) Swap(i, j int) { … }

func (bb *bucketBuffer) Copy() *bucketBuffer { … }