Documentation
¶
Index ¶
- type 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(ctx context.Context) 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Op ¶
type Op struct {
Impl iops.IOpInternal
ErrorC chan error
Worker iworker.IOpWorker
Err error
Result any
CreateTime time.Time
StartTime time.Time
EndTime time.Time
DoneCB OpDoneCB
Observers []iops.Observer
}
func (*Op) AddObserver ¶
func (*Op) GetCreateTime ¶
func (*Op) GetEndTime ¶
func (*Op) GetExecutTime ¶
func (*Op) GetStartTime ¶
func (*Op) PostExecute ¶
func (*Op) PreExecute ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.