From 1b861833b80f5a562d6d566a3c168d77c1a5f95e Mon Sep 17 00:00:00 2001
From: Sam Calder-Mason <sam@puritydev.io>
Date: Thu, 27 Jun 2024 18:34:22 +1000
Subject: [PATCH] feat: Add start method for each sink

---
 pkg/server/service/event-ingester/ingester.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/pkg/server/service/event-ingester/ingester.go b/pkg/server/service/event-ingester/ingester.go
index 3407808e..24ec5bd9 100644
--- a/pkg/server/service/event-ingester/ingester.go
+++ b/pkg/server/service/event-ingester/ingester.go
@@ -51,6 +51,12 @@ func (e *Ingester) Start(ctx context.Context, grpcServer *grpc.Server) error {
 
 	xatu.RegisterEventIngesterServer(grpcServer, e)
 
+	for _, sink := range e.sinks {
+		if err := sink.Start(ctx); err != nil {
+			return err
+		}
+	}
+
 	return nil
 }