Merge pull request #10296 from dragonchaser/nats-probes

add nats checks

ocis-pkg/handlers/checker.go

@@ -50,6 +50,15 @@ func (c CheckHandlerConfiguration) WithCheck(name string, f check) CheckHandlerC
 	return c
 }
 
+// WithInheritedChecksFrom appends the checks from another CheckHandlerConfiguration.
+func (c CheckHandlerConfiguration) WithInheritedChecksFrom(other CheckHandlerConfiguration) CheckHandlerConfiguration {
+	for name, check := range other.checks {
+		c.WithCheck(name, check)
+	}
+
+	return c
+}
+
 // WithLimit limits the number of active goroutines for the checks to at most n
 func (c CheckHandlerConfiguration) WithLimit(n int) CheckHandlerConfiguration {
 	c.limit = n

services/nats/pkg/server/debug/server.go

@@ -2,6 +2,7 @@ package debug
 
 import (
 	"net/http"
+	"strconv"
 
 	"github.com/owncloud/ocis/v2/ocis-pkg/handlers"
 	"github.com/owncloud/ocis/v2/ocis-pkg/service/debug"
@@ -12,9 +13,12 @@ import (
 func Server(opts ...Option) (*http.Server, error) {
 	options := newOptions(opts...)
 
+	// For nats readiness and liveness checks are identical
+	// the nats server will neither be healthy nor ready when it can not reach the nats server/cluster
 	checkHandler := handlers.NewCheckHandler(
 		handlers.NewCheckHandlerConfiguration().
-			WithLogger(options.Logger),
+			WithLogger(options.Logger).
+			WithCheck("nats reachability", handlers.NewNatsCheck(options.Config.Nats.Host+":"+strconv.Itoa(options.Config.Nats.Port))),
 	)
 
 	return debug.NewService(