Minor error handling change

nats-io · Dec 31, 2024 · b28544f · b28544f
1 parent 7c2e18a
commit b28544f
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/internal/controller/consumer_controller.go b/internal/controller/consumer_controller.go
@@ -178,6 +178,8 @@ func (r *ConsumerReconciler) createOrUpdate(ctx context.Context, log klog.Logger
 		_, err := js.Consumer(ctx, consumer.Spec.StreamName, consumerName)
 		if err == nil {
 			exists = true
+		} else if !errors.Is(err, jetstream.ErrConsumerNotFound) {
+			return err
 		}
 
 		if !exists {

diff --git a/internal/controller/keyvalue_controller.go b/internal/controller/keyvalue_controller.go
@@ -172,6 +172,8 @@ func (r *KeyValueReconciler) createOrUpdate(ctx context.Context, log logr.Logger
 		_, err := js.KeyValue(ctx, targetConfig.Bucket)
 		if err == nil {
 			exists = true
+		} else if !errors.Is(err, jetstream.ErrBucketNotFound) {
+			return err
 		}
 
 		if !exists {

diff --git a/internal/controller/stream_controller.go b/internal/controller/stream_controller.go
@@ -172,6 +172,8 @@ func (r *StreamReconciler) createOrUpdate(ctx context.Context, log logr.Logger,
 		_, err := js.Stream(ctx, targetConfig.Name)
 		if err == nil {
 			exists = true
+		} else if !errors.Is(err, jetstream.ErrStreamNotFound) {
+			return err
 		}
 
 		if !exists {