cron

Documentation

Index

• func StartCron(quit chan bool, rp *redis.Pool, name string, interval time.Duration, ...)
• type Function

Functions

func StartCron

func StartCron(quit chan bool, rp *redis.Pool, name string, interval time.Duration, cronFunc Function)

StartCron calls the passed in function every minute, making sure it acquires a lock so that only one process is running at once. Note that across processes crons may be called more often than duration as there is no inter-process coordination of cron fires. (this might be a worthy addition)

Types

type Function

type Function func(lockName string, lockValue string) error

Function is the function that will be called on our schedule