Add functionality for stopping/starting deployment

Makefile

@@ -10,7 +10,7 @@ CERT_MANAGER      := https://github.com/cert-manager/cert-manager/releases/downl
 # KUSTOMIZE_VERSION ?= v4.5.7
 KUSTOMIZE_VERSION ?= v5.4.3
 CTRL_GEN_VERSION  ?= v0.16.3
-KIND_VERSION      ?= v0.22.0
+KIND_VERSION      ?= v0.24.0
 GOLINT_VERSION    ?= v1.61.0
 
 .EXPORT_ALL_VARIABLES:
@@ -85,6 +85,10 @@ manifests: bin/kustomize generate
 	kustomize build config/certmanager > charts/conduit-operator/templates/certificate.yaml
 	kustomize build config/webhook > charts/conduit-operator/templates/webhook.yaml
 
+.PHONY: install
+install: manifests bin/kustomize ## Install CRDs into the K8s cluster specified in ~/.kube/config.
+	kustomize build config/crd | kubectl apply -f -
+
 .PHONY: crds
 crds: bin/controller-gen
 	controller-gen object:headerFile="hack/boilerplate.go.txt" paths="./..."

README.md

@@ -75,7 +75,7 @@ spec:
 
 3. Deploy a sample pipeline configuration
    ```shell
-   kubectl apply -f samples/conf/conduit-generator.yaml
+   kubectl apply -f config/samples/conduit-generator.yaml
    ```
 
 4. Wait for instance to become ready

config/samples/conduit-generator-image-ver.yaml

@@ -1,24 +1,32 @@
-apiVersion: operator.conduit.io/v1
+apiVersion: operator.conduit.io/v1alpha
 kind: Conduit
 metadata:
-  name: conduit-generator
+  name: conduit-generator-image-ver
 spec:
   running: true
   name: generator.log
   description: generator pipeline
   image: ghcr.io/conduitio/conduit
-  version: v0.9.0
+  version: v0.11.1
   connectors:
     - name: source-connector
       type: source
-      plugin: builtin:generator
+      plugin: "builtin:generator"
+      pluginName: "builtin:generator"
       settings:
         - name: format.type
           value: structured
-        - name: format.options
-          value: "id:int,name:string,company:string,trial:bool"
+        - name: format.options.id
+          value: "int"
+        - name: format.options.name
+          value: "string"
+        - name: format.options.company
+          value: "string"
+        - name: format.options.trial
+          value: "bool"
         - name: recordCount
           value: "3"
     - name: destination-connector
       type: destination
-      plugin: builtin:log
+      plugin: "builtin:log"
+      pluginName: "builtin:log"

config/samples/conduit-generator.yaml

@@ -1,4 +1,4 @@
-apiVersion: operator.conduit.io/v1
+apiVersion: operator.conduit.io/v1alpha
 kind: Conduit
 metadata:
   name: conduit-generator

controllers/conduit_controller.go

@@ -231,9 +231,9 @@ func (r *ConduitReconciler) CreateOrUpdateVolume(ctx context.Context, c *v1.Cond
 // Status conditions are set depending on the outcome of the operation.
 func (r *ConduitReconciler) CreateOrUpdateDeployment(ctx context.Context, c *v1.Conduit) error {
 	var (
-		cm         = corev1.ConfigMap{}
-		nn         = c.NamespacedName()
-		oneReplica = int32(1)
+		cm       = corev1.ConfigMap{}
+		nn       = c.NamespacedName()
+		replicas = r.getReplicas(c)
 
 		deployment = appsv1.Deployment{
 			ObjectMeta: metav1.ObjectMeta{
@@ -271,7 +271,7 @@ func (r *ConduitReconciler) CreateOrUpdateDeployment(ctx context.Context, c *v1.
 			Strategy: appsv1.DeploymentStrategy{
 				Type: appsv1.RecreateDeploymentStrategyType,
 			},
-			Replicas: &oneReplica,
+			Replicas: &replicas,
 			Selector: &metav1.LabelSelector{},
 			Template: corev1.PodTemplateSpec{
 				ObjectMeta: metav1.ObjectMeta{},
@@ -456,3 +456,10 @@ func (r *ConduitReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		// Owns(&corev1.PersistentVolume{}).
 		Complete(r)
 }
+
+func (r *ConduitReconciler) getReplicas(c *v1.Conduit) int32 {
+	if c.Spec.Running {
+		return 1
+	}
+	return 0
+}