interval

Documentation

Index

• type IntervalTask
  • func NewTask(name string, d time.Duration, mode TaskMode, doOnce bool, onExpired OnExpired) *IntervalTask
  • func (task *IntervalTask) Bytes() []byte
  • func (task *IntervalTask) Do() *IntervalTask
  • func (task *IntervalTask) Stop() bool
• type OnExpired
• type TaskMode

Types

type IntervalTask

type IntervalTask struct {
	// contains filtered or unexported fields
}

func NewTask

func NewTask(name string, d time.Duration, mode TaskMode, doOnce bool, onExpired OnExpired) *IntervalTask

func (*IntervalTask) Bytes

func (task *IntervalTask) Bytes() []byte

func (*IntervalTask) Do

func (task *IntervalTask) Do() *IntervalTask

func (*IntervalTask) Stop

func (task *IntervalTask) Stop() bool

type OnExpired

type OnExpired func(serializer common.Serializer) []byte

type TaskMode

type TaskMode uint8

const (
	Once TaskMode = iota
	Loop
)