scheduledevents

package
v1.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 9, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NumCurrentlyProcessing

func NumCurrentlyProcessing() int64

func NumScheduledEvents

func NumScheduledEvents() (n int, err error)

func RegisterEventHandler

func RegisterEventHandler(evt string, handler EvtHandler)

func RemoveEvent

func RemoveEvent(evt, data string) error

func Run

func Run()

Checks for and handles scheduled events every minute

func ScheduleEvent

func ScheduleEvent(evt, data string, when time.Time) error

func Stop

func Stop(wg *sync.WaitGroup)

Types

type EvtHandler

type EvtHandler func(evt string) error

If error is not nil, it will be added back

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL