scheduledevents

Documentation

Index

• func NumCurrentlyProcessing() int64
• func NumScheduledEvents() (n int, err error)
• func RegisterEventHandler(evt string, handler EvtHandler)
• func RemoveEvent(evt, data string) error
• func Run()
• func ScheduleEvent(evt, data string, when time.Time) error
• func Stop(wg *sync.WaitGroup)
• type EvtHandler

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