Tinker with naming

Author: nick-jones

internal/notification/aggregate.go

@@ -0,0 +1,22 @@
+package notification
+
+import "context"
+
+type MultiNotifier struct {
+	notifiers []Notifier
+}
+
+func NewMultiNotifier(notifiers []Notifier) *MultiNotifier {
+	return &MultiNotifier{
+		notifiers: notifiers,
+	}
+}
+
+func (an *MultiNotifier) Notify(ctx context.Context, notif Notification) error {
+	for _, n := range an.notifiers {
+		if err := n.Notify(ctx, notif); err != nil {
+			return err
+		}
+	}
+	return nil
+}

internal/notification/multi.go

@@ -68,7 +68,7 @@ func run(ctx context.Context) error {
 		conf.GKEClusterName,
 		k8sClient,
 		store,
-		notification.NewAggregateNotifier(notifiers),
+		notification.NewMultiNotifier(notifiers),
 	)
 
 	return watcher.Watch(ctx)