Integrate Cloud Map API

Author: astaticvoid

README.md

@@ -1,5 +1,12 @@
 # How to build and run
 
+Pre-requisite: Create Private DNS Namespace in Cloud Map `demo`
+
+Set region
+```
+export AWS_REGION=us-west-2
+```
+
 Spin up a local Kubernetes cluster using `kind`
 
 ```
@@ -19,6 +26,51 @@ Run controller
 make run
 ```
 
+Create a testing deployment
+
+```
+# my-deployment.yaml
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  namespace: demo
+  name: nginx-deployment
+  labels:
+    app: nginx
+spec:
+  replicas: 5
+  selector:
+    matchLabels:
+      app: nginx
+  template:
+    metadata:
+      labels:
+        app: nginx
+    spec:
+      containers:
+      - name: nginx
+        image: nginx:1.14.2
+        ports:
+        - containerPort: 80
+```
+
+Create a testing Service
+
+```
+# my-service.yaml
+kind: Service
+apiVersion: v1
+metadata:
+  namespace: demo
+  name: my-service-name
+spec:
+  selector:
+    app: nginx
+  ports:
+    - port: 8080
+      targetPort: 80
+```
+
 Create a testing ServiceExport resource
 
 ```
@@ -31,15 +83,24 @@ metadata:
  name: my-service-name
 ```
 
-Apply config file
+Apply config files
 
 ```
 kubectl create namespace demo
+kubectl apply -f my-deployment.yaml
+kubectl apply -f my-service.yaml
 kubectl apply -f my-export.yaml
 ```
 
 Check running controller if it correctly detects newly created resource
 
 ```
-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"}
+2021-07-09T14:31:26.933-0700	INFO	controllers.ServiceExport	updating Cloud Map service	{"serviceexport": "demo/my-service-name", "namespace": "demo", "name": "my-service-name"}
+2021-07-09T14:31:26.933-0700	INFO	cloudmap	fetching a service	{"namespaceName": "demo", "serviceName": "my-service-name"}
+2021-07-09T14:31:27.341-0700	INFO	cloudmap	creating a new service	{"namespace": "demo", "name": "my-service-name"}
+```
+
+# How to generate mocks and run unit tests
+```
+make test
 ```

aws-k8s-mcs-controller.REMOVED.git-id

@@ -0,0 +1 @@
+112454e82053acea23f71e2ee8e717f2fc8498a7

go.mod

@@ -3,6 +3,9 @@ module github.com/aws/aws-k8s-mcs-controller
 go 1.15
 
 require (
+	github.com/aws/aws-sdk-go-v2 v1.8.1
+	github.com/aws/aws-sdk-go-v2/config v1.6.1
+	github.com/aws/aws-sdk-go-v2/service/servicediscovery v1.7.3
 	github.com/go-logr/logr v0.3.0
 	github.com/golang/mock v1.6.0
 	github.com/onsi/ginkgo v1.14.1

go.sum

@@ -17,10 +17,14 @@ limitations under the License.
 package main
 
 import (
+	"context"
 	"flag"
-	"github.com/aws/aws-k8s-mcs-controller/pkg/cloudmap"
+
+	"github.com/aws/aws-sdk-go-v2/config"
 	"os"
 
+	"github.com/aws/aws-k8s-mcs-controller/pkg/cloudmap"
+
 	// Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
 	// to ensure that exec-entrypoint and run can make use of them.
 	_ "k8s.io/client-go/plugin/pkg/client/auth"
@@ -79,11 +83,20 @@ func main() {
 		os.Exit(1)
 	}
 
+	// TODO: configure session
+	awsCfg, err := config.LoadDefaultConfig(context.TODO(),
+		config.WithRegion(os.Getenv("AWS_REGION")),
+	)
+	if err != nil {
+		setupLog.Error(err, "unable to configure AWS session")
+		os.Exit(1)
+	}
+
 	if err = (&controllers.ServiceExportReconciler{
 		Client:   mgr.GetClient(),
 		Log:      ctrl.Log.WithName("controllers").WithName("ServiceExport"),
 		Scheme:   mgr.GetScheme(),
-		Cloudmap: &cloudmap.ClientMock{Log: ctrl.Log.WithName("cloudmap")},
+		Cloudmap: cloudmap.NewServiceDiscoveryClient(&awsCfg),
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "ServiceExport")
 		os.Exit(1)