threshold

package

v0.1.0 Latest Latest Go to latest Published: Aug 1, 2023 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ThresholdExecute[ITEM any] struct {
	// contains filtered or unexported fields
}

ThresholdExecute 阈值执行, 超过阈值就执行. 必须调用AsyncExecute才能执行. 默认 batchsize 128 periodic 100ms

func NewThresholdExecute[ITEM any](itemDo func(i int, item ITEM)) *ThresholdExecute[ITEM]

func (exec *ThresholdExecute[ITEM]) AsyncExecute() *ThresholdExecute[ITEM]

AsyncExecute 返回自身. 方便与With设置连用

func (exec *ThresholdExecute[ITEM]) Collect(item ITEM)

Collect 收集数据

func (pe *ThresholdExecute[ITEM]) Stop()

Stop 停止执行

func (pe *ThresholdExecute[ITEM]) WithBatchSize(bsize int) *ThresholdExecute[ITEM]

func (pe *ThresholdExecute[ITEM]) WithBatchSizeHandler(itemSizeDo func(i int, item ITEM)) *ThresholdExecute[ITEM]

func (pe *ThresholdExecute[ITEM]) WithPeriodic(per time.Duration) *ThresholdExecute[ITEM]

func (pe *ThresholdExecute[ITEM]) WithPeriodicHandler(itemPeriodicDo func(i int, item ITEM)) *ThresholdExecute[ITEM]

func (pe *ThresholdExecute[ITEM]) WithRecover(recoverDo func(ierr any)) *ThresholdExecute[ITEM]