diff --git a/pkg/injector/pod_patch.go b/pkg/injector/pod_patch.go index ec5465e..b7764e9 100644 --- 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 index ab3f63c..a2352ec 100644 --- 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",