[camel-k] 03/05: chore(health): Handle readiness probe call errors

[astefanutti]

This is an automated email from the ASF dual-hosted git repository.

astefanutti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git

commit 462f77420714fc58a6ea40671440f4e600f5559e
Author: Antonin Stefanutti <anto...@stefanutti.fr>
AuthorDate: Fri Nov 12 14:37:02 2021 +0100

    chore(health): Handle readiness probe call errors
---
 pkg/controller/integration/monitor.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/pkg/controller/integration/monitor.go 
b/pkg/controller/integration/monitor.go
index 08ee93d..66c7d59 100644
--- a/pkg/controller/integration/monitor.go
+++ b/pkg/controller/integration/monitor.go
@@ -20,6 +20,7 @@ package integration
 import (
        "context"
        "encoding/json"
+       "errors"
        "fmt"
        "reflect"
        "strconv"
@@ -372,8 +373,13 @@ func (action *monitorAction) 
updateIntegrationPhaseAndReadyCondition(ctx context
                        if err == nil {
                                continue
                        }
+                       if errors.Is(err, context.DeadlineExceeded) {
+                               runtimeNotReadyMessages = 
append(runtimeNotReadyMessages, fmt.Sprintf("readiness probe timed out for Pod 
%s/%s", pod.Namespace, pod.Name))
+                               continue
+                       }
                        if !k8serrors.IsServiceUnavailable(err) {
-                               return err
+                               runtimeNotReadyMessages = 
append(runtimeNotReadyMessages, fmt.Sprintf("readiness probe failed for Pod 
%s/%s: %s", pod.Namespace, pod.Name, err.Error()))
+                               continue
                        }
                        health := HealthCheck{}
                        err = json.Unmarshal(body, &health)