feat: Add HorizonSource (#416)

Closes: #392
Signed-off-by: Michael Gasch <mgasch@vmware.com>
Signed-off-by: Michael Gasch <15986659+embano1@users.noreply.github.com>

README.md

@@ -22,8 +22,9 @@ vSphere API from Kubernetes objects, e.g. a `Job`.
 
 - `VSphereSource` to create VMware vSphere (vCenter) event sources
 - `VSphereBinding` to inject VMware vSphere (vCenter) credentials
+- `HorizonSource` to create VMware Horizon event sources
 
-## Install Tanzu Sources for Knative
+## Install Tanzu Sources CRDs for Knative
 
 ### Install via Release (`latest`)
 
@@ -38,15 +39,15 @@ Install the CRD providing the control / dataplane for the various `Sources` and
 
 ```shell
 # define environment variables accordingly, e.g. when using kind
-# export KIND_CLUSTER_NAME=horizon
-# export KO_DOCKER_REPO=kind.local
+export KIND_CLUSTER_NAME=vmware
+export KO_DOCKER_REPO=kind.local
 
 ko apply -BRf config
 ```
 
 ## Examples
 
-To see examples of the Source and Binding in action, check out our
+To see examples of the `Sources` and `Bindings` in action, check out our
 [samples](./samples/README.md) directory.
 
 ## Basic `VSphereSource` Example
@@ -587,8 +588,8 @@ kubectl get vspheresource
 NAME                SOURCE                     SINK                                                                              READY   REASON
 example-vc-source   https://my-vc.corp.local   http://broker-ingress.knative-eventing.svc.cluster.local/default/example-broker   True
 
-kubectl rollout restart deployment/example-vc-source-deployment
-deployment.apps/example-vc-source-deployment restarted
+kubectl rollout restart deployment/example-vc-source-adapter
+deployment.apps/example-vc-source-adapter restarted
 ```
 
 ⚠️ **Note:** To avoid losing events due to this (brief) downtime, consider

cmd/horizon-adapter/kodata/HEAD

@@ -0,0 +1 @@
+../../../.git/HEAD

cmd/horizon-adapter/kodata/LICENSE

@@ -0,0 +1 @@
+../../../LICENSE

cmd/horizon-adapter/kodata/refs

@@ -0,0 +1 @@
+../../../.git/refs

cmd/horizon-adapter/main.go

@@ -0,0 +1,20 @@
+/*
+Copyright 2022 VMware, Inc.
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package main
+
+import (
+	"knative.dev/eventing/pkg/adapter/v2"
+
+	myadapter "github.com/vmware-tanzu/sources-for-knative/pkg/horizon"
+)
+
+const (
+	adapterName = "horizon-source-adapter"
+)
+
+func main() {
+	adapter.Main(adapterName, myadapter.NewEnv, myadapter.NewAdapter)
+}

cmd/horizon-controller/kodata/HEAD

@@ -0,0 +1 @@
+../../../.git/HEAD

cmd/horizon-controller/kodata/LICENSE

@@ -0,0 +1 @@
+../../../LICENSE

cmd/horizon-controller/kodata/refs

@@ -0,0 +1 @@
+../../../.git/refs

cmd/horizon-controller/main.go

@@ -0,0 +1,22 @@
+/*
+Copyright 2022 VMware, Inc.
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package main
+
+import (
+	// The set of controllers this controller process runs.
+	"github.com/vmware-tanzu/sources-for-knative/pkg/reconciler/horizonsource"
+
+	// This defines the shared main for injected controllers.
+	"knative.dev/pkg/injection/sharedmain"
+)
+
+const (
+	controllerName = "horizon-source-controller"
+)
+
+func main() {
+	sharedmain.Main(controllerName, horizonsource.NewController)
+}

cmd/horizon-webhook/kodata/HEAD

@@ -0,0 +1 @@
+../../../.git/HEAD

cmd/horizon-webhook/kodata/LICENSE

@@ -0,0 +1 @@
+../../../LICENSE

cmd/horizon-webhook/kodata/refs

@@ -0,0 +1 @@
+../../../.git/refs

cmd/horizon-webhook/main.go

@@ -0,0 +1,122 @@
+/*
+Copyright 2022 VMware, Inc.
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package main
+
+import (
+	"context"
+
+	"k8s.io/apimachinery/pkg/runtime/schema"
+	"knative.dev/pkg/configmap"
+	"knative.dev/pkg/controller"
+	"knative.dev/pkg/injection/sharedmain"
+	"knative.dev/pkg/logging"
+	"knative.dev/pkg/metrics"
+	"knative.dev/pkg/signals"
+	"knative.dev/pkg/webhook"
+	"knative.dev/pkg/webhook/certificates"
+	"knative.dev/pkg/webhook/configmaps"
+	"knative.dev/pkg/webhook/resourcesemantics"
+	"knative.dev/pkg/webhook/resourcesemantics/defaulting"
+	"knative.dev/pkg/webhook/resourcesemantics/validation"
+
+	"github.com/vmware-tanzu/sources-for-knative/pkg/apis/sources/v1alpha1"
+)
+
+var types = map[schema.GroupVersionKind]resourcesemantics.GenericCRD{
+	// List the types to validate
+	v1alpha1.SchemeGroupVersion.WithKind("HorizonSource"): &v1alpha1.HorizonSource{},
+}
+
+var callbacks = map[schema.GroupVersionKind]validation.Callback{}
+
+const admissionWebhookName = "horizon-source-webhook"
+
+// NewDefaultingAdmissionController sets up mutating webhook.
+func NewDefaultingAdmissionController(ctx context.Context, cmw configmap.Watcher) *controller.Impl {
+	return defaulting.NewAdmissionController(ctx,
+
+		// Name of the resource webhook.
+		"defaulting.webhook.horizon.sources.tanzu.vmware.com",
+
+		// The path on which to serve the webhook.
+		"/defaulting",
+
+		// The resource to default.
+		types,
+
+		// A function that infuses the context passed to Validate/SetDefaults with custom metadata.
+		func(ctx context.Context) context.Context {
+			// Here is where you would infuse the context with state
+			// (e.g. attach a store with configmap data)
+			return ctx
+		},
+
+		// Whether to disallow unknown fields.
+		true,
+	)
+}
+
+// NewValidationAdmissionController sets up validation webhook.
+func NewValidationAdmissionController(ctx context.Context, cmw configmap.Watcher) *controller.Impl {
+	return validation.NewAdmissionController(ctx,
+
+		// Name of the resource webhook.
+		"validation.webhook.horizon.sources.tanzu.vmware.com",
+
+		// The path on which to serve the webhook.
+		"/resource-validation",
+
+		// The resources to validate.
+		types,
+
+		// A function that infuses the context passed to Validate/SetDefaults with custom metadata.
+		func(ctx context.Context) context.Context {
+			// Here is where you would infuse the context with state
+			// (e.g. attach a store with configmap data)
+			return ctx
+		},
+
+		// Whether to disallow unknown fields.
+		true,
+
+		// Extra validating callbacks to be applied to resources.
+		callbacks,
+	)
+}
+
+// NewConfigValidationController sets up ConfigMap validation webhook.
+func NewConfigValidationController(ctx context.Context, cmw configmap.Watcher) *controller.Impl {
+	return configmaps.NewAdmissionController(ctx,
+
+		// Name of the configmap webhook.
+		"config.webhook.horizon.sources.tanzu.vmware.com",
+
+		// The path on which to serve the webhook.
+		"/config-validation",
+
+		// The configmaps to validate.
+		configmap.Constructors{
+			logging.ConfigMapName(): logging.NewConfigFromConfigMap,
+			metrics.ConfigMapName(): metrics.NewObservabilityConfigFromConfigMap,
+		},
+	)
+}
+
+func main() {
+	// Set up a signal context with our webhook options
+	ctx := webhook.WithOptions(signals.NewContext(), webhook.Options{
+		ServiceName: admissionWebhookName,
+		Port:        8443,
+		SecretName:  "webhook-certs",
+	})
+
+	sharedmain.WebhookMainWithContext(ctx, admissionWebhookName,
+		certificates.NewController,
+		NewDefaultingAdmissionController,
+		NewValidationAdmissionController,
+		NewConfigValidationController,
+	)
+}

cmd/vsphere-adapter/main.go

@@ -20,9 +20,13 @@ import (
 	"github.com/vmware-tanzu/sources-for-knative/pkg/vsphere"
 )
 
+const (
+	adapterName = "vsphere-source-adapter"
+)
+
 func main() {
 	ctx := signals.NewContext()
 	kc := kubernetes.NewForConfigOrDie(injection.ParseAndGetRESTConfigOrDie())
 	ctx = context.WithValue(ctx, kubeclient.Key{}, kc)
-	adapter.MainWithContext(ctx, "vspheresource", vsphere.NewEnvConfig, vsphere.NewAdapter)
+	adapter.MainWithContext(ctx, adapterName, vsphere.NewEnvConfig, vsphere.NewAdapter)
 }

cmd/vsphere-controller/main.go

@@ -36,7 +36,9 @@ var types = map[schema.GroupVersionKind]resourcesemantics.GenericCRD{
 	v1alpha1.SchemeGroupVersion.WithKind("VSphereBinding"): &v1alpha1.VSphereBinding{},
 }
 
-const admissionWebhookName = "vsphere-source-webhook"
+const (
+	admissionWebhookName = "vsphere-source-webhook"
+)
 
 func NewDefaultingAdmissionController(ctx context.Context, cmw configmap.Watcher) *controller.Impl {
 	return defaulting.NewAdmissionController(ctx,

config/200-horizon-serviceaccount.yaml

@@ -0,0 +1,20 @@
+# Copyright 2022 VMware, Inc.
+# SPDX-License-Identifier: Apache-2.0
+
+apiVersion: v1
+kind: ServiceAccount
+metadata:
+  name: horizon-source-controller
+  namespace: vmware-sources
+  labels:
+    sources.tanzu.vmware.com/release: devel
+
+---
+
+apiVersion: v1
+kind: ServiceAccount
+metadata:
+  name: horizon-source-webhook
+  namespace: vmware-sources
+  labels:
+    sources.tanzu.vmware.com/release: devel

config/vsphere/200-clusterrole.yaml → config/200-vsphere-clusterrole.yaml

@@ -1,4 +1,4 @@
-# Copyright 2020 VMware, Inc.
+# Copyright 2022 VMware, Inc.
 # SPDX-License-Identifier: Apache-2.0
 
 kind: ClusterRole

config/vsphere/200-podspecable-binding-clusterrole.yaml → config/200-vsphere-podspecable-binding-clusterrole.yaml

@@ -1,4 +1,4 @@
-# Copyright 2020 VMware, Inc.
+# Copyright 2022 VMware, Inc.
 # SPDX-License-Identifier: Apache-2.0
 
 # Use this aggregated ClusterRole when you need readonly access to "podspecables

config/vsphere/200-serviceaccount.yaml → config/200-vsphere-serviceaccount.yaml

@@ -1,4 +1,4 @@
-# Copyright 2020 VMware, Inc.
+# Copyright 2022 VMware, Inc.
 # SPDX-License-Identifier: Apache-2.0
 
 apiVersion: v1

config/201-horizon-clusterrole.yaml

@@ -0,0 +1,96 @@
+# Copyright 2022 VMware, Inc.
+# SPDX-License-Identifier: Apache-2.0
+
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRole
+metadata:
+  name: horizon-source-controller
+  labels:
+    sources.tanzu.vmware.com/release: devel
+rules:
+- apiGroups:
+  - apps
+  resources:
+  - deployments
+  verbs: &everything
+  - get
+  - list
+  - watch
+  - create
+  - update
+  - patch
+  - delete
+
+- apiGroups:
+  - rbac.authorization.k8s.io
+  resources:
+  - clusterroles
+  verbs:
+  - list
+
+- apiGroups:
+  - ""
+  resources:
+  - events
+  verbs: *everything
+
+- apiGroups:
+  - sources.tanzu.vmware.com
+  resources:
+  - horizonsources
+  verbs: *everything
+
+- apiGroups:
+  - sources.tanzu.vmware.com
+  resources:
+  - horizonsources/status
+  - horizonsources/finalizers
+  verbs:
+  - get
+  - update
+  - patch
+
+- apiGroups:
+  - ""
+  resources:
+  - configmaps
+  - secrets
+  verbs:
+  - get
+  - list
+  - watch
+
+# manage adapter SAs
+- apiGroups:
+  - ""
+  resources:
+  - serviceaccounts
+  verbs: *everything
+
+
+# For Leader Election
+- apiGroups:
+    - coordination.k8s.io
+  resources:
+    - leases
+  verbs: *everything
+
+---
+# The role is needed for the aggregated role source-observer in knative-eventing to provide readonly access to "Sources".
+# See https://github.com/knative/eventing/blob/master/config/200-source-observer-clusterrole.yaml.
+kind: ClusterRole
+apiVersion: rbac.authorization.k8s.io/v1
+metadata:
+  name: horizon-source-observer
+  labels:
+    sources.tanzu.vmware.com/release: devel
+    duck.knative.dev/source: "true"
+rules:
+  - apiGroups:
+      - "sources.eventing.knative.dev"
+    resources:
+      - "horizonsources"
+    verbs:
+      - get
+      - list
+      - watch