ops

Documentation

Index

• type Op
  • 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(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(ctx context.Context) error
  • func (op *Op) Waitable() bool
• type OpDoneCB

Types

type Op

type Op struct {
	Impl       iops.IOpInternal
	ErrorC     chan error
	WaitedOnce atomic.Bool
	Worker     iworker.IOpWorker
	Err        error
	Result     any
	CreateTime time.Time
	StartTime  time.Time
	EndTime    time.Time
	DoneCB     OpDoneCB
	Observers  []iops.Observer
}

func NewOp

func NewOp(impl iops.IOpInternal, w iworker.IOpWorker) *Op

func (*Op) AddObserver

func (op *Op) AddObserver(o iops.Observer)

func (*Op) Execute

func (op *Op) Execute() error

func (*Op) GetCreateTime

func (op *Op) GetCreateTime() time.Time

func (*Op) GetEndTime

func (op *Op) GetEndTime() time.Time

func (*Op) GetError

func (op *Op) GetError() error

func (*Op) GetExecutTime

func (op *Op) GetExecutTime() int64

func (*Op) GetStartTime

func (op *Op) GetStartTime() time.Time

func (*Op) OnExec

func (op *Op) OnExec(ctx context.Context) error

func (*Op) PostExecute

func (op *Op) PostExecute() error

func (*Op) PreExecute

func (op *Op) PreExecute() error

func (*Op) Push

func (op *Op) Push() error

func (*Op) SetError

func (op *Op) SetError(err error)

func (*Op) WaitDone

func (op *Op) WaitDone(ctx context.Context) error

func (*Op) Waitable

func (op *Op) Waitable() bool

type OpDoneCB

type OpDoneCB = func(iops.IOp)