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

type BucketID …

type Bucket …

type BatchTx …

type batchTx …

// Lock is supposed to be called only by the unit test.
func (t *batchTx) Lock() { … }

func (t *batchTx) lock() { … }

func (t *batchTx) LockInsideApply() { … }

func (t *batchTx) LockOutsideApply() { … }

func (t *batchTx) Unlock() { … }

func (t *batchTx) RLock() { … }

func (t *batchTx) RUnlock() { … }

func (t *batchTx) UnsafeCreateBucket(bucket Bucket) { … }

func (t *batchTx) UnsafeDeleteBucket(bucket Bucket) { … }

// UnsafePut must be called holding the lock on the tx.
func (t *batchTx) UnsafePut(bucket Bucket, key []byte, value []byte) { … }

// UnsafeSeqPut must be called holding the lock on the tx.
func (t *batchTx) UnsafeSeqPut(bucket Bucket, key []byte, value []byte) { … }

func (t *batchTx) unsafePut(bucketType Bucket, key []byte, value []byte, seq bool) { … }

// UnsafeRange must be called holding the lock on the tx.
func (t *batchTx) UnsafeRange(bucketType Bucket, key, endKey []byte, limit int64) ([][]byte, [][]byte) { … }

func unsafeRange(c *bolt.Cursor, key, endKey []byte, limit int64) (keys [][]byte, vs [][]byte) { … }

// UnsafeDelete must be called holding the lock on the tx.
func (t *batchTx) UnsafeDelete(bucketType Bucket, key []byte) { … }

// UnsafeForEach must be called holding the lock on the tx.
func (t *batchTx) UnsafeForEach(bucket Bucket, visitor func(k, v []byte) error) error { … }

func unsafeForEach(tx *bolt.Tx, bucket Bucket, visitor func(k, v []byte) error) error { … }

// Commit commits a previous tx and begins a new writable one.
func (t *batchTx) Commit() { … }

// CommitAndStop commits the previous tx and does not create a new one.
func (t *batchTx) CommitAndStop() { … }

func (t *batchTx) safePending() int { … }

func (t *batchTx) commit(stop bool) { … }

type batchTxBuffered …

func newBatchTxBuffered(backend *backend) *batchTxBuffered { … }

func (t *batchTxBuffered) Unlock() { … }

func (t *batchTxBuffered) Commit() { … }

func (t *batchTxBuffered) CommitAndStop() { … }

func (t *batchTxBuffered) commit(stop bool) { … }

func (t *batchTxBuffered) unsafeCommit(stop bool) { … }

func (t *batchTxBuffered) UnsafePut(bucket Bucket, key []byte, value []byte) { … }

func (t *batchTxBuffered) UnsafeSeqPut(bucket Bucket, key []byte, value []byte) { … }

func (t *batchTxBuffered) UnsafeDelete(bucketType Bucket, key []byte) { … }

func (t *batchTxBuffered) UnsafeDeleteBucket(bucket Bucket) { … }