options

Documentation

Index

• type MgrOptions
  • func Mgr() *MgrOptions
  • func (this *MgrOptions) Merge(deltas ...*MgrOptions)
  • func (this *MgrOptions) SetConcurrenceNum(a uint32)
  • func (this *MgrOptions) SetNormalTaskHandleDelta(a time.Duration)
  • func (this *MgrOptions) SetOrderTaskHandleDelta(a []time.Duration)

Types

type MgrOptions

type MgrOptions struct {
	ConcurrenceNum        uint32
	NormalTaskHandleDelta time.Duration
	OrderTaskHandleDelta  []time.Duration
}

func Mgr

func Mgr() *MgrOptions

func (*MgrOptions) Merge

func (this *MgrOptions) Merge(deltas ...*MgrOptions)

func (*MgrOptions) SetConcurrenceNum

func (this *MgrOptions) SetConcurrenceNum(a uint32)

最大并发数

func (*MgrOptions) SetNormalTaskHandleDelta

func (this *MgrOptions) SetNormalTaskHandleDelta(a time.Duration)

无顺序的任务，执行错误，等待多少再次执行

func (*MgrOptions) SetOrderTaskHandleDelta

func (this *MgrOptions) SetOrderTaskHandleDelta(a []time.Duration)

具有顺序的任务，需要强制执行完每一个，当其中一个报错的时候，重复执行的间隔