INNER CODE UNIT · Go

serviceHandlerMap

datastax-archive/kaskada · wren/main.go:321

		serviceHandlerMap := map[string]func(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) error{
			"materialization": v1alpha.RegisterMaterializationServiceHandlerFromEndpoint,
			"query":           v2alpha.RegisterQueryServiceHandlerFromEndpoint,
			"table":           v1alpha.RegisterTableServiceHandlerFromEndpoint,
			"view":            v1alpha.RegisterViewServiceHandlerFromEndpoint,
		}

		// Note: Make sure the gRPC server is running properly and accessible
		mux := runtime.NewServeMux()
		opts := []grpc.DialOption{grpc.WithInsecure()}
		wrenGrpcEndpoint := fmt.Sprintf("localhost:%d", *grpcPort)

		for service, handler := range serviceHandlerMap {
			if err := handler(ctx, mux, wrenGrpcEndpoint, opts); err != nil {
				log.Fatal().Err(err).Msgf("failed to register %s service", service)
			}
		}

View source record →