@@ -3,7 +3,7 @@ package mongodb
33import (
44 "context"
55
6- mongodbv1 "github.com/mongodb/mongodb-kubernetes-operator/mongodb-kubernetes-operator/pkg/apis/mongodb/v1"
6+ mdbv1 "github.com/mongodb/mongodb-kubernetes-operator/mongodb-kubernetes-operator/pkg/apis/mongodb/v1"
77 corev1 "k8s.io/api/core/v1"
88 "k8s.io/apimachinery/pkg/api/errors"
99 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -46,7 +46,7 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error {
4646 }
4747
4848 // Watch for changes to primary resource MongoDB
49- err = c .Watch (& source.Kind {Type : & mongodbv1 .MongoDB {}}, & handler.EnqueueRequestForObject {})
49+ err = c .Watch (& source.Kind {Type : & mdbv1 .MongoDB {}}, & handler.EnqueueRequestForObject {})
5050 if err != nil {
5151 return err
5252 }
@@ -55,7 +55,7 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error {
5555 // Watch for changes to secondary resource Pods and requeue the owner MongoDB
5656 err = c .Watch (& source.Kind {Type : & corev1.Pod {}}, & handler.EnqueueRequestForOwner {
5757 IsController : true ,
58- OwnerType : & mongodbv1 .MongoDB {},
58+ OwnerType : & mdbv1 .MongoDB {},
5959 })
6060 if err != nil {
6161 return err
@@ -87,7 +87,7 @@ func (r *ReplicaSetController) Reconcile(request reconcile.Request) (reconcile.R
8787 reqLogger .Info ("Reconciling MongoDB" )
8888
8989 // Fetch the MongoDB instance
90- instance := & mongodbv1 .MongoDB {}
90+ instance := & mdbv1 .MongoDB {}
9191 err := r .client .Get (context .TODO (), request .NamespacedName , instance )
9292 if err != nil {
9393 if errors .IsNotFound (err ) {
@@ -130,7 +130,7 @@ func (r *ReplicaSetController) Reconcile(request reconcile.Request) (reconcile.R
130130}
131131
132132// newPodForCR returns a busybox pod with the same name/namespace as the cr
133- func newPodForCR (cr * mongodbv1 .MongoDB ) * corev1.Pod {
133+ func newPodForCR (cr * mdbv1 .MongoDB ) * corev1.Pod {
134134 labels := map [string ]string {
135135 "app" : cr .Name ,
136136 }
0 commit comments