From f9e2bca7a19d00bab8c791e364d9db637e07bbcd Mon Sep 17 00:00:00 2001 From: Phillip Michelsen Date: Tue, 23 Sep 2025 02:12:16 +0800 Subject: [PATCH] Added registry to setup in main.go --- services/data_service/cmd/data_service/main.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/services/data_service/cmd/data_service/main.go b/services/data_service/cmd/data_service/main.go index 3d50fe4..aac2c7a 100644 --- a/services/data_service/cmd/data_service/main.go +++ b/services/data_service/cmd/data_service/main.go @@ -13,6 +13,7 @@ import ( "gitlab.michelsen.id/phillmichelsen/tessera/services/data_service/internal/provider/providers/test" "gitlab.michelsen.id/phillmichelsen/tessera/services/data_service/internal/router" "gitlab.michelsen.id/phillmichelsen/tessera/services/data_service/internal/server" + "gitlab.michelsen.id/phillmichelsen/tessera/services/data_service/internal/worker" "google.golang.org/grpc" "google.golang.org/grpc/reflection" ) @@ -56,8 +57,10 @@ func main() { slog.Info("starting", "svc", "data-service") // Setup + wr := worker.NewRegistry() + r := router.NewRouter(2048) - m := manager.NewManager(r) + m := manager.NewManager(r, wr) // Providers