IR additional health status (#2934)

CHANGELOG.md

@@ -5,6 +5,8 @@ Changelog for NeoFS Node
 
 ### Added
 - More effective FSTree writer for HDDs, new configuration options for it (#2814)
+- New health status `INITIALIZING_NETWORK` in inner ring (#2934)
+- Expose health status of inner ring via Prometheus (#2934)
 
 ### Fixed
 

pkg/innerring/innerring.go

@@ -308,7 +308,7 @@ func (s *Server) registerCloser(f func() error) {
 	s.closers = append(s.closers, f)
 }
 
-// New creates instance of inner ring sever structure.
+// New creates instance of inner ring server structure.
 func New(ctx context.Context, log *zap.Logger, cfg *viper.Viper, errChan chan<- error) (*Server, error) {
 	var err error
 	server := &Server{log: log}
@@ -550,6 +550,7 @@ func New(ctx context.Context, log *zap.Logger, cfg *viper.Viper, errChan chan<-
 
 		setNetworkSettingsDefaults(&deployPrm.NetmapContract.Config)
 
+		server.setHealthStatus(control.HealthStatus_INITIALIZING_NETWORK)
 		err = deploy.Deploy(ctx, deployPrm)
 		if err != nil {
 			return nil, fmt.Errorf("deploy Sidechain: %w", err)

pkg/innerring/state.go

@@ -201,6 +201,9 @@ func (s *Server) ResetEpochTimer(h uint32) error {
 
 func (s *Server) setHealthStatus(hs control.HealthStatus) {
 	s.healthStatus.Store(hs)
+	if s.metrics != nil {
+		s.metrics.SetHealthCheck(int32(hs))
+	}
 }
 
 // HealthStatus returns the current health status of the IR application.

pkg/metrics/innerring.go

@@ -8,7 +8,8 @@ const innerRingNameSpace = "neofs_ir"
 
 // InnerRingServiceMetrics contains metrics collected by inner ring.
 type InnerRingServiceMetrics struct {
-	epoch prometheus.Gauge
+	epoch       prometheus.Gauge
+	healthCheck prometheus.Gauge
 }
 
 // NewInnerRingMetrics returns new instance of metrics collectors for inner ring.
@@ -23,12 +24,25 @@ func NewInnerRingMetrics(version string) InnerRingServiceMetrics {
 	})
 	prometheus.MustRegister(epoch)
 
+	healthCheck := prometheus.NewGauge(prometheus.GaugeOpts{
+		Namespace: innerRingNameSpace,
+		Subsystem: stateSubsystem,
+		Name:      "health",
+		Help:      "Current ir state",
+	})
+	prometheus.MustRegister(healthCheck)
+
 	return InnerRingServiceMetrics{
-		epoch: epoch,
+		epoch:       epoch,
+		healthCheck: healthCheck,
 	}
 }
 
 // SetEpoch updates epoch metrics.
 func (m InnerRingServiceMetrics) SetEpoch(epoch uint64) {
 	m.epoch.Set(float64(epoch))
 }
+
+func (m InnerRingServiceMetrics) SetHealthCheck(healthCheck int32) {
+	m.healthCheck.Set(float64(healthCheck))
+}

pkg/services/control/ir/types.proto

@@ -26,4 +26,7 @@ enum HealthStatus {
 
     // IR application is shutting down.
     SHUTTING_DOWN = 3;
+
+    // Initializing Neo network
+    INITIALIZING_NETWORK = 4;
 }