add controllers

api/v1alpha1/common.go

@@ -16,7 +16,6 @@ package v1alpha1
 
 import (
 	"encoding/json"
-	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"reflect"
 
@@ -90,14 +89,9 @@ func IsPulsarResourceReady(instance reconciler.Object) bool {
 		meta.IsStatusConditionTrue(conditions, ConditionReady)
 }
 
-type FileRef struct {
-	ConfigMapRef *corev1.LocalObjectReference `json:"configMapRef"`
-	Key          string                       `json:"key"`
-}
-
 type PackageContentRef struct {
 	// +optional
-	FileRef *FileRef `json:"fileRef,omitempty"`
+	//persistentVolumeTemplate *corev1.PersistentVolumeClaim `json:"persistentVolumeTemplate,omitempty"`
 
 	// +optional
 	URL string `json:"url,omitempty"`

api/v1alpha1/pulsarfunction_types.go

@@ -99,10 +99,6 @@ type PulsarFunctionSpec struct {
 	// +optional
 	OutputTypeClassName string `json:"outputTypeClassName,omitempty"`
 
-	// Runtime is the runtime of the function
-	// +optional
-	Runtime string `json:"runtime,omitempty"`
-
 	// DeadLetterTopic is the dead letter topic of the function
 	// +optional
 	DeadLetterTopic string `json:"deadLetterTopic,omitempty"`
@@ -111,10 +107,6 @@ type PulsarFunctionSpec struct {
 	// +optional
 	SubName string `json:"subName,omitempty"`
 
-	// FQFN is the FQFN of the function
-	// +optional
-	FQFN string `json:"fqfn,omitempty"`
-
 	// Jar is the jar of the function
 	// +optional
 	Jar *PackageContentRef `json:"jar,omitempty"`
@@ -127,10 +119,6 @@ type PulsarFunctionSpec struct {
 	// +optional
 	Go *PackageContentRef `json:"go,omitempty"`
 
-	// FunctionType is the function type of the function
-	// +optional
-	FunctionType string `json:"functionType,omitempty"`
-
 	// RuntimeFlags is the runtime flags of the function
 	// +optional
 	RuntimeFlags string `json:"runtimeFlags,omitempty"`
@@ -209,6 +197,10 @@ type PulsarFunctionSpec struct {
 
 	// ConnectionRef is the reference to the PulsarConnection resource
 	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`
+
+	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
+	// +optional
+	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
 }
 
 type WindowConfig struct {

api/v1alpha1/pulsarpackage_types.go

@@ -28,10 +28,12 @@ type PulsarPackageSpec struct {
 	// Important: Run "make" to regenerate code after modifying this file
 
 	// PackageURL is the Pulsar Package URL, in format of type://tenant/namespace/package@version
+	// +kubebuilder:validation:Required
 	PackageURL string `json:"packageURL"`
 
-	// FileRef is the reference to the PulsarPackage File content
-	FileRef FileRef `json:"fileRef"`
+	// FileURL is the download-able URL of the package from http or https protocol
+	// +kubebuilder:validation:Required
+	FileURL string `json:"fileURL"`
 
 	// ConnectionRef is the reference to the PulsarConnection resource
 	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`
@@ -44,6 +46,10 @@ type PulsarPackageSpec struct {
 
 	// +optional
 	Properties map[string]string `json:"properties,omitempty"`
+
+	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
+	// +optional
+	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
 }
 
 // PulsarPackageStatus defines the observed state of PulsarPackage

api/v1alpha1/pulsarsink_types.go

@@ -157,6 +157,10 @@ type PulsarSinkSpec struct {
 
 	// ConnectionRef is the reference to the PulsarConnection resource
 	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`
+
+	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
+	// +optional
+	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
 }
 
 // PulsarSinkStatus defines the observed state of PulsarSink

api/v1alpha1/pulsarsource_types.go

@@ -101,6 +101,10 @@ type PulsarSourceSpec struct {
 
 	// ConnectionRef is the reference to the PulsarConnection resource
 	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`
+
+	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
+	// +optional
+	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
 }
 
 type BatchSourceConfig struct {