badgerBuffer

Documentation

Index

• type BadgerBuffer
  • func NewBadgerBuffer(size int, db *badger.DB, cond *sync.Cond, sharedCond *atomic.Bool) (*BadgerBuffer, error)
  • func (bb *BadgerBuffer) Add(key, val []byte) error
  • func (bb *BadgerBuffer) Flush() error

Types

type BadgerBuffer

type BadgerBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBadgerBuffer

func NewBadgerBuffer(size int, db *badger.DB, cond *sync.Cond, sharedCond *atomic.Bool) (*BadgerBuffer, error)

func (*BadgerBuffer) Add

func (bb *BadgerBuffer) Add(key, val []byte) error

func (*BadgerBuffer) Flush

func (bb *BadgerBuffer) Flush() error