Add Function Status

Author: RobertIndie

operator/api/v1alpha1/function_types.go

@@ -83,8 +83,16 @@ type PulsarSinkSpec struct {
 
 // FunctionStatus defines the observed state of Function
 type FunctionStatus struct {
-	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// Number of available pods (ready for at least minReadySeconds)
+	AvailableReplicas int32 `json:"availableReplicas,omitempty"`
+	// Total number of ready pods
+	ReadyReplicas int32 `json:"readyReplicas,omitempty"`
+	// Total number of non-terminated pods targeted by this deployment
+	Replicas int32 `json:"replicas,omitempty"`
+	// Total number of updated pods
+	UpdatedReplicas int32 `json:"updatedReplicas,omitempty"`
+	// Most recent generation observed for this Function
+	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
 }
 
 // +kubebuilder:object:root=true

operator/api/v1alpha1/zz_generated.deepcopy.go

@@ -63,6 +63,9 @@ func main() {
 	var probeAddr string
 	var secureMetrics bool
 	var enableHTTP2 bool
+	var pulsarServiceUrl string
+	var pulsarAuthPlugin string
+	var pulsarAuthParams string
 	var tlsOpts []func(*tls.Config)
 	flag.StringVar(&metricsAddr, "metrics-bind-address", "0", "The address the metrics endpoint binds to. "+
 		"Use :8443 for HTTPS or :8080 for HTTP, or leave as 0 to disable the metrics service.")
@@ -81,12 +84,23 @@ func main() {
 	flag.StringVar(&metricsCertKey, "metrics-cert-key", "tls.key", "The name of the metrics server key file.")
 	flag.BoolVar(&enableHTTP2, "enable-http2", false,
 		"If set, HTTP/2 will be enabled for the metrics and webhook servers")
+	// Pulsar CLI flags
+	flag.StringVar(&pulsarServiceUrl, "pulsar-service-url", os.Getenv("PULSAR_SERVICE_URL"), "Pulsar service URL")
+	flag.StringVar(&pulsarAuthPlugin, "pulsar-auth-plugin", os.Getenv("PULSAR_AUTH_PLUGIN"), "Pulsar auth plugin")
+	flag.StringVar(&pulsarAuthParams, "pulsar-auth-params", os.Getenv("PULSAR_AUTH_PARAMS"), "Pulsar auth params")
 	opts := zap.Options{
 		Development: true,
 	}
 	opts.BindFlags(flag.CommandLine)
 	flag.Parse()
 
+	// Build Config struct (no need to set env)
+	config := controller.Config{
+		PulsarServiceURL: pulsarServiceUrl,
+		PulsarAuthPlugin: pulsarAuthPlugin,
+		PulsarAuthParams: pulsarAuthParams,
+	}
+
 	ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))
 
 	// if the enable-http2 flag is false (the default), http/2 should be disabled
@@ -212,6 +226,7 @@ func main() {
 	if err = (&controller.FunctionReconciler{
 		Client: mgr.GetClient(),
 		Scheme: mgr.GetScheme(),
+		Config: config,
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "Function")
 		os.Exit(1)

operator/cmd/main.go

@@ -112,6 +112,28 @@ spec:
             type: object
           status:
             description: FunctionStatus defines the observed state of Function
+            properties:
+              availableReplicas:
+                description: Number of available pods (ready for at least minReadySeconds)
+                format: int32
+                type: integer
+              observedGeneration:
+                description: Most recent generation observed for this Function
+                format: int64
+                type: integer
+              readyReplicas:
+                description: Total number of ready pods
+                format: int32
+                type: integer
+              replicas:
+                description: Total number of non-terminated pods targeted by this
+                  deployment
+                format: int32
+                type: integer
+              updatedReplicas:
+                description: Total number of updated pods
+                format: int32
+                type: integer
             type: object
         type: object
     served: true

operator/config/crd/bases/fs.functionstream.github.io_functions.yaml

@@ -114,6 +114,28 @@ spec:
             type: object
           status:
             description: FunctionStatus defines the observed state of Function
+            properties:
+              availableReplicas:
+                description: Number of available pods (ready for at least minReadySeconds)
+                format: int32
+                type: integer
+              observedGeneration:
+                description: Most recent generation observed for this Function
+                format: int64
+                type: integer
+              readyReplicas:
+                description: Total number of ready pods
+                format: int32
+                type: integer
+              replicas:
+                description: Total number of non-terminated pods targeted by this
+                  deployment
+                format: int32
+                type: integer
+              updatedReplicas:
+                description: Total number of updated pods
+                format: int32
+                type: integer
             type: object
         type: object
     served: true