diff options
Diffstat (limited to 'certServiceK8sExternalProvider/src/cmpv2controller/cmpv2_issuer_controller.go')
-rw-r--r-- | certServiceK8sExternalProvider/src/cmpv2controller/cmpv2_issuer_controller.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/certServiceK8sExternalProvider/src/cmpv2controller/cmpv2_issuer_controller.go b/certServiceK8sExternalProvider/src/cmpv2controller/cmpv2_issuer_controller.go index 1b4e5312..c6e0e1da 100644 --- a/certServiceK8sExternalProvider/src/cmpv2controller/cmpv2_issuer_controller.go +++ b/certServiceK8sExternalProvider/src/cmpv2controller/cmpv2_issuer_controller.go @@ -83,7 +83,7 @@ func (controller *CMPv2IssuerController) Reconcile(req ctrl.Request) (ctrl.Resul return ctrl.Result{}, err } - // 4. Create CMPv2 provisioner and store the instance for further use + // 4. Create CMPv2 provisioner provisioner, err := provisioners.CreateProvisioner(issuer, secret) if err != nil { log.Error(err, "failed to initialize provisioner") @@ -91,9 +91,14 @@ func (controller *CMPv2IssuerController) Reconcile(req ctrl.Request) (ctrl.Resul handleErrorProvisionerInitialization(ctx, log, err, statusUpdater) return ctrl.Result{}, err } + + // 5. Check health of the provisioner and store the instance for further use + if err := provisioner.CheckHealth(); err != nil { + return ctrl.Result{}, err + } provisioners.Store(req.NamespacedName, provisioner) - // 5. Update the status of CMPv2Issuer to 'Validated' + // 6. Update the status of CMPv2Issuer to 'Validated' if err := updateCMPv2IssuerStatusToVerified(statusUpdater, ctx, log); err != nil { handleErrorUpdatingCMPv2IssuerStatus(log, err) return ctrl.Result{}, err |