test: Add endpointslice-controller integration tests

Author: rg0now

examples/endpointslice-controller/README.md

@@ -78,4 +78,4 @@ controllers:
                     - "-"
                     - $.id.port
     target:
-      kind: EndpointSliceView
+      kind: EndpointView

examples/endpointslice-controller/endpointslice-controller-gather-spec.yaml

@@ -46,30 +46,31 @@ controllers:
       "@aggregate":
         - "@project":
             metadata:
-              name: $.EndpointSlice.metadata.name
-              namespace: $.EndpointSlice.metadata.namespace
+              name: $.ServiceView.metadata.name
+              namespace: $.ServiceView.metadata.namespace
             spec: $.ServiceView.spec
             endpoints: $.EndpointSlice.endpoints
-            id:
-              name: $.ServiceView.spec.serviceName
-              namespace: $.ServiceView.metadata.namespace
-              type: $.ServiceView.spec.type
-              protocol: $.ServiceView.spec.ports.protocol
-              port: $.ServiceView.spec.ports.port
         - "@unwind": $.endpoints
         - "@select":
             "@eq": ["$.endpoints.conditions.ready", true]
         - "@unwind": $.endpoints.addresses
         - "@project":
-            # use @merge so that expressions are applied in order
+            metadata:
+              namespace: $.metadata.namespace
+            spec:
+              serviceName: $.spec.serviceName
+              type: $.spec.type
+              port: $.spec.ports.port
+              targetPort: $.spec.ports.targetPort
+              protocol: $.spec.ports.protocol
+              address: $.endpoints.addresses
+        - "@project":
             "@merge":
-              - {metadata: $.metadata}
-              - {spec: $.spec}
-              - {"$.spec.address": $.endpoints.addresses}
-              - "$.metadata.name":
+              metadata:
+                name:
                   "@concat":
-                    - $.id.name
+                    - $.spec.serviceName
                     - "-"
                     - { "@hash": $.spec }
     target:
-      kind: EndpointSliceView
+      kind: EndpointView

examples/endpointslice-controller/endpointslice-controller-spec.yaml

@@ -30,9 +30,9 @@ import (
 )
 
 const (
-	OperatorSpec                          = "examples/endpointslice-controller/endpointslice-controller-spec.yaml"
-	OperatorGatherSpec                    = "examples/endpointslice-controller/endpointslice-controller-gather-spec.yaml"
-	EndpointSliceControllerAnnotationName = "dcontroller.io/endpointslice-controller-enabled"
+	OperatorSpec                    = "examples/endpointslice-controller/endpointslice-controller-spec.yaml"
+	OperatorGatherSpec              = "examples/endpointslice-controller/endpointslice-controller-gather-spec.yaml"
+	EndpointSliceCtrlAnnotationName = "dcontroller.io/endpointslice-controller-enabled"
 )
 
 var (
@@ -125,7 +125,7 @@ type endpointSliceController struct {
 func NewEndpointSliceController(mgr manager.Manager, log logr.Logger) (*endpointSliceController, error) {
 	r := &endpointSliceController{
 		Client: mgr.GetClient(),
-		log:    log.WithName("endpointSlice-ctrl"),
+		log:    log.WithName("endpointslice-ctrl"),
 	}
 
 	on := true
@@ -139,7 +139,7 @@ func NewEndpointSliceController(mgr manager.Manager, log logr.Logger) (*endpoint
 
 	src, err := dreconciler.NewSource(mgr, opv1a1.Source{
 		Resource: opv1a1.Resource{
-			Kind: "EndpointSliceView",
+			Kind: "EndpointView",
 		},
 	}).GetSource()
 	if err != nil {
@@ -174,12 +174,12 @@ func (r *endpointSliceController) Reconcile(ctx context.Context, req dreconciler
 		name := obj.GetName()
 		namespace := obj.GetNamespace()
 
-		r.log.Info("Add/update EndpointSliceView object", "name", name, "namespace", namespace, "spec", fmt.Sprintf("%#v", spec))
+		r.log.Info("Add/update EndpointView object", "name", name, "namespace", namespace, "spec", fmt.Sprintf("%#v", spec))
 
 		// handle upsert event
 
 	case cache.Deleted:
-		r.log.Info("Delete EndpointSliceView object", "name", req.Name, "namespace", req.Namespace)
+		r.log.Info("Delete EndpointView object", "name", req.Name, "namespace", req.Namespace)
 
 		// handle delete event