|
|
@@ -0,0 +1,23 @@ |
|
|
|
package main |
|
|
|
|
|
|
|
import "fmt" |
|
|
|
import "time" |
|
|
|
import "github.com/bamzi/jobrunner" |
|
|
|
|
|
|
|
func main() { |
|
|
|
jobrunner.Start() // optional: jobrunner.Start(pool int, concurrent int) (10, 1) |
|
|
|
jobrunner.Schedule("@every 5s", ReminderEmails{}) |
|
|
|
time.Sleep(time.Second * 30) |
|
|
|
} |
|
|
|
|
|
|
|
// Job Specific Functions |
|
|
|
type ReminderEmails struct { |
|
|
|
// filtered |
|
|
|
} |
|
|
|
|
|
|
|
// ReminderEmails.Run() will get triggered automatically. |
|
|
|
func (e ReminderEmails) Run() { |
|
|
|
// Queries the DB |
|
|
|
// Sends some email |
|
|
|
fmt.Printf("Every 5 sec send reminder emails \n") |
|
|
|
} |