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