@@ -25,6 +25,7 @@ import (
2525 "github.com/IBM/platform-services-go-sdk/resourcemanagerv2"
2626 "github.com/IBM/vpc-go-sdk/vpcv1"
2727 "github.com/sirupsen/logrus"
28+ "k8s.io/apimachinery/pkg/util/wait"
2829 "k8s.io/utils/ptr"
2930
3031 "github.com/openshift/installer/pkg/types"
@@ -1360,11 +1361,18 @@ func (c *Client) AddIPToLoadBalancerPool(ctx context.Context, lbID string, poolN
13601361 clbpmOptions = c .vpcAPI .NewCreateLoadBalancerPoolMemberOptions (lbID , * lbPool .ID , port , lbpmtp )
13611362 logrus .Debugf ("AddIPToLoadBalancerPool: clbpmOptions = %+v" , clbpmOptions )
13621363
1363- lbpm , response , err = c .vpcAPI .CreateLoadBalancerPoolMemberWithContext (ctx , clbpmOptions )
1364- if err != nil {
1365- return fmt .Errorf ("could not add the load balancer pool member and the response = %+v, err = %w" , response , err )
1366- }
1367- logrus .Debugf ("AddIPToLoadBalancerPool: CLBPMWC lbpm = %+v" , lbpm )
1364+ return wait .PollUntilContextCancel (ctx ,
1365+ time .Second * 10 ,
1366+ false ,
1367+ func (ctx context.Context ) (bool , error ) {
1368+ lbpm , response , err = c .vpcAPI .CreateLoadBalancerPoolMemberWithContext (ctx , clbpmOptions )
1369+ if err != nil {
1370+ logrus .Debugf ("AddIPToLoadBalancerPool: could not add the load balancer pool member yet, err = %v" , err )
1371+ return false , nil
1372+ }
13681373
1369- return nil
1374+ logrus .Debugf ("AddIPToLoadBalancerPool: CLBPMWC lbpm = %+v" , lbpm )
1375+
1376+ return true , nil
1377+ })
13701378}
0 commit comments