use status option

Author: anandsyncs

api/v1/search/mongodbsearch_types.go

@@ -143,6 +143,9 @@ func (s *MongoDBSearch) UpdateStatus(phase status.Phase, statusOptions ...status
 	if option, exists := status.GetOption(statusOptions, status.WarningsOption{}); exists {
 		s.Status.Warnings = append(s.Status.Warnings, option.(status.WarningsOption).Warnings...)
 	}
+	if option, exists := status.GetOption(statusOptions, MongoDBSearchVersionOption{}); exists {
+		s.Status.Version = option.(MongoDBSearchVersionOption).Version
+	}
 }
 
 func (s *MongoDBSearch) NamespacedName() types.NamespacedName {

api/v1/search/status_options.go

@@ -0,0 +1,20 @@
+package search
+
+import "github.com/mongodb/mongodb-kubernetes/api/v1/status"
+
+// MongoDBSearchVersionOption captures the reconciled mongot version for status updates.
+type MongoDBSearchVersionOption struct {
+	Version string
+}
+
+var _ status.Option = MongoDBSearchVersionOption{}
+
+// NewMongoDBSearchVersionOption constructs an option that updates MongoDBSearch status version.
+func NewMongoDBSearchVersionOption(version string) MongoDBSearchVersionOption {
+	return MongoDBSearchVersionOption{Version: version}
+}
+
+// Value implements the status.Option interface.
+func (o MongoDBSearchVersionOption) Value() interface{} {
+	return o.Version
+}

controllers/searchcontroller/mongodbsearch_reconcile_helper.go

@@ -139,9 +139,7 @@ func (r *MongoDBSearchReconcileHelper) reconcile(ctx context.Context, log *zap.S
 		return statefulSetStatus
 	}
 
-	r.mdbSearch.Status.Version = version
-
-	return workflow.OK()
+	return workflow.OK().WithAdditionalOptions(searchv1.NewMongoDBSearchVersionOption(version))
 }
 
 func (r *MongoDBSearchReconcileHelper) ensureSourceKeyfile(ctx context.Context, log *zap.SugaredLogger) (statefulset.Modification, error) {