Documentation
¶
Index ¶
- type Event
- type EventTriggeredExecute
- func (be *EventTriggeredExecute[PARAMS]) CoverExecute(e Event, execDo func(params *Params[PARAMS]), recoverDo func(ierr any))
- func (be *EventTriggeredExecute[PARAMS]) Notify(e Event, params *PARAMS)
- func (be *EventTriggeredExecute[PARAMS]) RegisterExecute(execDo func(params *Params[PARAMS]), recoverDo func(ierr any)) Event
- func (be *EventTriggeredExecute[PARAMS]) SetShared(e Event, v any)
- type Params
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventTriggeredExecute ¶
type EventTriggeredExecute[PARAMS any] struct { // contains filtered or unexported fields }
EventTriggeredExecute 包含已注册的执行事件列表
func NewEventTriggeredExecute ¶
func NewEventTriggeredExecute[PARAMS any]() *EventTriggeredExecute[PARAMS]
NewEventTriggeredExecute构造函数
func (*EventTriggeredExecute[PARAMS]) CoverExecute ¶
func (be *EventTriggeredExecute[PARAMS]) CoverExecute(e Event, execDo func(params *Params[PARAMS]), recoverDo func(ierr any))
CoverExecute用来覆盖一个已注册的执行单元 通过事件号定位并替换为新函数
func (*EventTriggeredExecute[PARAMS]) Notify ¶
func (be *EventTriggeredExecute[PARAMS]) Notify(e Event, params *PARAMS)
Notify用于通知触发执行 根据事件号查找执行单元并检查通知次数 达到指定次数则触发goroutine异步执行
func (*EventTriggeredExecute[PARAMS]) RegisterExecute ¶
func (be *EventTriggeredExecute[PARAMS]) RegisterExecute(execDo func(params *Params[PARAMS]), recoverDo func(ierr any)) Event
RegisterExecute注册一个执行单元 返回分配的事件号
func (*EventTriggeredExecute[PARAMS]) SetShared ¶
func (be *EventTriggeredExecute[PARAMS]) SetShared(e Event, v any)
Click to show internal directories.
Click to hide internal directories.