feat: Add start method for each sink

ethpandaops · Jun 27, 2024 · 1b86183 · 1b86183
1 parent a833e32
commit 1b86183
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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
 }