transaction

Documentation

Index

• func Update(db *dbbadger.DB, f func(*Tx) error) error
• func WithTx(f func(*dbbadger.Txn) error) func(*Tx) error
• type Tx
  • func (b *Tx) OnSucceed(callback func())

Functions

func Update

func Update(db *dbbadger.DB, f func(*Tx) error) error

Update creates a badger transaction, passing it to a chain of functions, if all succeed. Useful to use callback to update cache in order to ensure data in badgerDB and cache are consistent.

func WithTx

func WithTx(f func(*dbbadger.Txn) error) func(*Tx) error

WithTx is useful when transaction is used without adding callback.

Types

type Tx

type Tx struct {
	DBTxn *dbbadger.Txn
	// contains filtered or unexported fields
}

func (*Tx) OnSucceed

func (b *Tx) OnSucceed(callback func())

OnSucceed adds a callback to execute after the batch has been successfully flushed. useful for implementing the cache where we will only cache after the batch has been successfully flushed