schedulex

Documentation

Index

• type HeapTaskPool
  • func NewHeapTaskPool(now base.FNNow) *HeapTaskPool
  • func (tp *HeapTaskPool) AddTask(key string, t time.Time, exec TaskFunc, params ...interface{}) error
  • func (tp *HeapTaskPool) RemoveTask(key string) error
  • func (tp *HeapTaskPool) Start()
  • func (tp *HeapTaskPool) Stop()
• type OpType
• type ScheduleTaskPool
  • func CreateHeapTaskPool() ScheduleTaskPool
  • func CreateHeapTaskPoolWithFNNow(now base.FNNow) ScheduleTaskPool
• type TaskFunc

Types

type HeapTaskPool

type HeapTaskPool struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewHeapTaskPool

func NewHeapTaskPool(now base.FNNow) *HeapTaskPool

func (*HeapTaskPool) AddTask

func (tp *HeapTaskPool) AddTask(key string, t time.Time, exec TaskFunc, params ...interface{}) error

func (*HeapTaskPool) RemoveTask

func (tp *HeapTaskPool) RemoveTask(key string) error

func (*HeapTaskPool) Start

func (tp *HeapTaskPool) Start()

func (*HeapTaskPool) Stop

func (tp *HeapTaskPool) Stop()

type OpType

type OpType int

type ScheduleTaskPool

type ScheduleTaskPool interface {
	AddTask(key string, t time.Time, exec TaskFunc, params ...any) error
	RemoveTask(key string) error

	Stop()
}

func CreateHeapTaskPool

func CreateHeapTaskPool() ScheduleTaskPool

func CreateHeapTaskPoolWithFNNow

func CreateHeapTaskPoolWithFNNow(now base.FNNow) ScheduleTaskPool

type TaskFunc

type TaskFunc func(key string, args ...any)