Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConcurrentExecute ¶
type ConcurrentExecute[ITEM any] struct { // contains filtered or unexported fields }
ConcurrentExecute 定期并发
func NewConcurrentExecute ¶
func NewConcurrentExecute[ITEM any](periodic time.Duration, execDo func(i int, item *ITEM)) *ConcurrentExecute[ITEM]
func (*ConcurrentExecute[ITEM]) Collect ¶
func (pe *ConcurrentExecute[ITEM]) Collect(item *ITEM)
Collect 收集数据
func (*ConcurrentExecute[ITEM]) SetRecover ¶
func (pe *ConcurrentExecute[ITEM]) SetRecover(recoverDo func(ierr any))
type ExecuteCompensate ¶
type ExecuteCompensate[ITEM any] struct { // contains filtered or unexported fields }
ExecuteCompensate 时间补偿执行
func NewExecuteCompensate ¶
func NewExecuteCompensate[ITEM any](periodic time.Duration, execDo func(i int, item *ITEM)) *ExecuteCompensate[ITEM]
func (*ExecuteCompensate[ITEM]) Collect ¶
func (pe *ExecuteCompensate[ITEM]) Collect(item *ITEM)
Collect 收集数据
func (*ExecuteCompensate[ITEM]) SetRecover ¶
func (pe *ExecuteCompensate[ITEM]) SetRecover(recoverDo func(ierr any))
type ExecuteInterval ¶
type ExecuteInterval[ITEM any] struct { // contains filtered or unexported fields }
ExecuteInterval 时间间隔执行
func NewExecuteInterval ¶
func NewExecuteInterval[ITEM any](periodic time.Duration, execDo func(i int, item *ITEM)) *ExecuteInterval[ITEM]
func (*ExecuteInterval[ITEM]) Collect ¶
func (pe *ExecuteInterval[ITEM]) Collect(item *ITEM)
Collect 收集数据
func (*ExecuteInterval[ITEM]) SetRecover ¶
func (pe *ExecuteInterval[ITEM]) SetRecover(recoverDo func(ierr any))
Source Files
Click to show internal directories.
Click to hide internal directories.