txn

May 14, 2015

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)