lmdbsync

Apr 7, 2016

Changes in this version

+ var MapResizedDefaultDelay = ExponentialBackoff(time.Millisecond, 5 * time.Millisecond, 2)

+ var MapResizedDefaultRetry = 2

+ type DelayFunc func(attempt int) time.Duration

+ func ExponentialBackoff(base time.Duration, max time.Duration, factor float64) DelayFunc

Oct 16, 2015

Changes in this version

+ var ErrTxnRetry = errors.New("lmdbsync: retry failed txn")

type Env

+ func (r *Env) BeginTxn(parent *lmdb.Txn, flags uint) (*lmdb.Txn, error)

Oct 12, 2015

Changes in this version

+ var DefaultDelayRepeatResize = time.Millisecond

+ var DefaultRetryResize = 2

+ var RetryTxn = errors.New("lmdbsync: retry failed txn")

+ type Bag interface

+ Value func(key interface{}) interface{}

+ func Background() Bag

+ func BagWith(b Bag, key, value interface{}) Bag

+ type Env struct

+ Handlers HandlerChain

+ func BagEnv(b Bag) *Env

+ func NewEnv(env *lmdb.Env, h ...Handler) (*Env, error)

+ func (r *Env) Open(path string, flags uint, mode os.FileMode) error

+ func (r *Env) RunTxn(flags uint, op lmdb.TxnOp) (err error)

+ func (r *Env) SetFlags(flags uint) error

+ func (r *Env) SetMapSize(size int64) error

+ func (r *Env) UnsetFlags(flags uint) error

+ func (r *Env) Update(op lmdb.TxnOp) error

+ func (r *Env) UpdateLocked(op lmdb.TxnOp) error

+ func (r *Env) View(op lmdb.TxnOp) error

+ func (r *Env) WithHandler(h Handler) TxnRunner

+ type Handler interface

+ HandleTxnErr func(c Bag, err error) (Bag, error)

+ func MapFullHandler(fn MapFullFunc) Handler

+ func MapResizedHandler(maxRetry int, repeatDelay func(retry int) time.Duration) Handler

+ type HandlerChain []Handler

+ func (c HandlerChain) Append(h Handler) HandlerChain

+ func (c HandlerChain) HandleTxnErr(b Bag, err error) (Bag, error)

+ type HandlerFunc func(c Bag, err error) (Bag, error)

+ func (fn HandlerFunc) HandleTxnErr(c Bag, err error) (Bag, error)

+ type MapFullFunc func(size int64) (int64, bool)

+ type TxnRunner interface

+ RunTxn func(flags uint, op lmdb.TxnOp) error

+ Update func(op lmdb.TxnOp) error

+ UpdateLocked func(op lmdb.TxnOp) error

+ View func(op lmdb.TxnOp) error

+ WithHandler func(h Handler) TxnRunner