Versions in this module Expand all Collapse all v1 v1.0.0 Apr 9, 2023 Changes in this version + const DocExists + const DocMissing + var ErrAborted = errors.New("transaction aborted") + var ErrChaos = errors.New("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 any + C string + Id any + Insert any + Remove bool + Update any + 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 any) (err error)
Go to main page