Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + type Op struct + CreateTime time.Time + DoneCB OpDoneCB + EndTime time.Time + Err error + ErrorC chan error + Impl iops.IOpInternal + Observers []iops.Observer + Result interface{} + StartTime time.Time + Worker iworker.IOpWorker + func NewOp(impl iops.IOpInternal, w iworker.IOpWorker) *Op + func (op *Op) AddObserver(o iops.Observer) + func (op *Op) Execute() error + func (op *Op) GetCreateTime() time.Time + func (op *Op) GetEndTime() time.Time + func (op *Op) GetError() error + func (op *Op) GetExecutTime() int64 + func (op *Op) GetStartTime() time.Time + func (op *Op) OnExec() error + func (op *Op) PostExecute() error + func (op *Op) PreExecute() error + func (op *Op) Push() error + func (op *Op) SetError(err error) + func (op *Op) WaitDone() error + func (op *Op) Waitable() bool + type OpDoneCB = func(iops.IOp)
Go to main page