add runnable examples

Author: MohamedAklamaash

examples/cron/main.go

@@ -0,0 +1,22 @@
+package main
+
+import (
+	"log"
+
+	"github.com/MohamedAklamaash/relay"
+)
+
+func main() {
+	scheduler := relay.NewScheduler(relay.RedisClientOpt{Addr: "127.0.0.1:6379"}, nil)
+
+	if _, err := scheduler.Register("*/1 * * * *", relay.NewTask("report:build", []byte(`{"kind":"minutely"}`))); err != nil {
+		log.Fatal(err)
+	}
+	if _, err := scheduler.Register("0 * * * *", relay.NewTask("email:send", []byte(`{"to":"ops@example.com","subject":"hourly"}`)), relay.Queue("critical")); err != nil {
+		log.Fatal(err)
+	}
+
+	if err := scheduler.Run(); err != nil {
+		log.Fatal(err)
+	}
+}

examples/producer/main.go

@@ -0,0 +1,46 @@
+package main
+
+import (
+	"encoding/json"
+	"log"
+	"time"
+
+	"github.com/MohamedAklamaash/relay"
+)
+
+type EmailPayload struct {
+	To      string `json:"to"`
+	Subject string `json:"subject"`
+}
+
+func main() {
+	client := relay.NewClient(relay.RedisClientOpt{Addr: "127.0.0.1:6379"})
+	defer client.Close()
+
+	payload, _ := json.Marshal(EmailPayload{To: "user@example.com", Subject: "welcome"})
+
+	now, err := client.Enqueue(relay.NewTask("email:send", payload), relay.Queue("critical"))
+	if err != nil {
+		log.Fatal(err)
+	}
+	log.Printf("enqueued immediate task %s", now.ID)
+
+	later, err := client.Enqueue(
+		relay.NewTask("report:build", []byte(`{"month":"june"}`)),
+		relay.ProcessIn(10*time.Second),
+		relay.MaxRetry(5),
+	)
+	if err != nil {
+		log.Fatal(err)
+	}
+	log.Printf("enqueued delayed task %s for %s", later.ID, later.NextProcessAt.Format(time.RFC3339))
+
+	_, err = client.Enqueue(
+		relay.NewTask("email:send", payload),
+		relay.Queue("critical"),
+		relay.Unique(time.Minute),
+	)
+	if err != nil {
+		log.Printf("second unique enqueue rejected as expected: %v", err)
+	}
+}

examples/worker/main.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"log"
+	"net/http"
+
+	"github.com/MohamedAklamaash/relay"
+)
+
+type EmailPayload struct {
+	To      string `json:"to"`
+	Subject string `json:"subject"`
+}
+
+func main() {
+	srv := relay.NewServer(relay.RedisClientOpt{Addr: "127.0.0.1:6379"}, relay.Config{
+		Concurrency: 10,
+		Queues:      map[string]int{"critical": 6, "default": 3, "low": 1},
+	})
+
+	mux := relay.NewServeMux()
+	mux.HandleFunc("email:send", handleEmail)
+	mux.HandleFunc("report:build", handleReport)
+
+	http.Handle("/metrics", relay.MetricsHandler())
+	go http.ListenAndServe(":2112", nil)
+
+	if err := srv.Run(mux); err != nil {
+		log.Fatal(err)
+	}
+}
+
+func handleEmail(ctx context.Context, t *relay.Task) error {
+	var p EmailPayload
+	if err := json.Unmarshal(t.Payload(), &p); err != nil {
+		return err
+	}
+	log.Printf("sending email to %s: %s", p.To, p.Subject)
+	return nil
+}
+
+func handleReport(ctx context.Context, t *relay.Task) error {
+	log.Printf("building report: %s", string(t.Payload()))
+	return nil
+}