@@ -592,17 +592,18 @@ func (r *DesignateReconciler) reconcileNormal(ctx context.Context, instance *des
592592 return ctrl.Result {RequeueAfter : time .Duration (10 ) * time .Second }, nil
593593 }
594594
595- instance .Status .Conditions .MarkTrue (designatev1beta1 .DesignateRabbitMqTransportURLReadyCondition , designatev1beta1 .DesignateRabbitMqTransportURLReadyMessage )
595+ instance .Status .Conditions .MarkTrue (
596+ designatev1beta1 .DesignateRabbitMqTransportURLReadyCondition ,
597+ designatev1beta1 .DesignateRabbitMqTransportURLReadyMessage )
596598
597599 // end transportURL
598-
599- redis , op , err := r .redisCreateOrUpdate (ctx , instance , helper )
600+ hostIPs , err := getRedisServiceIPs (ctx , instance , helper )
600601 if err != nil {
601602 return ctrl.Result {}, err
602603 }
603- if op != controllerutil . OperationResultNone {
604- Log . Info ( fmt . Sprintf ( "Redis %s successfully reconciled - operation: %s" , redis . Name , string ( op )) )
605- }
604+
605+ sort . Strings ( hostIPs )
606+ instance . Status . RedisHostIPs = hostIPs
606607
607608 instance .Status .Conditions .MarkTrue (condition .InputReadyCondition , condition .InputReadyMessage )
608609
@@ -1874,47 +1875,12 @@ func getRedisServiceIPs(
18741875 ctx context.Context ,
18751876 instance * designatev1beta1.Designate ,
18761877 helper * helper.Helper ,
1877- redis * redisv1.Redis ,
18781878) ([]string , error ) {
18791879 getOptions := metav1.GetOptions {}
1880- service , err := helper .GetKClient ().CoreV1 ().Services (instance .Namespace ).Get (ctx , "redis" , getOptions )
1880+ service , err := helper .GetKClient ().CoreV1 ().Services (instance .Namespace ).Get (ctx , instance . Spec . RedisServiceName , getOptions )
18811881 if err != nil {
18821882 return []string {}, err
18831883 }
1884- // TODO Ensure that the correct port is exposed
1884+ // TODO: Ensure that the correct port is exposed
18851885 return service .Spec .ClusterIPs , nil
18861886}
1887-
1888- func (r * DesignateReconciler ) redisCreateOrUpdate (
1889- ctx context.Context ,
1890- instance * designatev1beta1.Designate ,
1891- helper * helper.Helper ,
1892- ) (* redisv1.Redis , controllerutil.OperationResult , error ) {
1893- redis := & redisv1.Redis {
1894- // Use the "global" redis instance.
1895- ObjectMeta : metav1.ObjectMeta {
1896- Name : "redis" ,
1897- Namespace : instance .Namespace ,
1898- },
1899- }
1900-
1901- op , err := controllerutil .CreateOrUpdate (context .TODO (), r .Client , redis , func () error {
1902- // We probably don't want to own the redis instance.
1903- //err := controllerutil.SetControllerReference(instance, redis, r.Scheme)
1904- //return err
1905- return nil
1906- })
1907- if err != nil {
1908- return nil , op , err
1909- }
1910-
1911- hostIPs , err := getRedisServiceIPs (ctx , instance , helper , redis )
1912- if err != nil {
1913- return redis , op , err
1914- }
1915-
1916- sort .Strings (hostIPs )
1917- instance .Status .RedisHostIPs = hostIPs
1918-
1919- return redis , op , err
1920- }
0 commit comments