scheduledevents

Documentation

Index

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

Functions

func NumCurrentlyProcessing

func NumCurrentlyProcessing() int64

func NumScheduledEvents

func NumScheduledEvents(client *redis.Client) (int, error)

func RegisterEventHandler

func RegisterEventHandler(evt string, handler EvtHandler)

func RemoveEvent

func RemoveEvent(client *redis.Client, evt, data string) error

func Run

func Run()

Checks for and handles scheduled events every minute

func ScheduleEvent

func ScheduleEvent(client *redis.Client, 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