add cm and log when complete

Signed-off-by: Troy Connor <troy0820@users.noreply.github.com>

Author: troy0820

controllers/types.go

@@ -10,6 +10,10 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
+const (
+	PorterNamespace = "porter-operator-system"
+)
+
 type PorterClient interface {
 	ListInstallations(ctx context.Context, in *installationv1.ListInstallationsRequest, opts ...grpc.CallOption) (*installationv1.ListInstallationsResponse, error)
 	ListInstallationLatestOutputs(ctx context.Context, in *installationv1.ListInstallationLatestOutputRequest, opts ...grpc.CallOption) (*installationv1.ListInstallationLatestOutputResponse, error)
@@ -20,9 +24,22 @@ type ClientConn interface {
 }
 
 var GrpcDeployment = &appsv1.Deployment{
-	ObjectMeta: metav1.ObjectMeta{},
+	ObjectMeta: metav1.ObjectMeta{
+		Name:      "",
+		Namespace: PorterNamespace,
+	},
 }
 
 var GrpcService = &corev1.Service{
-	ObjectMeta: metav1.ObjectMeta{},
+	ObjectMeta: metav1.ObjectMeta{
+		Name:      "",
+		Namespace: PorterNamespace,
+	},
+}
+
+var GrpcConfigMap = &corev1.ConfigMap{
+	ObjectMeta: metav1.ObjectMeta{
+		Name:      "",
+		Namespace: PorterNamespace,
+	},
 }

main.go

@@ -127,6 +127,7 @@ func main() {
 	}
 
 	if createGrpc {
+		// TODO: should this be one go routine or several?
 		g, ctx := errgroup.WithContext(ctx)
 		g.Go(func() error {
 			k8sClient := mgr.GetClient()
@@ -135,6 +136,7 @@ func main() {
 			err := k8sClient.Get(ctx, types.NamespacedName{Name: controllers.GrpcDeployment.Name, Namespace: controllers.GrpcDeployment.Namespace}, deployment)
 			if err != nil {
 				if apierrors.IsNotFound(err) {
+					setupLog.Info("creating grpc deployment")
 					return k8sClient.Create(ctx, controllers.GrpcDeployment, &client.CreateOptions{})
 				}
 			}
@@ -148,18 +150,34 @@ func main() {
 			err := k8sClient.Get(ctx, types.NamespacedName{Name: controllers.GrpcService.Name, Namespace: controllers.GrpcService.Namespace}, service)
 			if err != nil {
 				if apierrors.IsNotFound(err) {
+					setupLog.Info("creating grpc service")
 					return k8sClient.Create(ctx, controllers.GrpcService, &client.CreateOptions{})
 				}
 			}
 			// NOTE: Don't crash, just don't deploy if Get fails for any other reason than not found
 			return nil
 		})
 
+		g.Go(func() error {
+			k8sClient := mgr.GetClient()
+			cm := &corev1.ConfigMap{}
+			err := k8sClient.Get(ctx, types.NamespacedName{Name: controllers.GrpcConfigMap.Name, Namespace: controllers.GrpcConfigMap.Namespace}, cm)
+			if err != nil {
+				if apierrors.IsNotFound(err) {
+					setupLog.Info("creating grpc configmap")
+					return k8sClient.Create(ctx, controllers.GrpcConfigMap, &client.CreateOptions{})
+				}
+			}
+			// NOTE: Don't crash, just don't deploy if Get fails for any other reason than not found
+			return nil
+		})
+
 		go func() {
 			if err := g.Wait(); err != nil {
 				setupLog.Error(err, "error with async operation of creating grpc deployment")
 				os.Exit(1)
 			}
+			setupLog.Info("grpc server has been created")
 		}()
 	}