Basic ServiceExport controller life-cycle + Cloud Map client interface

Author: vanekjar

Dockerfile

@@ -11,8 +11,8 @@ RUN go mod download
 
 # Copy the go source
 COPY main.go main.go
-COPY api/ api/
-COPY controllers/ controllers/
+COPY pkg/api api/
+COPY pkg/controllers controllers/
 
 # Build
 RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 GO111MODULE=on go build -a -o manager main.go

README.md

@@ -41,5 +41,5 @@ kubectl apply -f my-export.yaml
 Check running controller if it correctly detects newly created resource
 
 ```
-2021-04-16T14:41:01.686-0700	INFO	controllers.ServiceExport	ServiceExport detected: demo/my-service-name
+2021-05-10T18:23:28.674-0700	ERROR	controllers.ServiceExport	no service found for ServiceExport	{"serviceexport": "demo/my-service-name", "Namespace": "demo", "Name": "my-service-name", "error": "Service \"my-service-name\" not found"}
 ```

config/rbac/role.yaml

@@ -11,8 +11,6 @@ rules:
   resources:
   - serviceexports
   verbs:
-  - create
-  - delete
   - get
   - list
   - patch
@@ -21,10 +19,9 @@ rules:
 - apiGroups:
   - multicluster.k8s.aws
   resources:
-  - serviceexports/status
+  - serviceexports/finalizers
   verbs:
   - get
-  - patch
   - update
 - apiGroups:
   - multicluster.k8s.aws

controllers/serviceexport_controller.go

@@ -18,6 +18,7 @@ package main
 
 import (
 	"flag"
+	"github.com/aws/aws-k8s-mcs-controller/pkg/cloudmap"
 	"os"
 
 	// Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
@@ -31,9 +32,9 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/healthz"
 	"sigs.k8s.io/controller-runtime/pkg/log/zap"
 
-	multiclusterv1alpha1 "github.com/aws/aws-k8s-mcs-controller/api/v1alpha1"
-	"github.com/aws/aws-k8s-mcs-controller/controllers"
-	//+kubebuilder:scaffold:imports
+	multiclusterv1alpha1 "github.com/aws/aws-k8s-mcs-controller/pkg/api/v1alpha1"
+	"github.com/aws/aws-k8s-mcs-controller/pkg/controllers"
+	// +kubebuilder:scaffold:imports
 )
 
 var (
@@ -79,13 +80,15 @@ func main() {
 	}
 
 	if err = (&controllers.ServiceExportReconciler{
-		Client: mgr.GetClient(),
-		Log:    ctrl.Log.WithName("controllers").WithName("ServiceExport"),
-		Scheme: mgr.GetScheme(),
+		Client:   mgr.GetClient(),
+		Log:      ctrl.Log.WithName("controllers").WithName("ServiceExport"),
+		Scheme:   mgr.GetScheme(),
+		Cloudmap: &cloudmap.ClientMock{Log: ctrl.Log.WithName("cloudmap")},
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "ServiceExport")
 		os.Exit(1)
 	}
+
 	if err = (&controllers.ServiceImportReconciler{
 		Client: mgr.GetClient(),
 		Log:    ctrl.Log.WithName("controllers").WithName("ServiceImport"),