feat: Prevent deletes in consumers and streams

controllers/jetstream/consumer.go

@@ -387,6 +387,11 @@ func deleteConsumer(ctx context.Context, c jsmClient, spec apis.ConsumerSpec) (e
 		}
 	}()
 
+	if spec.PreventDelete {
+		fmt.Printf("Consumer %q is configured to preventDelete on stream %q:\n", stream, consumer)
+		return nil
+	}
+
 	var apierr jsmapi.ApiError
 	cn, err := c.LoadConsumer(ctx, stream, consumer)
 	if errors.As(err, &apierr) && apierr.NotFoundError() {

controllers/jetstream/stream.go

@@ -397,6 +397,11 @@ func deleteStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e
 		}
 	}()
 
+	if spec.PreventDelete {
+		fmt.Printf("Stream %q is configured to preventDelete:\n", name)
+		return nil
+	}
+
 	var apierr jsmapi.ApiError
 	str, err := c.LoadStream(ctx, name)
 	if errors.As(err, &apierr) && apierr.NotFoundError() {

deploy/crds.yml

@@ -189,6 +189,10 @@ spec:
                   source:
                     type: string
                     description: Messages will be published from that subject to the destination subject.
+              preventDelete:
+                description: When true, the managed Stream will not be deleted when the resource is deleted
+                type: boolean
+                default: false
           status:
             type: object
             properties:
@@ -551,6 +555,10 @@ spec:
                 description: Name of the account to which the Consumer belongs.
                 type: string
                 pattern: '^[^.*>]*$'
+              preventDelete:
+                description: When true, the managed Consumer will not be deleted when the resource is deleted
+                type: boolean
+                default: false
           status:
             type: object
             properties:

pkg/jetstream/apis/jetstream/v1beta2/consumertypes.go

@@ -30,6 +30,7 @@ type ConsumerSpec struct {
 	DeliverPolicy      string   `json:"deliverPolicy"`
 	DeliverSubject     string   `json:"deliverSubject"`
 	Description        string   `json:"description"`
+	PreventDelete      bool     `json:"preventDelete"`
 	DurableName        string   `json:"durableName"`
 	FilterSubject      string   `json:"filterSubject"`
 	FlowControl        bool     `json:"flowControl"`

pkg/jetstream/apis/jetstream/v1beta2/streamtypes.go

@@ -25,6 +25,7 @@ type StreamSpec struct {
 	Account           string                `json:"account"`
 	Creds             string                `json:"creds"`
 	Description       string                `json:"description"`
+	PreventDelete     bool                  `json:"preventDelete"`
 	Discard           string                `json:"discard"`
 	DuplicateWindow   string                `json:"duplicateWindow"`
 	MaxAge            string                `json:"maxAge"`