in internal/testhelpers/resources.go [362:379]
func (cc *TestCaseClient) GetAuthProxyWorkloadAfterReconcile(ctx context.Context, key types.NamespacedName) (*cloudsqlapi.AuthProxyWorkload, error) {
createdPodmod := &cloudsqlapi.AuthProxyWorkload{}
// We'll need to retry getting this newly created resource, given that creation may not immediately happen.
err := RetryUntilSuccess(6, DefaultRetryInterval, func() error {
err := cc.Client.Get(ctx, key, createdPodmod)
if err != nil {
return err
}
if GetConditionStatus(createdPodmod.Status.Conditions, cloudsqlapi.ConditionUpToDate) != metav1.ConditionTrue {
return errors.New("AuthProxyWorkload found, but reconcile not complete yet")
}
return nil
})
if err != nil {
return nil, err
}
return createdPodmod, nil
}