From d1e0c1ef61864187361a1d08aadab49103d1e3c4 Mon Sep 17 00:00:00 2001 From: Dipesh Dulal Date: Sat, 16 Jan 2021 10:58:28 +0545 Subject: [PATCH] feat: schedule an event after a minute --- main.go | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/main.go b/main.go index 73d742b..9f2d188 100644 --- a/main.go +++ b/main.go @@ -5,21 +5,14 @@ import ( "log" "os" "os/signal" + "time" "github.com/joho/godotenv" "github.com/dipeshdulal/event-scheduling/customevents" ) -// Event structure -type Event struct { - ID uint - Name string - Payload string - Locked string -} - -var eventListeners = map[string]func(d interface{}){ +var eventListeners = Listeners{ "SendEmail": customevents.SendEmail, "PayBills": customevents.PayBills, } @@ -37,6 +30,11 @@ func main() { db := initDBConnection() seedDB(db) + scheduler := NewScheduler(db, eventListeners) + scheduler.CheckDueEvents() + + scheduler.Schedule("SendEmail", "mail: nilkantha.dipesh@gmail.com", time.Now().Add(1*time.Minute)) + go func() { for range interrupt { log.Println("\n❌ Interrupt received closing...")