test(examples): update observer API usage

Author: cmilesio

examples/channelobserver-observe/main.go

@@ -5,15 +5,19 @@
 
 package main
 
-import "github.com/goforj/queue"
+import (
+	"context"
+
+	"github.com/goforj/queue"
+)
 
 func main() {
 	// Observe forwards an event to the configured channel.
 
 	// Example: channel observer
 	ch := make(chan queue.Event, 1)
 	observer := queue.ChannelObserver{Events: ch}
-	observer.Observe(queue.Event{Kind: queue.EventProcessStarted, Queue: "default"})
+	observer.Observe(context.Background(), queue.Event{Kind: queue.EventProcessStarted, Queue: "default"})
 	event := <-ch
 	_ = event
 }

examples/multiobserver/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"github.com/goforj/queue"
 )
@@ -17,9 +18,9 @@ func main() {
 	events := make(chan queue.Event, 2)
 	observer := queue.MultiObserver(
 		queue.ChannelObserver{Events: events},
-		queue.ObserverFunc(func(queue.Event) {}),
+		queue.ObserverFunc(func(context.Context, queue.Event) {}),
 	)
-	observer.Observe(queue.Event{Kind: queue.EventEnqueueAccepted})
+	observer.Observe(context.Background(), queue.Event{Kind: queue.EventEnqueueAccepted})
 	fmt.Println(len(events))
 	// Output: 1
 }

examples/observeall/main.go

@@ -22,7 +22,7 @@ func main() {
 	var flakyAttempts atomic.Int32
 	ctx := context.Background()
 
-	runtimeObserver := queue.ObserverFunc(func(event queue.Event) {
+	runtimeObserver := queue.ObserverFunc(func(ctx context.Context, event queue.Event) {
 		logger.Info("runtime event",
 			"kind", event.Kind,
 			"driver", event.Driver,
@@ -35,7 +35,7 @@ func main() {
 		)
 	})
 
-	workflowObserver := queue.WorkflowObserverFunc(func(event queue.WorkflowEvent) {
+	workflowObserver := queue.WorkflowObserverFunc(func(ctx context.Context, event queue.WorkflowEvent) {
 		logger.Info("workflow event",
 			"kind", event.Kind,
 			"dispatch_id", event.DispatchID,

examples/observer-observe/main.go

@@ -5,14 +5,18 @@
 
 package main
 
-import "github.com/goforj/queue"
+import (
+	"context"
+
+	"github.com/goforj/queue"
+)
 
 func main() {
 	// Observe handles a queue runtime event.
 
 	// Example: observe runtime event
 	var observer queue.Observer
-	observer.Observe(queue.Event{
+	observer.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventEnqueueAccepted,
 		Driver: queue.DriverSync,
 		Queue:  "default",

examples/observerfunc-observe/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"github.com/goforj/queue"
 	"log/slog"
 	"os"
@@ -16,7 +17,7 @@ func main() {
 
 	// Example: observer func logging hook
 	logger := slog.New(slog.NewTextHandler(os.Stdout, nil))
-	observer := queue.ObserverFunc(func(event queue.Event) {
+	observer := queue.ObserverFunc(func(ctx context.Context, event queue.Event) {
 		logger.Info("queue event",
 			"kind", event.Kind,
 			"driver", event.Driver,
@@ -28,10 +29,10 @@ func main() {
 			"err", event.Err,
 		)
 	})
-	observer.Observe(queue.Event{
-		Kind:     queue.EventProcessSucceeded,
-		Driver:   queue.DriverSync,
-		Queue:    "default",
+	observer.Observe(context.Background(), queue.Event{
+		Kind:    queue.EventProcessSucceeded,
+		Driver:  queue.DriverSync,
+		Queue:   "default",
 		JobType: "emails:send",
 	})
 }

examples/statscollector-observe/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"github.com/goforj/queue"
 	"time"
 )
@@ -15,7 +16,7 @@ func main() {
 
 	// Example: observe event
 	collector := queue.NewStatsCollector()
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventEnqueueAccepted,
 		Driver: queue.DriverSync,
 		Queue:  "default",

examples/statscollector-snapshot/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"github.com/goforj/queue"
 	"time"
@@ -16,24 +17,24 @@ func main() {
 
 	// Example: snapshot print
 	collector := queue.NewStatsCollector()
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventEnqueueAccepted,
 		Driver: queue.DriverSync,
 		Queue:  "default",
 		Time:   time.Now(),
 	})
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventProcessStarted,
 		Driver: queue.DriverSync,
 		Queue:  "default",
 		JobKey: "job-1",
 		Time:   time.Now(),
 	})
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:     queue.EventProcessSucceeded,
 		Driver:   queue.DriverSync,
 		Queue:    "default",
-		JobKey:  "job-1",
+		JobKey:   "job-1",
 		Duration: 12 * time.Millisecond,
 		Time:     time.Now(),
 	})

examples/statssnapshot-paused/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"github.com/goforj/queue"
 	"time"
@@ -16,7 +17,7 @@ func main() {
 
 	// Example: paused count getter
 	collector := queue.NewStatsCollector()
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventQueuePaused,
 		Driver: queue.DriverSync,
 		Queue:  "default",

examples/statssnapshot-queue/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"github.com/goforj/queue"
 	"time"
@@ -16,7 +17,7 @@ func main() {
 
 	// Example: queue counters getter
 	collector := queue.NewStatsCollector()
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventEnqueueAccepted,
 		Driver: queue.DriverSync,
 		Queue:  "default",

examples/statssnapshot-queues/main.go

@@ -6,6 +6,7 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"github.com/goforj/queue"
 	"time"
@@ -16,7 +17,7 @@ func main() {
 
 	// Example: list queues
 	collector := queue.NewStatsCollector()
-	collector.Observe(queue.Event{
+	collector.Observe(context.Background(), queue.Event{
 		Kind:   queue.EventEnqueueAccepted,
 		Driver: queue.DriverSync,
 		Queue:  "critical",