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

var defaultBatchLimit …

var defaultBatchInterval …

var defragLimit …

var InitialMmapSize …

var minSnapshotWarningTimeout …

type Backend …

type Snapshot …

type txReadBufferCache …

type backend …

type BackendConfig …

type BackendConfigOption …

func DefaultBackendConfig() BackendConfig { … }

func New(bcfg BackendConfig) Backend { … }

func WithMmapSize(size uint64) BackendConfigOption { … }

func NewDefaultBackend(path string, opts ...BackendConfigOption) Backend { … }

func newBackend(bcfg BackendConfig) *backend { … }

// BatchTx returns the current batch tx in coalescer. The tx can be used for read and
// write operations. The write result can be retrieved within the same tx immediately.
// The write result is isolated with other txs until the current one get committed.
func (b *backend) BatchTx() BatchTx { … }

func (b *backend) SetTxPostLockInsideApplyHook(hook func()) { … }

func (b *backend) ReadTx() ReadTx { … }

// ConcurrentReadTx creates and returns a new ReadTx, which:
// A) creates and keeps a copy of backend.readTx.txReadBuffer,
// B) references the boltdb read Tx (and its bucket cache) of current batch interval.
func (b *backend) ConcurrentReadTx() ReadTx { … }

// ForceCommit forces the current batching tx to commit.
func (b *backend) ForceCommit() { … }

func (b *backend) Snapshot() Snapshot { … }

func (b *backend) Hash(ignores func(bucketName, keyName []byte) bool) (uint32, error) { … }

func (b *backend) Size() int64 { … }

func (b *backend) SizeInUse() int64 { … }

func (b *backend) run() { … }

func (b *backend) Close() error { … }

// Commits returns total number of commits since start
func (b *backend) Commits() int64 { … }

func (b *backend) Defrag() error { … }

func (b *backend) defrag() error { … }

func defragdb(odb, tmpdb *bolt.DB, limit int) error { … }

func (b *backend) begin(write bool) *bolt.Tx { … }

func (b *backend) unsafeBegin(write bool) *bolt.Tx { … }

func (b *backend) OpenReadTxN() int64 { … }

type snapshot …

func (s *snapshot) Close() error { … }