change Nats Health policy to Status() != CONNECTED

osstotalsoft · Mar 22, 2022 · c06feea · c06feea
1 parent 401e8da
commit c06feea
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/pkg/injector/pod_patch.go b/pkg/injector/pod_patch.go
@@ -62,7 +62,7 @@ const (
 	sidecarHealthzPath                = "healthz"
 	defaultHealthzProbeDelaySeconds   = 3
 	defaultHealthzProbeTimeoutSeconds = 3
-	defaultHealthzProbePeriodSeconds  = 10
+	defaultHealthzProbePeriodSeconds  = 15
 	defaultHealthzProbeThreshold      = 3
 	trueString                        = "true"
 )

diff --git a/pkg/messaging/nats/nats.go b/pkg/messaging/nats/nats.go
@@ -365,8 +365,7 @@ func (n *natsStreamingPubSub) IsHealthy(ctx context.Context) healthcheck.HealthR
 	if n.closed ||
 		n.natStreamingConn == nil ||
 		n.natStreamingConn.NatsConn() == nil ||
-		n.natStreamingConn.NatsConn().Status() == nats.CLOSED ||
-		n.natStreamingConn.NatsConn().Status() == nats.DISCONNECTED {
+		n.natStreamingConn.NatsConn().Status() != nats.CONNECTED {
 		return healthcheck.HealthResult{
 			Status:      healthcheck.Unhealthy,
 			Description: "nats pubsub connection is closed",