Versions in this module Expand all Collapse all v0 v0.0.1 Oct 12, 2021 Changes in this version + const DocExists + const DocMissing + var ErrAborted = fmt.Errorf("transaction aborted") + var ErrChaos = fmt.Errorf("interrupted by chaos") + func SetChaos(c Chaos) + func SetDebug(debug bool) + func SetLogger(l log_Logger) + type Chaos struct + Breakpoint string + KillChance float64 + Slowdown time.Duration + SlowdownChance float64 + type Op struct + Assert interface{} + C string + Id interface{} + Insert interface{} + Remove bool + Update interface{} + type Runner struct + func NewRunner(tc *mgo.Collection) *Runner + func (r *Runner) ChangeLog(logc *mgo.Collection) + func (r *Runner) PurgeMissing(collections ...string) error + func (r *Runner) Resume(id bson.ObjectId) (err error) + func (r *Runner) ResumeAll() (err error) + func (r *Runner) Run(ops []Op, id bson.ObjectId, info interface{}) (err error)