@@ -19,7 +19,6 @@ package controllers
1919import (
2020 "context"
2121 "fmt"
22- "strings"
2322 "time"
2423
2524 "github.com/go-logr/logr"
@@ -831,7 +830,7 @@ func (r *NeutronAPIReconciler) reconcileNormal(ctx context.Context, instance *ne
831830 instance .Status .Conditions .MarkTrue (condition .InputReadyCondition , condition .InputReadyMessage )
832831 // run check OpenStack secret - end
833832
834- memcached , err := r . getNeutronMemcached (ctx , helper , instance )
833+ memcached , err := memcachedv1 . GetMemcachedByName (ctx , helper , instance . Spec . MemcachedInstance , instance . Namespace )
835834 if err != nil {
836835 if k8s_errors .IsNotFound (err ) {
837836 instance .Status .Conditions .Set (condition .FalseCondition (
@@ -1409,7 +1408,7 @@ func (r *NeutronAPIReconciler) generateServiceSecrets(
14091408 return err
14101409 }
14111410
1412- mc , err := r . getNeutronMemcached (ctx , h , instance )
1411+ mc , err := memcachedv1 . GetMemcachedByName (ctx , h , instance . Spec . MemcachedInstance , instance . Namespace )
14131412 if err != nil {
14141413 return err
14151414 }
@@ -1419,8 +1418,8 @@ func (r *NeutronAPIReconciler) generateServiceSecrets(
14191418 templateParameters ["KeystoneInternalURL" ] = keystoneInternalURL
14201419 templateParameters ["KeystonePublicURL" ] = keystonePublicURL
14211420 templateParameters ["TransportURL" ] = transportURL
1422- templateParameters ["MemcachedServers" ] = strings . Join ( mc .Status . ServerList , "," )
1423- templateParameters ["MemcachedServersWithInet" ] = strings . Join ( mc .Status . ServerListWithInet , "," )
1421+ templateParameters ["MemcachedServers" ] = mc .GetMemcachedServerListString ( )
1422+ templateParameters ["MemcachedServersWithInet" ] = mc .GetMemcachedServerListWithInetString ( )
14241423
14251424 // Other OpenStack services
14261425 servicePassword := string (ospSecret .Data [instance .Spec .PasswordSelectors .Service ])
@@ -1538,26 +1537,6 @@ func (r *NeutronAPIReconciler) memcachedNamespaceMapFunc(ctx context.Context, cl
15381537 }
15391538}
15401539
1541- // getNeutronMemcached - gets the Memcached instance used for neutron cache backend
1542- func (r * NeutronAPIReconciler ) getNeutronMemcached (
1543- ctx context.Context ,
1544- h * helper.Helper ,
1545- instance * neutronv1beta1.NeutronAPI ,
1546- ) (* memcachedv1.Memcached , error ) {
1547- memcached := & memcachedv1.Memcached {}
1548- err := h .GetClient ().Get (
1549- ctx ,
1550- types.NamespacedName {
1551- Name : instance .Spec .MemcachedInstance ,
1552- Namespace : instance .Namespace ,
1553- },
1554- memcached )
1555- if err != nil {
1556- return nil , err
1557- }
1558- return memcached , err
1559- }
1560-
15611540// ensureDB - create neutron DB instance
15621541func (r * NeutronAPIReconciler ) ensureDB (
15631542 ctx context.Context ,
0 commit comments